/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | AssuredReplicationPluginTest.java | 764 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 D | AssuredReplicationPluginTest.java | 764 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 D | AssuredReplicationPluginTest.java | 714 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 D | AssuredReplicationPluginTest.java | 847 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 D | AssuredReplicationPluginTest.java | 847 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 D | AssuredReplicationPluginTest.java | 847 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 D | ReplicationDomain.java | 864 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 D | ReplicationBroker.java | 113 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 D | ReplicationDomain.java | 865 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 D | ReplicationBroker.java | 107 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 D | ReplicationDomain.java | 864 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 D | ReplicationBroker.java | 113 private byte rsGroupId = -1; field in class:ReplicationBroker 300 return rsGroupId; 1049 rsGroupId = rsInfo.getGroupId(); 2194 rsGroupId = -1; 2719 rsGroupId = -1;
|