Cross Reference: /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/StateMachineTest.java

Lines Matching defs:ds2
84   private ReplicationBroker ds2;
104     ds2 = null;
119     stop(ds2, ds3);
120     ds2 = ds3 = null;
141         rb = ds2;
336       ds2 = createReplicationBroker(DS2_ID, new ServerState(), EMPTY_DN_GENID);
392       br2 = new BrokerReader(ds2, DS2_ID);
453       ds2 = createReplicationBroker(DS2_ID, new ServerState(), EMPTY_DN_GENID);
454       br = new BrokerReader(ds2, DS2_ID);
458       bw = new BrokerWriter(ds2, DS2_ID, false);
490       ds2.stop();
494       ds2 = createReplicationBroker(DS2_ID, curState, EMPTY_DN_GENID);
495       br = new BrokerReader(ds2, DS2_ID);
507       bw = new BrokerWriter(ds2, DS2_ID, false);
524       ds2.stop();
528       ds2 = createReplicationBroker(DS2_ID, curState, EMPTY_DN_GENID);
529       br = new BrokerReader(ds2, DS2_ID);
552       resetGenId(ds2, BAD_GEN_ID); // ds2 will also go bad gen
560       resetGenId(ds2, EMPTY_DN_GENID); // ds2 will also be disconnected
561       ds2.stop();
569       ds2 = createReplicationBroker(DS2_ID, curState, EMPTY_DN_GENID);
571       bw = new BrokerWriter(ds2, DS2_ID, false);
572       br = new BrokerReader(ds2, DS2_ID);
581       resetGenId(ds2, -1); // -1 to allow next step full update and flush RS db so that DS1 can reconnect after full update
589       BrokerInitializer bi = new BrokerInitializer(ds2, DS2_ID, false);
603       ds2.stop(); // will need a new broker with another gen id restart it
608       ds2 = createReplicationBroker(DS2_ID, curState, newGen);
610       bw = new BrokerWriter(ds2, DS2_ID, false);
611       br = new BrokerReader(ds2, DS2_ID);
620       bi = new BrokerInitializer(ds2, DS2_ID, false);
636       ds2.stop(); // will need a new broker with another gen id restart it
641       ds2 = createReplicationBroker(DS2_ID, curState, newGen);
643       br = new BrokerReader(ds2, DS2_ID);
644       resetGenId(ds2, newGen); // Make DS1 reconnect in normal status
652       bi = new BrokerInitializer(ds2, DS2_ID, false);
662       ds2.stop();