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

/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationDomainMonitor.java331 for (int dsServerId : toIterable(msg.ldapIterator()))
333 ServerState dsServerState = msg.getLDAPServerState(dsServerId);
335 pendingMonitorData.setLDAPServerState(dsServerId, dsServerState);
336 pendingMonitorData.setFirstMissingDate(dsServerId,
337 msg.getLDAPApproxFirstMissingDate(dsServerId));
H A DReplicationServerDomain.java261 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 DReplicationDomainMonitor.java331 for (int dsServerId : toIterable(msg.ldapIterator()))
333 ServerState dsServerState = msg.getLDAPServerState(dsServerId);
335 pendingMonitorData.setLDAPServerState(dsServerId, dsServerState);
336 pendingMonitorData.setFirstMissingDate(dsServerId,
337 msg.getLDAPApproxFirstMissingDate(dsServerId));
H A DReplicationServerDomain.java261 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 DReplicationDomainMonitor.java326 for (int dsServerId : toIterable(msg.ldapIterator()))
328 ServerState dsServerState = msg.getLDAPServerState(dsServerId);
330 pendingMonitorData.setLDAPServerState(dsServerId, dsServerState);
331 pendingMonitorData.setFirstMissingDate(dsServerId,
332 msg.getLDAPApproxFirstMissingDate(dsServerId));
H A DReplicationServerDomain.java249 private void enqueueDSMonitorMsg(int dsServerId, MonitorMsg msg) argument
251 pendingDSMonitorMsgs.put(dsServerId, msg);
/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,
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,
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,
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.java2997 * @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 DReplicationDomain.java2432 * @param dsServerId The provided serverId.
2435 private short getProtocolVersion(int dsServerId) argument
2437 final DSInfo dsInfo = getReplicaInfos().get(dsServerId);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java2997 * @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 DReplicationDomain.java2432 * @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 DReplicationBroker.java2962 * @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 DReplicationDomain.java2394 * @param dsServerId The provided serverId.
2397 private short getProtocolVersion(int dsServerId) argument
2399 final DSInfo dsInfo = getReplicaInfos().get(dsServerId);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java2400 * @param dsServerId The provided serverId.
2403 short getProtocolVersion(int dsServerId) argument
2408 if (dsi.getDsId() == dsServerId)
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java268 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 DReplicationDomain.java2401 * @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 DReplicationDomain.java2400 * @param dsServerId The provided serverId.
2403 short getProtocolVersion(int dsServerId) argument
2408 if (dsi.getDsId() == dsServerId)

Completed in 342 milliseconds