Searched defs:rsServerId (Results 1 - 16 of 16) 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/server/
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 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 DReplicationServerDomain.java254 private void enqueueRSMonitorMsg(int rsServerId, MonitorMsg msg) argument
256 pendingRSMonitorMsgs.put(rsServerId, msg);
/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/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.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);
/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/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-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...]

Completed in 103 milliseconds