/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, 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, 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, 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 | 261 private void enqueueDSMonitorMsg(int dsServerId, MonitorMsg msg) argument 263 pendingDSMonitorMsgs.put(dsServerId, msg);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 261 private void enqueueDSMonitorMsg(int dsServerId, MonitorMsg msg) argument 263 pendingDSMonitorMsgs.put(dsServerId, msg);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 249 private void enqueueDSMonitorMsg(int dsServerId, MonitorMsg msg) argument 251 pendingDSMonitorMsgs.put(dsServerId, msg);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 2400 * @param dsServerId The provided serverId. 2403 short getProtocolVersion(int dsServerId) argument 2408 if (dsi.getDsId() == dsServerId)
|
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 2997 * @param dsServerId 3007 int dsServerId, int rsServerId, 3014 this.rsInfos = computeRSInfos(dsServerId, newRSInfos, 3024 * @param dsServerId 3033 Topology(TopologyMsg topoMsg, int dsServerId, argument 3038 this.replicaInfos = removeThisDs(topoMsg.getReplicaInfos(), dsServerId); 3039 this.rsInfos = computeRSInfos(dsServerId, topoMsg.getRsInfos(), 3044 int dsServerId) 3047 copy.remove(dsServerId); 3052 int dsServerId, Lis 3006 Topology(Map<Integer, DSInfo> dsInfosToKeep, List<RSInfo> newRSInfos, int dsServerId, int rsServerId, Set<String> configuredReplicationServerUrls, Map<Integer, ReplicationServerInfo> previousRsInfos) argument 3043 removeThisDs(Map<Integer, DSInfo> dsInfos, int dsServerId) argument 3051 computeRSInfos( int dsServerId, List<RSInfo> newRsInfos, Map<Integer, ReplicationServerInfo> previousRsInfos, Set<String> configuredReplicationServerUrls) argument 3090 computeDSsConnectedTo(int rsId, int dsServerId) argument [all...] |
H A D | ReplicationDomain.java | 2432 * @param dsServerId The provided serverId. 2435 private short getProtocolVersion(int dsServerId) argument 2437 final DSInfo dsInfo = getReplicaInfos().get(dsServerId);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerDomain.java | 268 private void enqueueDSMonitorMsg(int dsServerId, MonitorMsg msg) argument 270 pendingDSMonitorMsgs.put(dsServerId, msg);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 2401 * @param dsServerId The provided serverId. 2404 short getProtocolVersion(int dsServerId) argument 2409 if (dsi.getDsId() == dsServerId)
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 2400 * @param dsServerId The provided serverId. 2403 short getProtocolVersion(int dsServerId) argument 2408 if (dsi.getDsId() == dsServerId)
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 2997 * @param dsServerId 3007 int dsServerId, int rsServerId, 3014 this.rsInfos = computeRSInfos(dsServerId, newRSInfos, 3024 * @param dsServerId 3033 Topology(TopologyMsg topoMsg, int dsServerId, argument 3038 this.replicaInfos = removeThisDs(topoMsg.getReplicaInfos(), dsServerId); 3039 this.rsInfos = computeRSInfos(dsServerId, topoMsg.getRsInfos(), 3044 int dsServerId) 3047 copy.remove(dsServerId); 3052 int dsServerId, Lis 3006 Topology(Map<Integer, DSInfo> dsInfosToKeep, List<RSInfo> newRSInfos, int dsServerId, int rsServerId, Set<String> configuredReplicationServerUrls, Map<Integer, ReplicationServerInfo> previousRsInfos) argument 3043 removeThisDs(Map<Integer, DSInfo> dsInfos, int dsServerId) argument 3051 computeRSInfos( int dsServerId, List<RSInfo> newRsInfos, Map<Integer, ReplicationServerInfo> previousRsInfos, Set<String> configuredReplicationServerUrls) argument 3090 computeDSsConnectedTo(int rsId, int dsServerId) argument [all...] |
H A D | ReplicationDomain.java | 2432 * @param dsServerId The provided serverId. 2435 private short getProtocolVersion(int dsServerId) argument 2437 final DSInfo dsInfo = getReplicaInfos().get(dsServerId);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 2962 * @param dsServerId 2972 int dsServerId, int rsServerId, 2979 this.rsInfos = computeRSInfos(dsServerId, newRSInfos, 2989 * @param dsServerId 2998 Topology(TopologyMsg topoMsg, int dsServerId, argument 3003 this.replicaInfos = removeThisDs(topoMsg.getReplicaInfos(), dsServerId); 3004 this.rsInfos = computeRSInfos(dsServerId, topoMsg.getRsInfos(), 3009 int dsServerId) 3012 copy.remove(dsServerId); 3017 int dsServerId, Lis 2971 Topology(Map<Integer, DSInfo> dsInfosToKeep, List<RSInfo> newRSInfos, int dsServerId, int rsServerId, Set<String> configuredReplicationServerUrls, Map<Integer, ReplicationServerInfo> previousRsInfos) argument 3008 removeThisDs(Map<Integer, DSInfo> dsInfos, int dsServerId) argument 3016 computeRSInfos( int dsServerId, List<RSInfo> newRsInfos, Map<Integer, ReplicationServerInfo> previousRsInfos, Set<String> configuredReplicationServerUrls) argument 3054 computeDSsConnectedTo(int rsId, int dsServerId) argument [all...] |
H A D | ReplicationDomain.java | 2394 * @param dsServerId The provided serverId. 2397 private short getProtocolVersion(int dsServerId) argument 2399 final DSInfo dsInfo = getReplicaInfos().get(dsServerId);
|