/forgerock/opendj2/src/server/org/opends/server/replication/common/ |
H A D | RSInfo.java | 39 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 D | RSInfo.java | 39 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 D | RSInfo.java | 39 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 D | ReplicationBrokerTest.java | 67 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 D | ReplicationBrokerTest.java | 67 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 D | ReplicationBrokerTest.java | 67 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 D | ReplicationServerDomain.java | 266 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 D | ReplicationServerDomain.java | 266 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 D | ReplicationServerDomain.java | 254 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 D | ReplicationBroker.java | 115 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 D | ReplicationBroker.java | 836 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 D | ReplicationServerDomain.java | 273 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 D | ReplicationBroker.java | 109 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 D | ReplicationBroker.java | 115 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 D | ReplicationBroker.java | 836 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 D | ReplicationBroker.java | 828 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...] |