Cross Reference: /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ReplicationBroker.java

Lines Matching defs:replicationServerInfo
356    * @param replicationServerInfo the Replication server to check and update
359     ReplicationServerInfo replicationServerInfo)
363     String rsUrl = replicationServerInfo.getServerURL();
369       replicationServerInfo.setLocallyConfigured(false);
377         replicationServerInfo.setLocallyConfigured(true);
378         replicationServerInfo.serverURL = serverUrl;
382     replicationServerInfo.setLocallyConfigured(false);
823       ReplicationServerInfo replicationServerInfo =
827       if (replicationServerInfo != null)
829         rsInfos.put(replicationServerInfo.getServerId(), replicationServerInfo);
1643       ReplicationServerInfo replicationServerInfo = bestServers.get(rsId);
1644       if (replicationServerInfo.isLocallyConfigured())
1646         result.put(rsId, replicationServerInfo);
1669       ReplicationServerInfo replicationServerInfo = bestServers.get(rsId);
1670       if (replicationServerInfo.getGroupId() == groupId)
1672         result.put(rsId, replicationServerInfo);
1700       ReplicationServerInfo replicationServerInfo = bestServers.get(rsId);
1701       if (replicationServerInfo.getGenerationId() == generationId)
1703         result.put(rsId, replicationServerInfo);
1704         if (!replicationServerInfo.serverState.isEmpty())
1715         ReplicationServerInfo replicationServerInfo = bestServers.get(rsId);
1716         if (replicationServerInfo.getGenerationId() == -1)
1718           result.put(rsId, replicationServerInfo);
1762       ReplicationServerInfo replicationServerInfo = bestServers.get(rsId);
1763       ServerState rsState = replicationServerInfo.getServerState();
1777           upToDateServers.put(rsId, replicationServerInfo);
1791               moreUpToDateServers.put(rsId, replicationServerInfo);
1797               moreUpToDateServers.put(rsId, replicationServerInfo);
1839       ReplicationServerInfo replicationServerInfo = bestServers.get(rsId);
1840       String server = replicationServerInfo.getServerURL();
1857             result.put(rsId, replicationServerInfo);
1861             result.put(rsId, replicationServerInfo);
1909     for (ReplicationServerInfo replicationServerInfo : bestServers.values())
1911       sumOfWeights += replicationServerInfo.getWeight();
1912       sumOfConnectedDSs += replicationServerInfo.getConnectedDSNumber();
1921       ReplicationServerInfo replicationServerInfo = bestServers.get(rsId);
1923       int rsWeight = replicationServerInfo.getWeight();
1931         int connectedDSs = replicationServerInfo.getConnectedDSNumber();
2935     for (ReplicationServerInfo replicationServerInfo :
2938       result.add(replicationServerInfo.toRSInfo());
2995       ReplicationServerInfo replicationServerInfo =
2997       if (replicationServerInfo == null)
3000         replicationServerInfo =
3004         updateRSInfoLocallyConfiguredStatus(replicationServerInfo);
3005         replicationServerInfos.put(rsId, replicationServerInfo);
3009         replicationServerInfo.update(rsInfo, connectedDSs);