/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ServerWriter.java | 141 handler.getServiceId(), handler.getServerId(), 149 handler.getServiceId(), handler.getServerId(), 169 handler.getServerId(), 187 " server=" + handler.getServerId() + 206 handler.getReplicationServerId(), handler.getServerId(), 212 handler.getReplicationServerId(), handler.getServerId(), 227 handler.getReplicationServerId(), handler.getServerId(), 233 handler.getReplicationServerId(), handler.getServerId(),
|
H A D | ReplicationServerDomain.java | 232 int excludedServerId = excludedDS != null ? excludedDS.getServerId() : -1; 265 pendingHeartbeats.put(msg.getChangeNumber().getServerId(), msg); 298 + replicationServer.getServerId() 320 int id = cn.getServerId(); 370 Integer.toString(replicationServer.getServerId()), 474 baseDn + " " + replicationServer.getServerId() + 478 Integer.toString(handler.getServerId()) + " with generation id " + 492 getServerId())) 543 Integer.toString(handler.getServerId()) + " with generation id " + 549 replicationServer.getServerId() [all...] |
H A D | ExternalChangeLogSessionImpl.java | 61 rs.getServerId(),
|
H A D | DataServerHandler.java | 133 replicationServerDomain.getReplicationServer().getServerId() + 134 ". Closing connection to DS " + getServerId() + 172 replicationServerDomain.getReplicationServer().getServerId() + 173 ". DS " + getServerId() + " for baseDn " + getServiceId() + 194 getReplicationServer().getServerId()), 221 replicationServerDomain.getReplicationServer().getServerId() + 222 " Sending change status for reset gen id to " + getServerId() + 264 replicationServerDomain.getReplicationServer().getServerId() + 265 " Sending change status from status analyzer to " + getServerId() + 409 serverId = serverStartMsg.getServerId(); [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | ServerWriter.java | 141 handler.getServiceId(), handler.getServerId(), 149 handler.getServiceId(), handler.getServerId(), 169 handler.getServerId(), 187 " server=" + handler.getServerId() + 206 handler.getReplicationServerId(), handler.getServerId(), 212 handler.getReplicationServerId(), handler.getServerId(), 227 handler.getReplicationServerId(), handler.getServerId(), 233 handler.getReplicationServerId(), handler.getServerId(),
|
H A D | ReplicationServerDomain.java | 209 + replicationServer.getServerId() 230 int id = cn.getServerId(); 280 Integer.toString(replicationServer.getServerId()), 384 baseDn + " " + replicationServer.getServerId() + 388 Integer.toString(handler.getServerId()) + " with generation id " + 402 getServerId())) 453 Integer.toString(handler.getServerId()) + " with generation id " + 459 replicationServer.getServerId() + 463 Integer.toString(handler.getServerId()) + 476 getServerId())) [all...] |
H A D | ExternalChangeLogSessionImpl.java | 61 rs.getServerId(),
|
H A D | DataServerHandler.java | 134 replicationServerDomain.getReplicationServer().getServerId() + 135 ". Closing connection to DS " + getServerId() + 173 replicationServerDomain.getReplicationServer().getServerId() + 174 ". DS " + getServerId() + " for baseDn " + getServiceId() + 195 getReplicationServer().getServerId()), 222 replicationServerDomain.getReplicationServer().getServerId() + 223 " Sending change status for reset gen id to " + getServerId() + 265 replicationServerDomain.getReplicationServer().getServerId() + 266 " Sending change status from status analyzer to " + getServerId() + 418 serverId = serverStartMsg.getServerId(); [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 225 int excludedServerId = excludedDS != null ? excludedDS.getServerId() : -1; 258 pendingHeartbeats.put(msg.getCSN().getServerId(), msg); 304 + localReplicationServer.getServerId() 407 + rsHandler.getServerId() + " with generation id " 434 + dsHandler.getServerId() + " with generation id " 446 + dsHandler.getServerId() + " as it is in full update"); 478 Integer.toString(localReplicationServer.getServerId()), 568 && !assuredServers.contains(sHandler.getServerId())) 649 expectedServers.add(dsHandler.getServerId()); 652 wrongStatusServers.add(dsHandler.getServerId()); [all...] |
H A D | DataServerHandler.java | 106 Integer.toString(replicationServer.getServerId()), 137 TRACER.debugInfo("In RS " + replicationServer.getServerId() 138 + ", DS " + getServerId() + " for baseDN=" + getBaseDNString() 151 TRACER.debugInfo("In RS " + replicationServer.getServerId() 152 + ", closing connection to DS " + getServerId() + " for baseDN=" 220 TRACER.debugInfo("In RS " + replicationServer.getServerId() 221 + " Sending change status " + origin + " to " + getServerId() 357 serverId = serverStartMsg.getServerId(); 410 .containsKey(inServerStartMsg.getServerId())) 462 Integer.toString(inServerStartMsg.getServerId()), [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 225 int excludedServerId = excludedDS != null ? excludedDS.getServerId() : -1; 258 pendingHeartbeats.put(msg.getCSN().getServerId(), msg); 304 + localReplicationServer.getServerId() 407 + rsHandler.getServerId() + " with generation id " 434 + dsHandler.getServerId() + " with generation id " 446 + dsHandler.getServerId() + " as it is in full update"); 478 Integer.toString(localReplicationServer.getServerId()), 568 && !assuredServers.contains(sHandler.getServerId())) 649 expectedServers.add(dsHandler.getServerId()); 652 wrongStatusServers.add(dsHandler.getServerId()); [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 213 int excludedServerId = excludedDS != null ? excludedDS.getServerId() : -1; 246 pendingHeartbeats.put(msg.getCSN().getServerId(), msg); 292 + localReplicationServer.getServerId() 395 + rsHandler.getServerId() + " with generation id " 422 + dsHandler.getServerId() + " with generation id " 434 + dsHandler.getServerId() + " as it is in full update"); 466 localReplicationServer.getServerId(), updateMsg.getAssuredMode(), baseDN, updateMsg); 553 && !assuredServers.contains(sHandler.getServerId())) 634 expectedServers.add(dsHandler.getServerId()); 637 wrongStatusServers.add(dsHandler.getServerId()); [all...] |
H A D | DataServerHandler.java | 107 logger.info(NOTE_BAD_GEN_ID_IN_FULL_UPDATE, replicationServer.getServerId(), 134 logger.trace("In RS " + replicationServer.getServerId() 135 + ", DS " + getServerId() + " for baseDN=" + getBaseDN() 148 logger.trace("In RS " + replicationServer.getServerId() 149 + ", closing connection to DS " + getServerId() + " for baseDN=" + getBaseDN() 214 logger.trace("In RS " + replicationServer.getServerId() 215 + " Sending change status " + origin + " to " + getServerId() 339 serverId = serverStartMsg.getServerId(); 392 .containsKey(inServerStartMsg.getServerId())) 446 inServerStartMsg.getServerId(), replicationServe [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 209 + replicationServer.getServerId() 230 int id = cn.getServerId(); 280 Integer.toString(replicationServer.getServerId()), 384 baseDn + " " + replicationServer.getServerId() + 388 Integer.toString(handler.getServerId()) + " with generation id " + 402 getServerId())) 453 Integer.toString(handler.getServerId()) + " with generation id " + 459 replicationServer.getServerId() + 463 Integer.toString(handler.getServerId()) + 476 getServerId())) [all...] |
H A D | ExternalChangeLogSessionImpl.java | 61 rs.getServerId(),
|
H A D | DataServerHandler.java | 134 replicationServerDomain.getReplicationServer().getServerId() + 135 ". Closing connection to DS " + getServerId() + 173 replicationServerDomain.getReplicationServer().getServerId() + 174 ". DS " + getServerId() + " for baseDn " + getServiceId() + 195 getReplicationServer().getServerId()), 222 replicationServerDomain.getReplicationServer().getServerId() + 223 " Sending change status for reset gen id to " + getServerId() + 265 replicationServerDomain.getReplicationServer().getServerId() + 266 " Sending change status from status analyzer to " + getServerId() + 418 serverId = serverStartMsg.getServerId(); [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/common/ |
H A D | CSNGenerator.java | 81 if (csn.getServerId() == serverId) 144 int changeServerId = number.getServerId();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/ |
H A D | CSNGenerator.java | 81 if (csn.getServerId() == serverId) 144 int changeServerId = number.getServerId();
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/ |
H A D | CSNGenerator.java | 81 if (csn.getServerId() == serverId) 144 int changeServerId = number.getServerId();
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBrokerTest.java | 91 map.put(info.getServerId(), info); 122 if (info.getServerId() == rsInfo.getId()) 170 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 181 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 192 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 204 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 217 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, previousRSs); 231 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, previousRSs); 244 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, previousRSs); 257 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), locallyConfigure [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBrokerTest.java | 91 map.put(info.getServerId(), info); 122 if (info.getServerId() == rsInfo.getId()) 170 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 181 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 192 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 204 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 217 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, previousRSs); 231 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, previousRSs); 244 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, previousRSs); 257 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), locallyConfigure [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/ |
H A D | ReplicationBrokerTest.java | 90 map.put(info.getServerId(), info); 121 if (info.getServerId() == rsInfo.getId()) 169 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 180 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 191 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 203 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, EMPTY_MAP); 216 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, previousRSs); 230 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, previousRSs); 243 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), EMPTY_SET, previousRSs); 256 CURRENT_DS.getDsId(), CURRENT_RS.getServerId(), locallyConfigure [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 74 CSN csn1 = new CSN(csn.getTime() + 1, csn.getSeqnum(), csn.getServerId()); 75 CSN csn2 = new CSN(csn1.getTime(), csn1.getSeqnum() + 1, csn1.getServerId()); 76 CSN csn3 = new CSN(csn2.getTime(), csn2.getSeqnum(), (csn2.getServerId() + 1)); 89 assertEquals(csn2.compareTo(serverState.getCSN(csn2.getServerId())), 0); 90 assertEquals(csn3.compareTo(serverState.getCSN(csn3.getServerId())), 0); 104 CSN csn1 = new CSN(csn.getTime() + 1, csn.getSeqnum(), csn.getServerId()); 105 CSN csn3 = new CSN(csn1.getTime(), csn1.getSeqnum(), (csn1.getServerId() + 1));
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 74 CSN csn1 = new CSN(csn.getTime() + 1, csn.getSeqnum(), csn.getServerId()); 75 CSN csn2 = new CSN(csn1.getTime(), csn1.getSeqnum() + 1, csn1.getServerId()); 76 CSN csn3 = new CSN(csn2.getTime(), csn2.getSeqnum(), (csn2.getServerId() + 1)); 89 assertEquals(csn2.compareTo(serverState.getCSN(csn2.getServerId())), 0); 90 assertEquals(csn3.compareTo(serverState.getCSN(csn3.getServerId())), 0); 104 CSN csn1 = new CSN(csn.getTime() + 1, csn.getSeqnum(), csn.getServerId()); 105 CSN csn3 = new CSN(csn1.getTime(), csn1.getSeqnum(), (csn1.getServerId() + 1));
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/common/ |
H A D | ServerStateTest.java | 74 CSN csn1 = new CSN(csn.getTime() + 1, csn.getSeqnum(), csn.getServerId()); 75 CSN csn2 = new CSN(csn1.getTime(), csn1.getSeqnum() + 1, csn1.getServerId()); 76 CSN csn3 = new CSN(csn2.getTime(), csn2.getSeqnum(), (csn2.getServerId() + 1)); 89 assertEquals(csn2.compareTo(serverState.getCSN(csn2.getServerId())), 0); 90 assertEquals(csn3.compareTo(serverState.getCSN(csn3.getServerId())), 0); 104 CSN csn1 = new CSN(csn.getTime() + 1, csn.getSeqnum(), csn.getServerId()); 105 CSN csn3 = new CSN(csn1.getTime(), csn1.getSeqnum(), (csn1.getServerId() + 1));
|