/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | LightweightServerHandler.java | 168 public int getServerId() method in class:LightweightServerHandler
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | DomainFakeCfg.java | 276 public int getServerId() method in class:DomainFakeCfg
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | DomainFakeCfg.java | 267 public int getServerId() method in class:DomainFakeCfg
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ReplServerStartDSMsg.java | 215 public int getServerId() method in class:ReplServerStartDSMsg
|
H A D | ReplServerStartMsg.java | 267 public int getServerId() method in class:ReplServerStartMsg
|
H A D | ServerStartMsg.java | 212 public int getServerId() method in class:ServerStartMsg
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | LightweightServerHandler.java | 168 public int getServerId() method in class:LightweightServerHandler
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/ |
H A D | MultiDomainServerState.java | 311 && csn.equals(excluded.getCSN(baseDN, csn.getServerId()));
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/ |
H A D | PersistentServerState.java | 379 && csn.getServerId() == serverId
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 241 serverId = csn.getServerId();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationDomainMonitorData.java | 310 int serverId = newCSN.getServerId();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/ |
H A D | FileChangelogDB.java | 801 csn.getServerId(), replicationServer); 810 notifyReplicaOnline(indexer, baseDN, csn.getServerId()); 823 notifyReplicaOnline(indexer, baseDN, heartbeatCSN.getServerId()); 848 updateCursorsWithOfflineCSN(baseDN, offlineCSN.getServerId(), offlineCSN);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
H A D | JEChangelogDB.java | 844 csn.getServerId(), replicationServer); 853 notifyReplicaOnline(indexer, baseDN, csn.getServerId()); 866 notifyReplicaOnline(indexer, baseDN, heartbeatCSN.getServerId()); 891 updateCursorsWithOfflineCSN(baseDN, offlineCSN.getServerId(), offlineCSN);
|
H A D | JEReplicaDB.java | 362 public int getServerId() method in class:JEReplicaDB
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/ |
H A D | CSN.java | 179 public int getServerId() method in class:CSN
|
H A D | MultiDomainServerState.java | 323 && csn.equals(excluded.getCSN(baseDN, csn.getServerId()));
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/ |
H A D | PersistentServerState.java | 360 && csn.getServerId() == serverId
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | MonitorMsg.java | 239 serverId = csn.getServerId();
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | MessageHandler.java | 617 return this.replicationServer.getServerId();
|
H A D | ReplicationDomainMonitorData.java | 274 int serverId = newCSN.getServerId();
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
H A D | ReplicationEnvironment.java | 533 final File serverIdPath = getServerIdPath(domainId, offlineCSN.getServerId()); 550 domainDN.toString(), offlineCSN.getServerId(), offlineFile.getPath(), offlineCSN.toString()), e); 771 replicationServer.getServerId())); 781 serverIdPath.getPath(), replicationServer.getServerId()));
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 1083 debugInfo("BrokerReader " + broker.getServerId() + " starts"); 1110 "BrokerReader " + broker.getServerId() 1148 debugInfo("writer " + broker.getServerId() + " starts to produce " + count); 1164 debugInfo("writer " + broker.getServerId() + " to send="+count); 1166 debugInfo("writer " + broker.getServerId() + " ends sent="+ccount);
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 1083 debugInfo("BrokerReader " + broker.getServerId() + " starts"); 1110 "BrokerReader " + broker.getServerId() 1148 debugInfo("writer " + broker.getServerId() + " starts to produce " + count); 1164 debugInfo("writer " + broker.getServerId() + " to send="+count); 1166 debugInfo("writer " + broker.getServerId() + " ends sent="+ccount);
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerTest.java | 1083 debugInfo("BrokerReader " + broker.getServerId() + " starts"); 1110 "BrokerReader " + broker.getServerId() 1148 debugInfo("writer " + broker.getServerId() + " starts to produce " + count); 1164 debugInfo("writer " + broker.getServerId() + " to send="+count); 1166 debugInfo("writer " + broker.getServerId() + " ends sent="+ccount);
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 153 assertEquals(msg.getServerId(), newMsg.getServerId()); 177 assertEquals(msg.getServerId(), vlastMsg.getServerId()); 960 assertEquals(msg.getServerId(), serverId); 986 assertEquals(msg.getServerId(), serverId);
|