Searched refs:rsGroupId (Results 1 - 12 of 12) sorted by relevance

/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DAssuredReplicationPluginTest.java764 public void testSafeDataModeTimeout(byte rsGroupId) throws Exception argument
767 String testcase = "testSafeDataModeTimeout" + rsGroupId;
772 replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
774 if (rsGroupId != 1)
780 if (rsGroupId == 1)
788 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + SAFE_DATA_DN + "\n" +
801 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + NOT_ASSURED_DN + "\n" +
810 if (rsGroupId == 1)
874 public void testSafeReadModeTimeout(byte rsGroupId) throws Exception argument
877 String testcase = "testSafeReadModeTimeout" + rsGroupId;
1130 testSafeReadModeReply(byte rsGroupId) argument
1217 testSafeDataModeReply(byte rsGroupId) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DAssuredReplicationPluginTest.java764 public void testSafeDataModeTimeout(byte rsGroupId) throws Exception argument
767 String testcase = "testSafeDataModeTimeout" + rsGroupId;
772 replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
774 if (rsGroupId != 1)
780 if (rsGroupId == 1)
788 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + SAFE_DATA_DN + "\n" +
801 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + NOT_ASSURED_DN + "\n" +
810 if (rsGroupId == 1)
874 public void testSafeReadModeTimeout(byte rsGroupId) throws Exception argument
877 String testcase = "testSafeReadModeTimeout" + rsGroupId;
1130 testSafeReadModeReply(byte rsGroupId) argument
1217 testSafeDataModeReply(byte rsGroupId) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DAssuredReplicationPluginTest.java714 public void testSafeDataModeTimeout(byte rsGroupId) throws Exception argument
717 String testcase = "testSafeDataModeTimeout" + rsGroupId;
722 replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
724 if (rsGroupId != 1)
732 if (rsGroupId == 1)
740 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + SAFE_DATA_DN + "\n" +
753 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + NOT_ASSURED_DN + "\n" +
762 if (rsGroupId == 1)
826 public void testSafeReadModeTimeout(byte rsGroupId) throws Exception argument
829 String testcase = "testSafeReadModeTimeout" + rsGroupId;
1084 testSafeReadModeReply(byte rsGroupId) argument
1171 testSafeDataModeReply(byte rsGroupId) argument
[all...]
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DAssuredReplicationPluginTest.java847 public void testSafeDataModeTimeout(byte rsGroupId) throws Exception argument
851 String testcase = "testSafeDataModeTimeout" + rsGroupId;
856 replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
858 if (rsGroupId != (byte)1)
864 if (rsGroupId == (byte)1)
873 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + SAFE_DATA_DN + "\n" +
886 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + NOT_ASSURED_DN + "\n" +
895 if (rsGroupId == (byte)1)
967 public void testSafeReadModeTimeout(byte rsGroupId) throws Exception argument
971 String testcase = "testSafeReadModeTimeout" + rsGroupId;
1308 testSafeReadModeReply(byte rsGroupId) argument
1407 testSafeDataModeReply(byte rsGroupId) argument
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DAssuredReplicationPluginTest.java847 public void testSafeDataModeTimeout(byte rsGroupId) throws Exception argument
851 String testcase = "testSafeDataModeTimeout" + rsGroupId;
856 replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
858 if (rsGroupId != (byte)1)
864 if (rsGroupId == (byte)1)
873 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + SAFE_DATA_DN + "\n" +
886 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + NOT_ASSURED_DN + "\n" +
895 if (rsGroupId == (byte)1)
967 public void testSafeReadModeTimeout(byte rsGroupId) throws Exception argument
971 String testcase = "testSafeReadModeTimeout" + rsGroupId;
1308 testSafeReadModeReply(byte rsGroupId) argument
1407 testSafeDataModeReply(byte rsGroupId) argument
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DAssuredReplicationPluginTest.java847 public void testSafeDataModeTimeout(byte rsGroupId) throws Exception argument
851 String testcase = "testSafeDataModeTimeout" + rsGroupId;
856 replicationServer = new FakeReplicationServer(rsGroupId, replServerPort, RS_SERVER_ID,
858 if (rsGroupId != (byte)1)
864 if (rsGroupId == (byte)1)
873 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + SAFE_DATA_DN + "\n" +
886 String entry = "dn: ou=assured-sd-timeout-entry" + rsGroupId + "," + NOT_ASSURED_DN + "\n" +
895 if (rsGroupId == (byte)1)
967 public void testSafeReadModeTimeout(byte rsGroupId) throws Exception argument
971 String testcase = "testSafeReadModeTimeout" + rsGroupId;
1308 testSafeReadModeReply(byte rsGroupId) argument
1407 testSafeDataModeReply(byte rsGroupId) argument
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java864 byte rsGroupId = broker.getRsGroupId();
866 AssuredMode.SAFE_READ_MODE) && (rsGroupId == groupId) )
3206 byte rsGroupId = broker.getRsGroupId();
3216 if (rsGroupId == groupId)
3276 byte rsGroupId = broker.getRsGroupId();
3286 if (assured && (rsGroupId == groupId))
3314 byte rsGroupId = broker.getRsGroupId();
3318 if (assured && (rsGroupId == groupId))
H A DReplicationBroker.java113 private byte rsGroupId = -1; field in class:ReplicationBroker
300 return rsGroupId;
1049 rsGroupId = rsInfo.getGroupId();
2194 rsGroupId = -1;
2719 rsGroupId = -1;
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java865 byte rsGroupId = broker.getRsGroupId();
867 AssuredMode.SAFE_READ_MODE) && (rsGroupId == groupId) )
3210 byte rsGroupId = broker.getRsGroupId();
3220 if (rsGroupId == groupId)
3280 byte rsGroupId = broker.getRsGroupId();
3290 if (assured && (rsGroupId == groupId))
3318 byte rsGroupId = broker.getRsGroupId();
3322 if (assured && (rsGroupId == groupId))
H A DReplicationBroker.java107 private byte rsGroupId = -1; field in class:ReplicationBroker
300 return rsGroupId;
1048 rsGroupId = rsInfo.getGroupId();
2452 rsGroupId = -1;
2981 rsGroupId = -1;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java864 byte rsGroupId = broker.getRsGroupId();
866 AssuredMode.SAFE_READ_MODE) && (rsGroupId == groupId) )
3206 byte rsGroupId = broker.getRsGroupId();
3216 if (rsGroupId == groupId)
3276 byte rsGroupId = broker.getRsGroupId();
3286 if (assured && (rsGroupId == groupId))
3314 byte rsGroupId = broker.getRsGroupId();
3318 if (assured && (rsGroupId == groupId))
H A DReplicationBroker.java113 private byte rsGroupId = -1; field in class:ReplicationBroker
300 return rsGroupId;
1049 rsGroupId = rsInfo.getGroupId();
2194 rsGroupId = -1;
2719 rsGroupId = -1;

Completed in 90 milliseconds