Lines Matching defs:getServerId
107 public int getServerId()
109 return rsInfo != null ? rsInfo.getServerId() : -1;
140 sb.append("connectedRS(serverId=").append(rsInfo.getServerId())
298 return connectedRS.get().getServerId();
305 public int getServerId()
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()
686 + " ServerId:" + getServerId()
708 rsInfos.put(rsInfo.getServerId(), rsInfo);
759 final int serverId = getServerId();
801 rsInfos.put(electedRsInfo.getServerId(), electedRsInfo);
828 final int rsServerId = rs.rsInfo.getServerId();
872 newTopo = new Topology(oldTopo.replicaInfos, newRSInfos, getServerId(),
921 receiveTopo(topologyMsg, rs.getServerId());
963 groupId, rs.getServerId(), rsInfo.getServerURL(), rs.getGroupId(), baseDN, getServerId());
1087 final StartMsg serverStartMsg = new ServerStartMsg(getServerId(), url, getBaseDN(),
1139 errorMessage = WARN_NO_CHANGELOG_SERVER_LISTENING.get(getServerId(), serverURL, getBaseDN());
1144 errorMessage = WARN_TIMEOUT_CONNECTING_TO_RS.get(getServerId(), serverURL, getBaseDN());
1150 getServerId(), serverURL, getBaseDN(), stackTraceToSingleLineString(e));
1200 domain.getEclIncludes(domain.getServerId()),
1201 domain.getEclIncludesForDeletes(domain.getServerId()));
1222 getServerId(), electedRS.rsInfo.getServerURL(), getBaseDN(), stackTraceToSingleLineString(e));
1283 if (rsInfo.getServerId() != bestRsId)
1329 final Integer bestRSServerId = getBestRS().getServerId();
1389 this.accepted.remove(rsInfo.getServerId()); // undo accept
1409 result.put(entry.getKey().getServerId(), entry.getValue());
1734 rsInfo.getServerId(), rsCSN, localServerId, localCSN.toStringUI());
1802 rsInfo.getServerId(), localServerId));
2115 heartbeatMonitor = new HeartbeatMonitor(getServerId(), rs.getServerId(),
2201 + rs.getServerId() + ") genId=" + getGenerationID());
2446 final int serverId = getServerId();
2448 final int previousRsServerID = rs.getServerId();
2540 || bestServerInfo.getServerId() != previousRsServerID))
2552 final int bestRsServerId = bestServerInfo.getServerId();
2620 publish(new MonitorRequestMsg(getServerId(), getRsServerId()));
2848 logger.error(ERR_EXCEPTION_SENDING_CS, getBaseDN(), getServerId(),
2909 newTopo = new Topology(topoMsg, getServerId(), rsServerId,
3206 final String threadName = "Replica DS(" + getServerId()
3208 + "\" to RS(" + rs.getServerId() + ") at " + rs.replicationServer;
3211 threadName, rs.session, changeTimeHeartbeatInterval, getServerId());
3328 .append(getServerId()).append("\",")
3339 + " and serverId=" + getServerId() + ": " + message);