Searched refs:getServerId (Results 151 - 175 of 335) sorted by relevance

1234567891011>>

/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DReplicationEnvironment.java432 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 DChangeNumber.java160 public int getServerId() method in class:ChangeNumber
H A DMultiDomainServerState.java104 int serverId = changeNumber.getServerId();
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DDomainFakeCfg.java194 public int getServerId() method in class:DomainFakeCfg
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/
H A DChangeNumber.java160 public int getServerId() method in class:ChangeNumber
H A DMultiDomainServerState.java104 int serverId = changeNumber.getServerId();
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/
H A DCSN.java179 public int getServerId() method in class:CSN
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DByteArrayScanner.java372 if (serverId != csn.getServerId())
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DReplicationEnvironment.java432 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 DByteArrayScanner.java372 if (serverId != csn.getServerId())
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DDomainFakeCfg.java180 public int getServerId() method in class:DomainFakeCfg
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DDbHandler.java153 + replicationServer.getServerId()
619 public int getServerId() method in class:DbHandler
H A DDraftCNDbHandler.java384 .getServerId());
417 || ((cnVector.getMaxChangeNumber(cn.getServerId()) != null)
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexer.java292 && 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 DDbHandler.java151 + replicationServer.getServerId()
619 public int getServerId() method in class:DbHandler
H A DDraftCNDbHandler.java405 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 DDbHandler.java153 + replicationServer.getServerId()
619 public int getServerId() method in class:DbHandler
H A DDraftCNDbHandler.java384 .getServerId());
417 || ((cnVector.getMaxChangeNumber(cn.getServerId()) != null)
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DChangeNumberIndexer.java292 && 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 DChangeNumberIndexer.java287 && 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 DExternalChangeLogTest.java953 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 DExternalChangeLogTest.java953 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 DExternalChangeLogTest.java953 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 DReplicationServerTest.java1008 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 DReplicationServer.java218 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="

Completed in 1096 milliseconds

1234567891011>>