/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...] |