/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ChangelogState.java | 41 * <li>its generationId</li> 59 * Sets the generationId for the supplied replication domain. 63 * @param generationId 66 public void setDomainGenerationId(DN baseDN, long generationId) argument 68 domainToGenerationId.put(baseDN, generationId); 127 * Returns the Map of domainBaseDN => generationId. 129 * @return a Map of domainBaseDN => generationId
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | StartMsg.java | 45 protected long generationId; field in class:StartMsg 67 * @param generationId The generationId for this server. 70 public StartMsg(short protocolVersion, long generationId) argument 73 this.generationId = generationId; 96 String.valueOf(generationId).getBytes("UTF-8"); 112 /* put the generationId */ 142 String.valueOf(generationId).getBytes("UTF-8"); 160 /* put the generationId */ [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationDbEnv.java | 180 " Read tag baseDn generationId=" + stringData); 185 long generationId; 188 // <generationId> 189 generationId = new Long(str[1]); 207 + " generationId=" + generationId); 210 initGenerationID(generationId); 303 * @param generationId The generationId associated to this domain. 307 public Database getOrAddDb(int serverId, String baseDn, Long generationId) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | DummyReplicationDomain.java | 43 public DummyReplicationDomain(long generationId) argument 45 super(new DomainFakeCfg(null, -1, new TreeSet<String>()), generationId);
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ReplicationDbEnvTest.java | 115 public void encodeDecodeChangelogState(DN baseDN, long generationId, argument 122 put(wholeState, toGenIdEntry(baseDN, generationId)); 136 entry(baseDN, generationId));
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 70 long generationId) throws ConfigException 72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId); 89 long generationId) throws ConfigException 91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId); 68 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, long generationId) argument 87 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, long generationId) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | StartMsg.java | 45 protected long generationId; field in class:StartMsg 67 * @param generationId The generationId for this server. 70 public StartMsg(short protocolVersion, long generationId) argument 73 this.generationId = generationId; 96 String.valueOf(generationId).getBytes("UTF-8"); 112 /* put the generationId */ 142 String.valueOf(generationId).getBytes("UTF-8"); 160 /* put the generationId */ [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationDbEnv.java | 180 " Read tag baseDn generationId=" + stringData); 185 long generationId; 188 // <generationId> 189 generationId = new Long(str[1]); 207 + " generationId=" + generationId); 210 initGenerationID(generationId); 303 * @param generationId The generationId associated to this domain. 307 public Database getOrAddDb(int serverId, String baseDn, Long generationId) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartMsg.java | 75 * @param generationId The generationId for this server. 84 long generationId, 89 super((short) -1 /* version set when sending */, generationId); 251 "\ngenerationId: " + generationId + 81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
|
H A D | StartMsg.java | 42 protected long generationId; field in class:StartMsg 59 * @param generationId The generationId for this server. 62 StartMsg(short protocolVersion, long generationId) argument 65 this.generationId = generationId; 83 builder.appendLongUTF8(generationId); 103 builder.appendLongUTF8(generationId); 144 generationId = scanner.nextLongUTF8(); 155 generationId [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ChangelogState.java | 41 * <li>its generationId</li> 59 * Sets the generationId for the supplied replication domain. 63 * @param generationId 66 public void setDomainGenerationId(DN baseDN, long generationId) argument 68 domainToGenerationId.put(baseDN, generationId); 127 * Returns the Map of domainBaseDN => generationId. 129 * @return a Map of domainBaseDN => generationId
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | ReplServerStartMsg.java | 75 * @param generationId The generationId for this server. 84 long generationId, 89 super((short) -1 /* version set when sending */, generationId); 251 "\ngenerationId: " + generationId + 81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
|
H A D | StartMsg.java | 42 protected long generationId; field in class:StartMsg 59 * @param generationId The generationId for this server. 62 StartMsg(short protocolVersion, long generationId) argument 65 this.generationId = generationId; 83 builder.appendLongUTF8(generationId); 103 builder.appendLongUTF8(generationId); 144 generationId = scanner.nextLongUTF8(); 155 generationId [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ChangelogState.java | 41 * <li>its generationId</li> 57 * Sets the generationId for the supplied replication domain. 61 * @param generationId 64 public void setDomainGenerationId(DN baseDN, long generationId) argument 66 domainToGenerationId.put(baseDN, generationId); 125 * Returns the Map of domainBaseDN => generationId. 127 * @return a Map of domainBaseDN => generationId
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | DummyReplicationDomain.java | 57 public DummyReplicationDomain(long generationId) argument 59 super(new DomainFakeCfg(null, -1, new TreeSet<String>()), generationId);
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 70 long generationId) throws ConfigException 72 super(newConfig(baseDN, serverID, replicationServers, window, heartbeatInterval), generationId); 89 long generationId) throws ConfigException 91 this(baseDN, serverID, replicationServers, 100, heartbeatInterval, generationId); 68 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, long generationId) argument 87 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, long generationId) argument
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/ |
H A D | DSInfo.java | 51 private long generationId = -1; field in class:DSInfo 81 * @param generationId 102 public DSInfo(int dsId, String dsUrl, int rsId, long generationId, argument 111 this.generationId = generationId; 156 return generationId; 258 (generationId == dsInfo.getGenerationId()) && 289 hash = 73 * hash + (int) (this.generationId ^ (this.generationId >>> 32)); 319 sb.append(generationId); [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 78 * @param generationId The generationId for this server. 90 long generationId, 97 super((short) -1 /* version set when sending */, generationId); 364 "\ngenerationId: " + generationId + 87 ReplServerStartDSMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
|
H A D | ReplServerStartMsg.java | 76 * @param generationId The generationId for this server. 85 long generationId, 90 super((short) -1 /* version set when sending */, generationId); 413 "\ngenerationId: " + generationId + 82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
|
H A D | ServerStartECLMsg.java | 76 * @param generationId The generationId for this server. 86 long generationId, 90 super((short) -1 /* version set when sending */, generationId); 355 "\ngenerationId: " + generationId + 81 ServerStartECLMsg(String serverURL, int maxReceiveDelay, int maxReceiveQueue, int maxSendDelay, int maxSendQueue, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
H A D | ServerStartMsg.java | 76 * @param generationId The generationId for this server. 83 long generationId, boolean sslEncryption, 86 super((short) -1 /* version set when sending */, generationId); 394 "\ngenerationId: " + generationId + 81 ServerStartMsg(int serverId2, String serverURL, String baseDn, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | LightweightServerHandler.java | 79 private long generationId = -1; field in class:LightweightServerHandler 109 * @param generationId The generation id of this remote DS. 123 long generationId, byte groupId, ServerStatus status, 133 this.generationId = generationId; 159 return new DSInfo(serverId, serverUrl, replicationServerId, generationId, 121 LightweightServerHandler(ReplicationServerHandler replServerHandler, int replicationServerId, int serverId, String serverUrl, long generationId, byte groupId, ServerStatus status, List<String> refUrls, boolean assuredFlag, AssuredMode assuredMode, byte safeDataLevel, Set<String> eclInclude, Set<String> eclIncludeForDeletes, short protocolVersion) argument
|
/forgerock/opendj2/src/server/org/opends/server/replication/common/ |
H A D | DSInfo.java | 49 private final long generationId; field in class:DSInfo 77 * @param generationId 98 public DSInfo(int dsId, String dsUrl, int rsId, long generationId, argument 107 this.generationId = generationId; 154 return generationId; 250 return new DSInfo(dsId, dsUrl, rsId, generationId, status, assuredFlag, 274 && generationId == dsInfo.getGenerationId() 301 hash = 73 * hash + (int) (this.generationId ^ (this.generationId >>> 3 [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 77 * @param generationId The generationId for this server. 89 long generationId, 96 super((short) -1 /* version set when sending */, generationId); 243 "\ngenerationId: " + generationId + 86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
|
H A D | ServerStartMsg.java | 76 * @param generationId The generationId for this server. 83 long generationId, boolean sslEncryption, 86 super((short) -1 /* version set when sending */, generationId); 262 "\ngenerationId: " + generationId + 81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
|