Cross Reference: /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/ChangeNumberIndexerTest.java

Lines Matching defs:serverId1
127   private static final int serverId1 = 101;
193     addReplica(BASE_DN1, serverId1);
197     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
206     addReplica(BASE_DN1, serverId1);
212     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
215     // do not start publishing to the changelog until we hear from serverId1
225     addReplica(BASE_DN1, serverId1);
230     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
234     final ReplicatedUpdateMsg msg3 = msg(BASE_DN1, serverId1, 3);
261     addReplica(BASE_DN1, serverId1);
265     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
278     final ReplicatedUpdateMsg msg3 = msg(BASE_DN1, serverId1, 3);
290     addReplica(BASE_DN1, serverId1);
297     final ReplicatedUpdateMsg msg2Sid1 = msg(BASE_DN1, serverId1, 2);
308     addReplica(ADMIN_DATA_DN, serverId1);
316     final ReplicatedUpdateMsg msg1 = msg(ADMIN_DATA_DN, serverId1, 1);
330     addReplica(BASE_DN1, serverId1);
334     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
343     final ReplicatedUpdateMsg msg3 = msg(BASE_DN1, serverId1, 3);
352     addReplica(BASE_DN1, serverId1);
356     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
364     sendHeartbeat(BASE_DN1, serverId1, 3);
372     addReplica(BASE_DN1, serverId1);
377     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
382     sendHeartbeat(BASE_DN1, serverId1, 3);
390     addReplica(BASE_DN1, serverId1);
395     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
401     // MCP cannot move forward since no new updates from serverId1
404     final ReplicatedUpdateMsg msg4 = msg(BASE_DN1, serverId1, 4);
406     // MCP moves forward after receiving update from serverId1
413     // MCP does not move until it knows what happens to serverId1
415     sendHeartbeat(BASE_DN1, serverId1, 6);
424     addReplica(BASE_DN1, serverId1);
426     initialState.addOfflineReplica(BASE_DN1, new CSN(1, 1, serverId1));
432     // MCP does not wait for temporarily offline serverId1
435     // serverId1 is back online, wait for changes from serverId2
436     final ReplicatedUpdateMsg msg3 = msg(BASE_DN1, serverId1, 3);
458     addReplica(BASE_DN1, serverId1);
460     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
462     initialState.addOfflineReplica(BASE_DN1, new CSN(2, 1, serverId1));
472     // do not wait for temporarily offline serverId1
477     // serverId1 is back online, wait for changes from serverId2
478     final ReplicatedUpdateMsg msg5 = msg(BASE_DN1, serverId1, 5);
503     addReplica(BASE_DN1, serverId1);
505     initialState.addOfflineReplica(BASE_DN1, new CSN(1, 1, serverId1));
506     final ReplicatedUpdateMsg msg2 = msg(BASE_DN1, serverId1, 2);
507     final ReplicatedUpdateMsg msg3 = msg(BASE_DN1, serverId1, 3);
512     // MCP moves forward because serverId1 is not really offline
519     sendHeartbeat(BASE_DN1, serverId1, 5);
527     addReplica(BASE_DN1, serverId1);
532     final ReplicatedUpdateMsg msg1 = msg(BASE_DN1, serverId1, 1);
541     final ReplicatedUpdateMsg msg3 = msg(BASE_DN1, serverId1, 3);