| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
| 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...] |
| H A D | SafeDataExpectedAcksInfo.java | 97 + ackingServer.getServerId() + " ack message: " + ackMsg);
102 int ackingServerId = ackingServer.getServerId();
|
| /forgerock/opendj2/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 110 public int getServerId() method in class:ReplicationBroker.ConnectedRS
112 return rsInfo != null ? rsInfo.getServerId() : -1;
143 sb.append("connectedRS(serverId=").append(rsInfo.getServerId())
307 return connectedRS.get().getServerId();
314 public int getServerId() method in class:ReplicationBroker
316 return config.getServerId();
456 this.rsInfo = new RSInfo(msg.getServerId(), msg.getServerURL(),
475 this.rsInfo = new RSInfo(msg.getServerId(), msg.getServerURL(),
551 public int getServerId() method in class:ReplicationBroker.ReplicationServerInfo
695 + " ServerId:" + getServerId()
[all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 110 public int getServerId() method in class:ReplicationBroker.ConnectedRS
112 return rsInfo != null ? rsInfo.getServerId() : -1;
143 sb.append("connectedRS(serverId=").append(rsInfo.getServerId())
307 return connectedRS.get().getServerId();
314 public int getServerId() method in class:ReplicationBroker
316 return config.getServerId();
456 this.rsInfo = new RSInfo(msg.getServerId(), msg.getServerURL(),
475 this.rsInfo = new RSInfo(msg.getServerId(), msg.getServerURL(),
551 public int getServerId() method in class:ReplicationBroker.ReplicationServerInfo
695 + " ServerId:" + getServerId()
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 107 public int getServerId() method in class:ReplicationBroker.ConnectedRS
109 return rsInfo != null ? rsInfo.getServerId() : -1;
140 sb.append("connectedRS(serverId=").append(rsInfo.getServerId())
298 return connectedRS.get().getServerId();
305 public int getServerId() method in class:ReplicationBroker
307 return config.getServerId();
447 this.rsInfo = new RSInfo(msg.getServerId(), msg.getServerURL(),
466 this.rsInfo = new RSInfo(msg.getServerId(), msg.getServerURL(),
542 public int getServerId() method in class:ReplicationBroker.ReplicationServerInfo
686 + " ServerId:" + getServerId()
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
| H A D | ServerReader.java | 162 handler.getBaseDN(), handler.getServerId(), csMsg);
276 handler.getBaseDN(), handler.getServerId(),
285 handler.getBaseDN(), handler.getServerId(),
302 handler.getBaseDN(), handler.getServerId(),
|
| H A D | SafeDataExpectedAcksInfo.java | 90 + ackingServer.getServerId() + " ack message: " + ackMsg);
96 int ackingServerId = ackingServer.getServerId();
|
| H A D | ReplicationServerHandler.java | 80 serverId = inReplServerStartMsg.getServerId();
251 logger.debug(INFO_REPLICATION_SERVER_CONNECTION_TO_RS, getReplicationServerId(), getServerId(),
378 logger.debug(INFO_REPLICATION_SERVER_CONNECTION_FROM_RS, getReplicationServerId(), getServerId(),
387 inReplServerStartMsg.getServerId(), replicationServer.getServerId()));
597 remoteDirectoryServers.put(lsh.getServerId(), lsh);
617 if (serverId == server.getServerId())
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
| H A D | SafeDataExpectedAcksInfo.java | 94 + ackingServer.getServerId() + " ack message: " + ackMsg);
99 int ackingServerId = ackingServer.getServerId();
|
| H A D | ServerReader.java | 144 handler.getServiceId(), handler.getServerId(),
152 handler.getServiceId(), handler.getServerId(),
171 handler.getServerId(),
241 Integer.toString(handler.getServerId()),
305 handler.getReplicationServerId(), handler.getServerId(),
311 handler.getReplicationServerId(), handler.getServerId(),
|
| H A D | ECLServerWriter.java | 177 handler.getServerId(),
185 handler.getServerId(),
249 handler.getServerId()));
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
| H A D | ListenerThread.java | 65 super("Replica DS(" + repDomain.getServerId()
148 + repDomain.getServiceID() + " in DS " + repDomain.getServerId());
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
| H A D | CSNGeneratorTest.java | 103 assertEquals(csns[i + 1].getServerId(), csns[i].getServerId());
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/ |
| H A D | SafeDataExpectedAcksInfo.java | 97 + ackingServer.getServerId() + " ack message: " + ackMsg);
102 int ackingServerId = ackingServer.getServerId();
|
| H A D | ServerWriter.java | 177 handler.getBaseDNString(), handler.getServerId(),
188 handler.getBaseDNString(), handler.getServerId(),
206 handler.getBaseDNString(), handler.getServerId(),
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
| H A D | SafeDataExpectedAcksInfo.java | 94 + ackingServer.getServerId() + " ack message: " + ackMsg);
99 int ackingServerId = ackingServer.getServerId();
|
| H A D | ServerReader.java | 144 handler.getServiceId(), handler.getServerId(),
152 handler.getServiceId(), handler.getServerId(),
171 handler.getServerId(),
232 Integer.toString(handler.getServerId()),
287 handler.getReplicationServerId(), handler.getServerId(),
293 handler.getReplicationServerId(), handler.getServerId(),
|
| H A D | ECLServerWriter.java | 177 handler.getServerId(),
185 handler.getServerId(),
249 handler.getServerId()));
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
| H A D | ListenerThread.java | 65 super("Replica DS(" + repDomain.getServerId()
148 + repDomain.getServiceID() + " in DS " + repDomain.getServerId());
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/common/ |
| H A D | CSNGeneratorTest.java | 103 assertEquals(csns[i + 1].getServerId(), csns[i].getServerId());
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
| H A D | SafeDataExpectedAcksInfo.java | 94 + ackingServer.getServerId() + " ack message: " + ackMsg);
99 int ackingServerId = ackingServer.getServerId();
|
| H A D | ServerReader.java | 144 handler.getServiceId(), handler.getServerId(),
152 handler.getServiceId(), handler.getServerId(),
171 handler.getServerId(),
241 Integer.toString(handler.getServerId()),
305 handler.getReplicationServerId(), handler.getServerId(),
311 handler.getReplicationServerId(), handler.getServerId(),
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
| H A D | ListenerThread.java | 65 super("Replica DS(" + repDomain.getServerId()
148 + repDomain.getServiceID() + " in DS " + repDomain.getServerId());
|
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/common/ |
| H A D | CSNGeneratorTest.java | 103 assertEquals(csns[i + 1].getServerId(), csns[i].getServerId());
|
| /forgerock/opendj2/src/server/org/opends/server/replication/common/ |
| H A D | ServerState.java | 93 final int serverId = csn.getServerId();
159 if (serverIdToCSN.remove(expectedCSN.getServerId(), expectedCSN))
338 final CSN csn = this.serverIdToCSN.get(covered.getServerId());
|