Searched defs:serverId2 (Results 1 - 24 of 24) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DCTHeartbeatPublisherThread.java78 * @param serverId2 The serverId of the sender domain.
81 long heartbeatInterval, int serverId2)
86 this.serverId = serverId2;
80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId2) argument
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DCTHeartbeatPublisherThread.java78 * @param serverId2 The serverId of the sender domain.
81 long heartbeatInterval, int serverId2)
86 this.serverId = serverId2;
80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId2) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DCTHeartbeatPublisherThread.java78 * @param serverId2 The serverId of the sender domain.
81 long heartbeatInterval, int serverId2)
86 this.serverId = serverId2;
80 CTHeartbeatPublisherThread(String threadName, Session session, long heartbeatInterval, int serverId2) argument
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationDomainTest.java353 public void exportAndImport(int serverId1, int serverId2) throws Exception argument
390 testService, serverId2, servers, 100, 0,
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationDomainTest.java353 public void exportAndImport(int serverId1, int serverId2) throws Exception argument
390 testService, serverId2, servers, 100, 0,
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationDomainTest.java353 public void exportAndImport(int serverId1, int serverId2) throws Exception argument
390 testService, serverId2, servers, 100, 0,
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DServerStartMsg.java69 * @param serverId2 The serverId of the server for which the ServerStartMsg
81 public ServerStartMsg(int serverId2, String serverURL, String baseDn, argument
88 this.serverId = serverId2;
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DServerStartMsg.java69 * @param serverId2 The serverId of the server for which the ServerStartMsg
81 public ServerStartMsg(int serverId2, String serverURL, DN baseDN, argument
88 this.serverId = serverId2;
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DServerStartMsg.java69 * @param serverId2 The serverId of the server for which the ServerStartMsg
81 public ServerStartMsg(int serverId2, String serverURL, String baseDn, argument
88 this.serverId = serverId2;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DServerStartMsg.java69 * @param serverId2 The serverId of the server for which the ServerStartMsg
81 public ServerStartMsg(int serverId2, String serverURL, String baseDn, argument
88 this.serverId = serverId2;
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DServerStartMsg.java69 * @param serverId2 The serverId of the server for which the ServerStartMsg
81 public ServerStartMsg(int serverId2, String serverURL, DN baseDN, argument
88 this.serverId = serverId2;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DServerStartMsg.java69 * @param serverId2 The serverId of the server for which the ServerStartMsg
81 public ServerStartMsg(int serverId2, String serverURL, DN baseDN, argument
88 this.serverId = serverId2;
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/
H A DChangeNumber.java120 * @param serverId2 identity of server
122 public ChangeNumber(long time, int seq, int serverId2) argument
124 serverId = serverId2;
H A DServerState.java345 * @param serverId2 : the server ID
348 public ChangeNumber getMaxChangeNumber(int serverId2) argument
350 return list.get(serverId2);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationDomainTest.java344 public void exportAndImport(int serverId1, int serverId2) throws Exception argument
367 testService, serverId2, servers, 0, null, importedData, 0);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/
H A DChangeNumber.java120 * @param serverId2 identity of server
122 public ChangeNumber(long time, int seq, int serverId2) argument
124 serverId = serverId2;
H A DServerState.java345 * @param serverId2 : the server ID
348 public ChangeNumber getMaxChangeNumber(int serverId2) argument
350 return list.get(serverId2);
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationDomainTest.java344 public void exportAndImport(int serverId1, int serverId2) throws Exception argument
367 testService, serverId2, servers, 0, null, importedData, 0);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/
H A DChangeNumber.java120 * @param serverId2 identity of server
122 public ChangeNumber(long time, int seq, int serverId2) argument
124 serverId = serverId2;
H A DServerState.java345 * @param serverId2 : the server ID
348 public ChangeNumber getMaxChangeNumber(int serverId2) argument
350 return list.get(serverId2);
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DReplicationDomainTest.java339 public void exportAndImport(int serverId1, int serverId2) throws Exception argument
362 testService, serverId2, servers, 0, null, importedData, 0);
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexerTest.java120 private static final int serverId2 = 102; field in class:ChangeNumberIndexerTest
205 addReplica(BASE_DN1, serverId2);
211 final ReplicatedUpdateMsg msg2 = msg(BASE_DN1, serverId2, 2);
224 addReplica(BASE_DN2, serverId2);
229 final ReplicatedUpdateMsg msg2 = msg(BASE_DN2, serverId2, 2);
267 addReplica(BASE_DN1, serverId2);
268 sendHeartbeat(BASE_DN1, serverId2, 2);
272 final ReplicatedUpdateMsg msg2 = msg(BASE_DN1, serverId2, 2);
279 sendHeartbeat(BASE_DN1, serverId2, 4);
289 addReplica(BASE_DN1, serverId2);
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexerTest.java120 private static final int serverId2 = 102; field in class:ChangeNumberIndexerTest
205 addReplica(BASE_DN1, serverId2);
211 final ReplicatedUpdateMsg msg2 = msg(BASE_DN1, serverId2, 2);
224 addReplica(BASE_DN2, serverId2);
229 final ReplicatedUpdateMsg msg2 = msg(BASE_DN2, serverId2, 2);
267 addReplica(BASE_DN1, serverId2);
268 sendHeartbeat(BASE_DN1, serverId2, 2);
272 final ReplicatedUpdateMsg msg2 = msg(BASE_DN1, serverId2, 2);
279 sendHeartbeat(BASE_DN1, serverId2, 4);
289 addReplica(BASE_DN1, serverId2);
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DChangeNumberIndexerTest.java128 private static final int serverId2 = 102; field in class:ChangeNumberIndexerTest
207 addReplica(BASE_DN1, serverId2);
213 final ReplicatedUpdateMsg msg2 = msg(BASE_DN1, serverId2, 2);
226 addReplica(BASE_DN2, serverId2);
231 final ReplicatedUpdateMsg msg2 = msg(BASE_DN2, serverId2, 2);
269 addReplica(BASE_DN1, serverId2);
270 sendHeartbeat(BASE_DN1, serverId2, 2);
274 final ReplicatedUpdateMsg msg2 = msg(BASE_DN1, serverId2, 2);
281 sendHeartbeat(BASE_DN1, serverId2, 4);
291 addReplica(BASE_DN1, serverId2);
[all...]

Completed in 72 milliseconds