| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
| H A D | ECLServerWriter.java | 177 handler.getServerId(),
185 handler.getServerId(),
249 handler.getServerId()));
|
| H A D | ReplicationServerHandler.java | 84 serverId = inReplServerStartMsg.getServerId();
268 .get(getReplicationServerId(), getServerId(),
417 .get(getReplicationServerId(), getServerId(),
431 .toString(inReplServerStartMsg.getServerId()), Integer
433 .getServerId()));
701 remoteDirectoryServers.put(lsh.getServerId(), lsh);
721 if (wantedServer == server.getServerId())
|
| /forgerock/opendj2-hg/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());
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
| H A D | ServerWriter.java | 177 handler.getBaseDNString(), handler.getServerId(),
188 handler.getBaseDNString(), handler.getServerId(),
206 handler.getBaseDNString(), handler.getServerId(),
|
| H A D | ServerReader.java | 166 Integer.toString(handler.getServerId()),
276 handler.getBaseDNString(), handler.getServerId(),
287 handler.getBaseDNString(), handler.getServerId(),
306 handler.getServerId(),
|
| H A D | ReplicationServerHandler.java | 82 serverId = inReplServerStartMsg.getServerId();
252 .get(getReplicationServerId(), getServerId(),
387 .get(getReplicationServerId(), getServerId(),
401 Integer.toString(inReplServerStartMsg.getServerId()),
402 Integer.toString(replicationServer.getServerId()));
623 remoteDirectoryServers.put(lsh.getServerId(), lsh);
643 if (serverId == server.getServerId())
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
| H A D | ServerWriter.java | 170 updateMsg.getCSN(), handler.getBaseDN(), handler.getServerId(),
179 updateMsg.getCSN(), handler.getBaseDN(), handler.getServerId(),
196 updateMsg.getCSN(), handler.getBaseDN(), handler.getServerId(),
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/ |
| H A D | ExternalChangelogDomain.java | 65 domain.setEclIncludes(domain.getServerId(),
93 domain.setEclIncludes(domain.getServerId(),
|
| /forgerock/opendj2/src/server/org/opends/server/replication/plugin/ |
| H A D | ExternalChangelogDomain.java | 64 domain.setEclIncludes(domain.getServerId(),
92 domain.setEclIncludes(domain.getServerId(),
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/ |
| H A D | ExternalChangelogDomain.java | 65 domain.setEclIncludes(domain.getServerId(),
93 domain.setEclIncludes(domain.getServerId(),
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/ |
| H A D | ExternalChangelogDomain.java | 65 domain.setEclIncludes(domain.getServerId(),
93 domain.setEclIncludes(domain.getServerId(),
|
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/ |
| H A D | ExternalChangelogDomain.java | 64 domain.setEclIncludes(domain.getServerId(),
92 domain.setEclIncludes(domain.getServerId(),
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/ |
| H A D | ExternalChangelogDomain.java | 65 domain.setEclIncludes(domain.getServerId(),
83 domain.setEclIncludes(domain.getServerId(),
|
| /forgerock/opendj2/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationDomain.java | 423 this.generator = new CSNGenerator(getServerId(), state);
446 getBaseDNString(), Integer.toString(getServerId())));
475 getBaseDNString(), Integer.toString(getServerId())));
553 public int getServerId() method in class:ReplicationDomain
555 return config.getServerId();
828 "[IE] processErrorMsg:" + getServerId() +
975 getBaseDNString(), Integer.toString(getServerId()),
1074 super("Export thread from serverId=" + getServerId() + " to serverId="
1439 initializeRemote(target, getServerId(), initTask, getInitWindow());
1475 countEntries(), getBaseDNString(), getServerId()));
[all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationDomain.java | 423 this.generator = new CSNGenerator(getServerId(), state);
446 getBaseDNString(), Integer.toString(getServerId())));
475 getBaseDNString(), Integer.toString(getServerId())));
553 public int getServerId() method in class:ReplicationDomain
555 return config.getServerId();
828 "[IE] processErrorMsg:" + getServerId() +
975 getBaseDNString(), Integer.toString(getServerId()),
1074 super("Export thread from serverId=" + getServerId() + " to serverId="
1439 initializeRemote(target, getServerId(), initTask, getInitWindow());
1475 countEntries(), getBaseDNString(), getServerId()));
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
| H A D | ReplicationDomain.java | 402 this.generator = new CSNGenerator(getServerId(), state);
424 logger.error(ERR_DS_INVALID_INIT_STATUS, initStatus, getBaseDN(), getServerId());
454 logger.error(ERR_DS_INVALID_REQUESTED_STATUS, reqStatus, getBaseDN(), getServerId());
523 public int getServerId() method in class:ReplicationDomain
525 return config.getServerId();
799 "[IE] processErrorMsg:" + getServerId() +
946 logger.info(NOTE_DS_RECEIVED_ACK_ERROR, getBaseDN(), getServerId(), update, ack.errorsToString());
1044 super("Export thread from serverId=" + getServerId() + " to serverId="
1410 initializeRemote(target, getServerId(), initTask, getInitWindow());
1446 countEntries(), getBaseDN(), getServerId());
[all...] |
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumberGenerator.java | 132 int changeServerId = number.getServerId();
|
| H A D | ServerState.java | 166 int id = changeNumber.getServerId();
445 ChangeNumber change = this.list.get(coveredChange.getServerId());
463 ChangeNumber change = this.list.get(covered.getServerId());
489 Integer id = change.getServerId();
569 Integer id = change.getServerId();
|
| /forgerock/opendj2/src/server/org/opends/server/replication/server/ |
| H A D | ServerReader.java | 166 Integer.toString(handler.getServerId()),
276 handler.getBaseDNString(), handler.getServerId(),
287 handler.getBaseDNString(), handler.getServerId(),
306 handler.getServerId(),
|
| H A D | ReplicationServerHandler.java | 82 serverId = inReplServerStartMsg.getServerId();
252 .get(getReplicationServerId(), getServerId(),
387 .get(getReplicationServerId(), getServerId(),
401 Integer.toString(inReplServerStartMsg.getServerId()),
402 Integer.toString(replicationServer.getServerId()));
623 remoteDirectoryServers.put(lsh.getServerId(), lsh);
643 if (serverId == server.getServerId())
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumberGenerator.java | 132 int changeServerId = number.getServerId();
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/common/ |
| H A D | ChangeNumberGenerator.java | 132 int changeServerId = number.getServerId();
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/api/ |
| H A D | ReplicaId.java | 76 public int getServerId() method in class:ReplicaId
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationServerHandler.java | 84 serverId = inReplServerStartMsg.getServerId();
268 .get(getReplicationServerId(), getServerId(),
417 .get(getReplicationServerId(), getServerId(),
431 .toString(inReplServerStartMsg.getServerId()), Integer
433 .getServerId()));
701 remoteDirectoryServers.put(lsh.getServerId(), lsh);
721 if (wantedServer == server.getServerId())
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationServerHandler.java | 84 serverId = inReplServerStartMsg.getServerId();
268 .get(getReplicationServerId(), getServerId(),
417 .get(getReplicationServerId(), getServerId(),
431 .toString(inReplServerStartMsg.getServerId()), Integer
433 .getServerId()));
701 remoteDirectoryServers.put(lsh.getServerId(), lsh);
721 if (wantedServer == server.getServerId())
|