Cross Reference: /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/StateMachineTest.java

Lines Matching defs:ds2
93   private ReplicationBroker ds2;
129     ds2 = null;
144     stop(ds2, ds3);
145     ds2 = ds3 = null;
176       return ds2.isConnected();
324       ds2 = createReplicationBroker(DS2_ID, new ServerState(), EMPTY_DN_GENID);
377       br2 = new BrokerReader(ds2, DS2_ID);
436       ds2 = createReplicationBroker(DS2_ID, new ServerState(), EMPTY_DN_GENID);
437       br = new BrokerReader(ds2, DS2_ID);
441       bw = new BrokerWriter(ds2, DS2_ID, false);
467       ds2.stop();
471       ds2 = createReplicationBroker(DS2_ID, curState, EMPTY_DN_GENID);
472       br = new BrokerReader(ds2, DS2_ID);
480       bw = new BrokerWriter(ds2, DS2_ID, false);
494       ds2.stop();
498       ds2 = createReplicationBroker(DS2_ID, curState, EMPTY_DN_GENID);
499       br = new BrokerReader(ds2, DS2_ID);
521       resetGenId(ds2, BAD_GEN_ID); // ds2 will also go bad gen
529       resetGenId(ds2, EMPTY_DN_GENID); // ds2 will also be disconnected
530       ds2.stop();
537       ds2 = createReplicationBroker(DS2_ID, curState, EMPTY_DN_GENID);
539       bw = new BrokerWriter(ds2, DS2_ID, false);
540       br = new BrokerReader(ds2, DS2_ID);
549       resetGenId(ds2, -1); // -1 to allow next step full update and flush RS db so that DS1 can reconnect after full update
557       BrokerInitializer bi = new BrokerInitializer(ds2, DS2_ID, false);
569       ds2.stop(); // will need a new broker with another gen id restart it
574       ds2 = createReplicationBroker(DS2_ID, curState, newGen);
576       bw = new BrokerWriter(ds2, DS2_ID, false);
577       br = new BrokerReader(ds2, DS2_ID);
583       bi = new BrokerInitializer(ds2, DS2_ID, false);
599       ds2.stop(); // will need a new broker with another gen id restart it
604       ds2 = createReplicationBroker(DS2_ID, curState, newGen);
606       br = new BrokerReader(ds2, DS2_ID);
607       resetGenId(ds2, newGen); // Make DS1 reconnect in normal status
612       bi = new BrokerInitializer(ds2, DS2_ID, false);
622       ds2.stop();