| /forgerock/opendj2-hg/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-hg/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="
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
| H A D | ReplicationServer.java | 215 getServerId(),
683 final CSN providedCsn = providedState.getCSN(oldestCsn.getServerId());
1020 public int getServerId() method in class:ReplicationServer
1134 return "Replication Server " + getReplicationPort() + " " + getServerId();
1354 return "RS(" + getServerId() + ") on " + serverURL + ", domains="
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/ |
| H A D | FileChangelogDB.java | 633 if (getDomainOldestCSNs(baseDN).getCSN(newFirstCSN.getServerId()).isNewerThan(newFirstCSN))
813 csn.getServerId(), replicationServer);
822 notifyReplicaOnline(indexer, baseDN, csn.getServerId());
834 notifyReplicaOnline(indexer, baseDN, heartbeatCSN.getServerId());
858 updateCursorsWithOfflineCSN(baseDN, offlineCSN.getServerId(), offlineCSN);
|
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ |
| H A D | ReplicationServerTest.java | 1008 debugInfo("BrokerReader " + broker.getServerId() + " starts");
1037 "BrokerReader " + broker.getServerId()
1072 debugInfo("writer " + broker.getServerId() + " starts to produce " + count);
1087 debugInfo("writer " + broker.getServerId() + " to send="+count);
1090 debugInfo("writer " + broker.getServerId() + " ends sent="+ccount);
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationDB.java | 843 .get(replicationServer.getServerId(),
971 if (cn.getServerId() != 0)
1080 return ((cn.getServerId()== 0) && (cn.getSeqnum()==0));
|
| H A D | LightweightServerHandler.java | 168 public int getServerId() method in class:LightweightServerHandler
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ReplicationDbEnv.java | 217 databaseName, replicationServer.getServerId()));
229 databaseName, replicationServer.getServerId()));
534 final byte[] key = toReplicaOfflineKey(baseDN, offlineCSN.getServerId());
|
| 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/opendj2.6.2/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationDB.java | 843 .get(replicationServer.getServerId(),
971 if (cn.getServerId() != 0)
1080 return ((cn.getServerId()== 0) && (cn.getSeqnum()==0));
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationDB.java | 843 .get(replicationServer.getServerId(),
971 if (cn.getServerId() != 0)
1080 return ((cn.getServerId()== 0) && (cn.getSeqnum()==0));
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/ |
| H A D | ReplicationDbEnv.java | 217 databaseName, replicationServer.getServerId()));
229 databaseName, replicationServer.getServerId()));
534 final byte[] key = toReplicaOfflineKey(baseDN, offlineCSN.getServerId());
|
| /forgerock/opendj-b2.6/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/src/server/org/opends/server/replication/common/ |
| H A D | MultiDomainServerState.java | 311 && csn.equals(excluded.getCSN(baseDN, csn.getServerId()));
|
| /forgerock/opendj2/src/server/org/opends/server/replication/plugin/ |
| H A D | PersistentServerState.java | 379 && csn.getServerId() == serverId
|
| /forgerock/opendj-b2.6/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/src/server/org/opends/server/replication/protocol/ |
| H A D | MonitorMsg.java | 241 serverId = csn.getServerId();
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationDomainMonitorData.java | 310 int serverId = newCSN.getServerId();
|
| /forgerock/opendj2/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.6.2/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
|