| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationServer.java | 295 getServerId(),
1204 public int getServerId() method in class:ReplicationServer
|
| H A D | ServerHandler.java | 682 public int getServerId() method in class:ServerHandler
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
| H A D | ReplicationServer.java | 294 getServerId(),
1225 public int getServerId() method in class:ReplicationServer
|
| H A D | ServerHandler.java | 680 public int getServerId() method in class:ServerHandler
|
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 316 public int getServerId() method in class:ReplicationBroker
558 this.serverId = replServerStartMsg.getServerId();
580 this.serverId = replServerStartDSMsg.getServerId();
632 public int getServerId() method in class:ReplicationBroker.ReplicationServerInfo
829 rsInfos.put(replicationServerInfo.getServerId(), replicationServerInfo);
951 .put(electedRsInfo.getServerId(), electedRsInfo);
1050 rsServerId = rsInfo.getServerId();
1470 domain.getEclIncludes(domain.getServerId()),
1471 domain.getEclIncludesForDeletes(domain.getServerId()));
2150 heartbeatMonitor = new HeartbeatMonitor(getServerId(),
[all...] |
| H A D | ReplicationDomain.java | 490 public int getServerId() method in class:ReplicationDomain
|
| /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...] |
| 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.6.2/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 316 public int getServerId() method in class:ReplicationBroker
558 this.serverId = replServerStartMsg.getServerId();
580 this.serverId = replServerStartDSMsg.getServerId();
632 public int getServerId() method in class:ReplicationBroker.ReplicationServerInfo
829 rsInfos.put(replicationServerInfo.getServerId(), replicationServerInfo);
950 .put(electedRsInfo.getServerId(), electedRsInfo);
1049 rsServerId = rsInfo.getServerId();
1470 domain.getEclIncludes(domain.getServerId()),
1471 domain.getEclIncludesForDeletes(domain.getServerId()));
1564 if (rsInfo.getServerId() !
[all...] |
| H A D | ReplicationDomain.java | 491 public int getServerId() method in class:ReplicationDomain
|
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 316 public int getServerId() method in class:ReplicationBroker
558 this.serverId = replServerStartMsg.getServerId();
580 this.serverId = replServerStartDSMsg.getServerId();
632 public int getServerId() method in class:ReplicationBroker.ReplicationServerInfo
829 rsInfos.put(replicationServerInfo.getServerId(), replicationServerInfo);
951 .put(electedRsInfo.getServerId(), electedRsInfo);
1050 rsServerId = rsInfo.getServerId();
1470 domain.getEclIncludes(domain.getServerId()),
1471 domain.getEclIncludesForDeletes(domain.getServerId()));
2150 heartbeatMonitor = new HeartbeatMonitor(getServerId(),
[all...] |
| H A D | ReplicationDomain.java | 490 public int getServerId() method in class:ReplicationDomain
|
| /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...] |
| 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 | 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...] |
| 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...] |