/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicationEnvironment.java | 432 final File serverIdPath = getServerIdPath(domainId, offlineCSN.getServerId()); 449 domainDN.toString(), offlineCSN.getServerId(), offlineFile.getPath(), offlineCSN.toString()), e); 677 replicationServer.getServerId())); 687 serverIdPath.getPath(), replicationServer.getServerId()));
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
H A D | ChangeNumber.java | 160 public int getServerId() method in class:ChangeNumber
|
H A D | MultiDomainServerState.java | 104 int serverId = changeNumber.getServerId();
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | DomainFakeCfg.java | 194 public int getServerId() method in class:DomainFakeCfg
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
H A D | ChangeNumber.java | 160 public int getServerId() method in class:ChangeNumber
|
H A D | MultiDomainServerState.java | 104 int serverId = changeNumber.getServerId();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/ |
H A D | CSN.java | 179 public int getServerId() method in class:CSN
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ByteArrayScanner.java | 372 if (serverId != csn.getServerId())
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicationEnvironment.java | 432 final File serverIdPath = getServerIdPath(domainId, offlineCSN.getServerId()); 449 domainDN.toString(), offlineCSN.getServerId(), offlineFile.getPath(), offlineCSN.toString()), e); 677 replicationServer.getServerId())); 687 serverIdPath.getPath(), replicationServer.getServerId()));
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | ByteArrayScanner.java | 372 if (serverId != csn.getServerId())
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | DomainFakeCfg.java | 180 public int getServerId() method in class:DomainFakeCfg
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | DbHandler.java | 153 + replicationServer.getServerId() 619 public int getServerId() method in class:DbHandler
|
H A D | DraftCNDbHandler.java | 384 .getServerId()); 417 || ((cnVector.getMaxChangeNumber(cn.getServerId()) != null)
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ChangeNumberIndexer.java | 292 && replicasOffline.getCSN(baseDN, csn.getServerId()) == null) 550 final int mcServerId = mcCSN.getServerId();
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | DbHandler.java | 151 + replicationServer.getServerId() 619 public int getServerId() method in class:DbHandler
|
H A D | DraftCNDbHandler.java | 405 ChangeNumber fcn = startState.getMaxChangeNumber(cn.getServerId()); 438 || ((cnVector.getMaxChangeNumber(cn.getServerId()) != null)
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | DbHandler.java | 153 + replicationServer.getServerId() 619 public int getServerId() method in class:DbHandler
|
H A D | DraftCNDbHandler.java | 384 .getServerId()); 417 || ((cnVector.getMaxChangeNumber(cn.getServerId()) != null)
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | ChangeNumberIndexer.java | 292 && replicasOffline.getCSN(baseDN, csn.getServerId()) == null) 550 final int mcServerId = mcCSN.getServerId();
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | ChangeNumberIndexer.java | 287 && replicasOffline.getCSN(baseDN, csn.getServerId()) == null) 556 final int mcServerId = mcCSN.getServerId();
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ExternalChangeLogTest.java | 953 ChangeNumber cn = new ChangeNumber(time, ts++, s1test.getServerId()); 959 cn = new ChangeNumber(time++, ts++, s2test2.getServerId()); 965 ChangeNumber cn3 = new ChangeNumber(time++, ts++, s2test2.getServerId()); 971 cn = new ChangeNumber(time++, ts++, s1test.getServerId()); 1073 ChangeNumber cn5 = new ChangeNumber(time++, ts++, s1test.getServerId()); 1182 cn = new ChangeNumber(time++, ts++, s1test2.getServerId()); 1187 cn = new ChangeNumber(time++, ts++, s2test.getServerId()); 1192 ChangeNumber cn8 = new ChangeNumber(time++, ts++, s1test2.getServerId()); 1197 ChangeNumber cn9 = new ChangeNumber(time++, ts++, s2test.getServerId()); 1206 assertTrue(startState.getMaxChangeNumber(s1test.getServerId()) [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ExternalChangeLogTest.java | 953 ChangeNumber cn = new ChangeNumber(time, ts++, s1test.getServerId()); 959 cn = new ChangeNumber(time++, ts++, s2test2.getServerId()); 965 ChangeNumber cn3 = new ChangeNumber(time++, ts++, s2test2.getServerId()); 971 cn = new ChangeNumber(time++, ts++, s1test.getServerId()); 1073 ChangeNumber cn5 = new ChangeNumber(time++, ts++, s1test.getServerId()); 1182 cn = new ChangeNumber(time++, ts++, s1test2.getServerId()); 1187 cn = new ChangeNumber(time++, ts++, s2test.getServerId()); 1192 ChangeNumber cn8 = new ChangeNumber(time++, ts++, s1test2.getServerId()); 1197 ChangeNumber cn9 = new ChangeNumber(time++, ts++, s2test.getServerId()); 1206 assertTrue(startState.getMaxChangeNumber(s1test.getServerId()) [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ExternalChangeLogTest.java | 953 ChangeNumber cn = new ChangeNumber(time, ts++, s1test.getServerId()); 959 cn = new ChangeNumber(time++, ts++, s2test2.getServerId()); 965 ChangeNumber cn3 = new ChangeNumber(time++, ts++, s2test2.getServerId()); 971 cn = new ChangeNumber(time++, ts++, s1test.getServerId()); 1073 ChangeNumber cn5 = new ChangeNumber(time++, ts++, s1test.getServerId()); 1182 cn = new ChangeNumber(time++, ts++, s1test2.getServerId()); 1187 cn = new ChangeNumber(time++, ts++, s2test.getServerId()); 1192 ChangeNumber cn8 = new ChangeNumber(time++, ts++, s1test2.getServerId()); 1197 ChangeNumber cn9 = new ChangeNumber(time++, ts++, s2test.getServerId()); 1206 assertTrue(startState.getMaxChangeNumber(s1test.getServerId()) [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 1008 debugInfo("BrokerReader " + broker.getServerId() + " starts"); 1035 "BrokerReader " + broker.getServerId() 1072 debugInfo("writer " + broker.getServerId() + " starts to produce " + count); 1086 debugInfo("writer " + broker.getServerId() + " to send="+count); 1088 debugInfo("writer " + broker.getServerId() + " ends sent="+ccount);
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServer.java | 218 getServerId(), 715 final CSN providedCsn = providedState.getCSN(oldestCsn.getServerId()); 1066 public int getServerId() method in class:ReplicationServer 1180 return "Replication Server " + getReplicationPort() + " " + getServerId(); 1375 return "RS(" + getServerId() + ") on " + serverURL + ", domains="
|