Searched refs:getServerId (Results 26 - 50 of 335) sorted by relevance

1234567891011>>

/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DServerWriter.java141 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 DReplicationServerDomain.java232 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 DExternalChangeLogSessionImpl.java61 rs.getServerId(),
H A DDataServerHandler.java133 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 DServerWriter.java141 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 DReplicationServerDomain.java209 + 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 DExternalChangeLogSessionImpl.java61 rs.getServerId(),
H A DDataServerHandler.java134 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 DReplicationServerDomain.java225 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 DDataServerHandler.java106 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 DReplicationServerDomain.java225 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 DReplicationServerDomain.java213 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 DDataServerHandler.java107 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 DReplicationServerDomain.java209 + 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 DExternalChangeLogSessionImpl.java61 rs.getServerId(),
H A DDataServerHandler.java134 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 DCSNGenerator.java81 if (csn.getServerId() == serverId)
144 int changeServerId = number.getServerId();
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/
H A DCSNGenerator.java81 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 DCSNGenerator.java81 if (csn.getServerId() == serverId)
144 int changeServerId = number.getServerId();
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationBrokerTest.java91 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 DReplicationBrokerTest.java91 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 DReplicationBrokerTest.java90 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 DServerStateTest.java74 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 DServerStateTest.java74 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 DServerStateTest.java74 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));

Completed in 99 milliseconds

1234567891011>>