Searched refs:rsServerId (Results 1 - 19 of 19) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/common/
H A DRSInfo.java39 private final int rsServerId; field in class:RSInfo
58 * @param rsServerId The RS id
64 public RSInfo(int rsServerId, String rsServerURL, argument
67 this.rsServerId = rsServerId;
80 return rsServerId;
128 return rsServerId == rsInfo.getId()
142 hash = 17 * hash + this.rsServerId;
165 return "RS id: " + rsServerId
/forgerock/opendj2-hg/src/server/org/opends/server/replication/common/
H A DRSInfo.java39 private final int rsServerId; field in class:RSInfo
58 * @param rsServerId The RS id
64 public RSInfo(int rsServerId, String rsServerURL, argument
67 this.rsServerId = rsServerId;
80 return rsServerId;
128 return rsServerId == rsInfo.getId()
142 hash = 17 * hash + this.rsServerId;
165 return "RS id: " + rsServerId
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/common/
H A DRSInfo.java39 private final int rsServerId; field in class:RSInfo
58 * @param rsServerId The RS id
64 public RSInfo(int rsServerId, String rsServerURL, argument
67 this.rsServerId = rsServerId;
80 return rsServerId;
128 return rsServerId == rsInfo.getId()
142 hash = 17 * hash + this.rsServerId;
165 return "RS id: " + rsServerId
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationBrokerTest.java67 private DSInfo dsInfo(int dsServerId, int rsServerId) argument
70 return new DSInfo(dsServerId, null, rsServerId, 0, null,
74 private ReplicationServerInfo rsInfo(int rsServerId, Integer... dsIds) argument
77 final RSInfo info = new RSInfo(rsServerId, rsServerId + ":1389", 0, z, 0);
131 Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId,
137 return new Topology(topologyMsg, dsServerId, rsServerId, rsUrls, previousRSs);
141 return new Topology(replicaInfos, rsInfos, dsServerId, rsServerId, rsUrls, previousRSs);
130 newTopology(TopologyCtorToUse toUse, Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId, Set<String> rsUrls, Map<Integer, ReplicationServerInfo> previousRSs) argument
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/
H A DReplicationBrokerTest.java67 private DSInfo dsInfo(int dsServerId, int rsServerId) argument
70 return new DSInfo(dsServerId, null, rsServerId, 0, null,
74 private ReplicationServerInfo rsInfo(int rsServerId, Integer... dsIds) argument
77 final RSInfo info = new RSInfo(rsServerId, rsServerId + ":1389", 0, z, 0);
131 Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId,
137 return new Topology(topologyMsg, dsServerId, rsServerId, rsUrls, previousRSs);
141 return new Topology(replicaInfos, rsInfos, dsServerId, rsServerId, rsUrls, previousRSs);
130 newTopology(TopologyCtorToUse toUse, Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId, Set<String> rsUrls, Map<Integer, ReplicationServerInfo> previousRSs) argument
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/
H A DReplicationBrokerTest.java67 private DSInfo dsInfo(int dsServerId, int rsServerId) argument
70 return new DSInfo(dsServerId, null, rsServerId, 0, null,
74 private ReplicationServerInfo rsInfo(int rsServerId, Integer... dsIds) argument
77 final RSInfo info = new RSInfo(rsServerId, rsServerId + ":1389", 0, z, 0);
130 Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId,
136 return new Topology(topologyMsg, dsServerId, rsServerId, rsUrls, previousRSs);
140 return new Topology(replicaInfos, rsInfos, dsServerId, rsServerId, rsUrls, previousRSs);
129 newTopology(TopologyCtorToUse toUse, Map<Integer, DSInfo> replicaInfos, List<RSInfo> rsInfos, int dsServerId, int rsServerId, Set<String> rsUrls, Map<Integer, ReplicationServerInfo> previousRSs) argument
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java836 final int rsServerId = rs.rsInfo.getServerId();
840 serverId, rsServerId, baseDN.toNormalizedString(),
846 serverId, rsServerId, baseDN.toNormalizedString(),
877 final int rsServerId = getRsServerId();
885 rsServerId, getReplicationServerUrls(), oldTopo.rsInfos);
891 debugInfo(topologyChange(rsServerId, oldTopo, newTopo));
895 private StringBuilder topologyChange(int rsServerId, Topology oldTopo, argument
899 sb.append("rsServerId=").append(rsServerId);
1367 * @param rsServerId
1372 getEvaluation(int rsServerId) argument
1468 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
2927 receiveTopo(TopologyMsg topoMsg, int rsServerId) argument
2937 computeNewTopology(TopologyMsg topoMsg, int rsServerId) argument
2968 private final int rsServerId; field in class:ReplicationBroker.Topology
3006 Topology(Map<Integer, DSInfo> dsInfosToKeep, List<RSInfo> newRSInfos, int dsServerId, int rsServerId, Set<String> configuredReplicationServerUrls, Map<Integer, ReplicationServerInfo> previousRsInfos) argument
3033 Topology(TopologyMsg topoMsg, int dsServerId, int rsServerId, Set<String> configuredReplicationServerUrls, Map<Integer, ReplicationServerInfo> previousRsInfos) argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java836 final int rsServerId = rs.rsInfo.getServerId();
840 serverId, rsServerId, baseDN.toNormalizedString(),
846 serverId, rsServerId, baseDN.toNormalizedString(),
877 final int rsServerId = getRsServerId();
885 rsServerId, getReplicationServerUrls(), oldTopo.rsInfos);
891 debugInfo(topologyChange(rsServerId, oldTopo, newTopo));
895 private StringBuilder topologyChange(int rsServerId, Topology oldTopo, argument
899 sb.append("rsServerId=").append(rsServerId);
1367 * @param rsServerId
1372 getEvaluation(int rsServerId) argument
1468 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
2927 receiveTopo(TopologyMsg topoMsg, int rsServerId) argument
2937 computeNewTopology(TopologyMsg topoMsg, int rsServerId) argument
2968 private final int rsServerId; field in class:ReplicationBroker.Topology
3006 Topology(Map<Integer, DSInfo> dsInfosToKeep, List<RSInfo> newRSInfos, int dsServerId, int rsServerId, Set<String> configuredReplicationServerUrls, Map<Integer, ReplicationServerInfo> previousRsInfos) argument
3033 Topology(TopologyMsg topoMsg, int dsServerId, int rsServerId, Set<String> configuredReplicationServerUrls, Map<Integer, ReplicationServerInfo> previousRsInfos) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java828 final int rsServerId = rs.rsInfo.getServerId();
831 logger.info(NOTE_NOW_FOUND_SAME_GENERATION_CHANGELOG, serverId, rsServerId, baseDN,
836 logger.warn(WARN_NOW_FOUND_BAD_GENERATION_CHANGELOG, serverId, rsServerId, baseDN,
865 final int rsServerId = getRsServerId();
873 rsServerId, getReplicationServerUrls(), oldTopo.rsInfos);
879 debugInfo(topologyChange(rsServerId, oldTopo, newTopo));
883 private StringBuilder topologyChange(int rsServerId, Topology oldTopo, argument
887 sb.append("rsServerId=").append(rsServerId);
1345 * @param rsServerId
1350 getEvaluation(int rsServerId) argument
1444 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
2892 receiveTopo(TopologyMsg topoMsg, int rsServerId) argument
2902 computeNewTopology(TopologyMsg topoMsg, int rsServerId) argument
2933 private final int rsServerId; field in class:ReplicationBroker.Topology
2971 Topology(Map<Integer, DSInfo> dsInfosToKeep, List<RSInfo> newRSInfos, int dsServerId, int rsServerId, Set<String> configuredReplicationServerUrls, Map<Integer, ReplicationServerInfo> previousRsInfos) argument
2998 Topology(TopologyMsg topoMsg, int dsServerId, int rsServerId, Set<String> configuredReplicationServerUrls, Map<Integer, ReplicationServerInfo> previousRsInfos) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationDomainMonitor.java342 for (int rsServerId : toIterable(msg.rsIterator()))
344 long newFmd = msg.getRSApproxFirstMissingDate(rsServerId);
345 if (rsServerId == domain.getLocalRSServerId())
360 domain.getConnectedRSs().get(rsServerId);
H A DReplicationServerDomain.java266 private void enqueueRSMonitorMsg(int rsServerId, MonitorMsg msg) argument
268 pendingRSMonitorMsgs.put(rsServerId, msg);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationDomainMonitor.java342 for (int rsServerId : toIterable(msg.rsIterator()))
344 long newFmd = msg.getRSApproxFirstMissingDate(rsServerId);
345 if (rsServerId == domain.getLocalRSServerId())
360 domain.getConnectedRSs().get(rsServerId);
H A DReplicationServerDomain.java266 private void enqueueRSMonitorMsg(int rsServerId, MonitorMsg msg) argument
268 pendingRSMonitorMsgs.put(rsServerId, msg);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationDomainMonitor.java337 for (int rsServerId : toIterable(msg.rsIterator()))
339 long newFmd = msg.getRSApproxFirstMissingDate(rsServerId);
340 if (rsServerId == domain.getLocalRSServerId())
355 domain.getConnectedRSs().get(rsServerId);
H A DReplicationServerDomain.java254 private void enqueueRSMonitorMsg(int rsServerId, MonitorMsg msg) argument
256 pendingRSMonitorMsgs.put(rsServerId, msg);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java109 private Integer rsServerId = -1; field in class:ReplicationBroker
309 return rsServerId;
984 .get(serverId, rsServerId, baseDn,
991 .get(serverId, rsServerId, baseDn,
1049 rsServerId = rsInfo.getServerId();
1104 .toString(groupId), Integer.toString(rsServerId), rsInfo
1626 * @param rsServerId
1631 private Message getEvaluation(int rsServerId) argument
1633 final Message evaluation = getEvaluations().get(rsServerId);
1638 return NOTE_UNKNOWN_RS.get(rsServerId, localServerI
1729 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java115 private Integer rsServerId = -1; field in class:ReplicationBroker
309 return rsServerId;
985 .get(serverId, rsServerId, baseDn,
992 .get(serverId, rsServerId, baseDn,
1050 rsServerId = rsInfo.getServerId();
1105 .toString(groupId), Integer.toString(rsServerId), rsInfo
1520 * @param rsServerId The id of the replication server we are currently
1534 boolean firstConnection, int rsServerId, ServerState myState,
1602 return computeBestServerForWeight(bestServers, rsServerId,
2195 rsServerId
1533 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java115 private Integer rsServerId = -1; field in class:ReplicationBroker
309 return rsServerId;
985 .get(serverId, rsServerId, baseDn,
992 .get(serverId, rsServerId, baseDn,
1050 rsServerId = rsInfo.getServerId();
1105 .toString(groupId), Integer.toString(rsServerId), rsInfo
1520 * @param rsServerId The id of the replication server we are currently
1534 boolean firstConnection, int rsServerId, ServerState myState,
1602 return computeBestServerForWeight(bestServers, rsServerId,
2195 rsServerId
1533 computeBestReplicationServer( boolean firstConnection, int rsServerId, ServerState myState, Map<Integer, ReplicationServerInfo> rsInfos, int localServerId, byte groupId, long generationId) argument
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java273 private void enqueueRSMonitorMsg(int rsServerId, MonitorMsg msg) argument
275 pendingRSMonitorMsgs.put(rsServerId, msg);

Completed in 107 milliseconds