Searched refs:topoMsg (Results 1 - 25 of 30) sorted by relevance

12

/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DReplicationServerHandler.java575 * @param topoMsg The received topology message
577 public void processTopoInfoFromRS(TopologyMsg topoMsg) argument
580 final RSInfo rsInfo = topoMsg.getRsInfos().get(0);
590 for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
719 * @param topoMsg The message received.
723 public void receiveTopoInfoFromRS(TopologyMsg topoMsg) argument
726 replicationServerDomain.receiveTopoInfoFromRS(topoMsg, this, true);
H A DReplicationServerDomain.java2056 * @param topoMsg The just received topo message from remote RS
2063 public void receiveTopoInfoFromRS(TopologyMsg topoMsg, argument
2070 + ":\n" + topoMsg);
2090 rsHandler.processTopoInfoFromRS(topoMsg);
2633 final TopologyMsg topoMsg = createTopologyMsgForDS(handler
2635 sendTopologyMsg("directory", handler, topoMsg);
2642 final TopologyMsg topoMsg = createTopologyMsgForRS();
2645 sendTopologyMsg("replication", handler, topoMsg);
H A DServerHandler.java845 * @param topoMsg
850 public void sendTopoInfo(TopologyMsg topoMsg) throws IOException argument
855 send(topoMsg);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java665 * @param topoMsg The received topology message
667 public void processTopoInfoFromRS(TopologyMsg topoMsg) argument
670 List<RSInfo> rsInfos = topoMsg.getRsList();
680 List<DSInfo> dsInfos = topoMsg.getDsList();
847 * @param topoMsg The message received.
851 public void receiveTopoInfoFromRS(TopologyMsg topoMsg) argument
855 replicationServerDomain.receiveTopoInfoFromRS(topoMsg, this, true);
H A DServerReader.java225 TopologyMsg topoMsg = (TopologyMsg) msg;
227 rsh.receiveTopoInfoFromRS(topoMsg);
H A DReplicationServerDomain.java1880 TopologyMsg topoMsg=createTopologyMsgForDS(handler.getServerId());
1883 handler.sendTopoInfo(topoMsg);
1912 TopologyMsg topoMsg = createTopologyMsgForRS();
1923 handler.sendTopoInfo(topoMsg);
2412 * @param topoMsg The just received topo message from remote RS
2419 public void receiveTopoInfoFromRS(TopologyMsg topoMsg, argument
2429 " for baseDn " + baseDn + ":\n" + topoMsg);
2451 handler.processTopoInfoFromRS(topoMsg);
H A DServerHandler.java971 * @param topoMsg
976 public void sendTopoInfo(TopologyMsg topoMsg) throws IOException argument
981 send(topoMsg);
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java601 * @param topoMsg The received topology message
603 public void processTopoInfoFromRS(TopologyMsg topoMsg) argument
606 final RSInfo rsInfo = topoMsg.getRsInfos().get(0);
616 for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
752 * @param topoMsg The message received.
756 public void receiveTopoInfoFromRS(TopologyMsg topoMsg) argument
759 replicationServerDomain.receiveTopoInfoFromRS(topoMsg, this, true);
H A DReplicationServerDomain.java2119 * @param topoMsg The just received topo message from remote RS
2126 public void receiveTopoInfoFromRS(TopologyMsg topoMsg, argument
2133 + ":\n" + topoMsg);
2153 rsHandler.processTopoInfoFromRS(topoMsg);
2705 final TopologyMsg topoMsg = createTopologyMsgForDS(handler
2707 sendTopologyMsg("directory", handler, topoMsg);
2714 final TopologyMsg topoMsg = createTopologyMsgForRS();
2717 sendTopologyMsg("replication", handler, topoMsg);
H A DServerHandler.java882 * @param topoMsg
887 public void sendTopoInfo(TopologyMsg topoMsg) throws IOException argument
892 send(topoMsg);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java665 * @param topoMsg The received topology message
667 public void processTopoInfoFromRS(TopologyMsg topoMsg) argument
670 List<RSInfo> rsInfos = topoMsg.getRsList();
680 List<DSInfo> dsInfos = topoMsg.getDsList();
847 * @param topoMsg The message received.
851 public void receiveTopoInfoFromRS(TopologyMsg topoMsg) argument
855 replicationServerDomain.receiveTopoInfoFromRS(topoMsg, this, true);
H A DServerReader.java216 TopologyMsg topoMsg = (TopologyMsg) msg;
218 rsh.receiveTopoInfoFromRS(topoMsg);
H A DReplicationServerDomain.java2437 * @param topoMsg The just received topo message from remote RS
2444 public void receiveTopoInfoFromRS(TopologyMsg topoMsg, argument
2454 " for baseDn " + baseDn + ":\n" + topoMsg);
2476 handler.processTopoInfoFromRS(topoMsg);
3503 final TopologyMsg topoMsg =
3505 sendTopologyMsg("directory", handler, topoMsg);
3512 final TopologyMsg topoMsg = createTopologyMsgForRS();
3515 sendTopologyMsg("replication", handler, topoMsg);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java665 * @param topoMsg The received topology message
667 public void processTopoInfoFromRS(TopologyMsg topoMsg) argument
670 List<RSInfo> rsInfos = topoMsg.getRsList();
680 List<DSInfo> dsInfos = topoMsg.getDsList();
847 * @param topoMsg The message received.
851 public void receiveTopoInfoFromRS(TopologyMsg topoMsg) argument
855 replicationServerDomain.receiveTopoInfoFromRS(topoMsg, this, true);
H A DServerReader.java225 TopologyMsg topoMsg = (TopologyMsg) msg;
227 rsh.receiveTopoInfoFromRS(topoMsg);
H A DReplicationServerDomain.java1880 TopologyMsg topoMsg=createTopologyMsgForDS(handler.getServerId());
1883 handler.sendTopoInfo(topoMsg);
1912 TopologyMsg topoMsg = createTopologyMsgForRS();
1923 handler.sendTopoInfo(topoMsg);
2412 * @param topoMsg The just received topo message from remote RS
2419 public void receiveTopoInfoFromRS(TopologyMsg topoMsg, argument
2429 " for baseDn " + baseDn + ":\n" + topoMsg);
2451 handler.processTopoInfoFromRS(topoMsg);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java601 * @param topoMsg The received topology message
603 public void processTopoInfoFromRS(TopologyMsg topoMsg) argument
606 final RSInfo rsInfo = topoMsg.getRsInfos().get(0);
616 for (DSInfo dsInfo : topoMsg.getReplicaInfos().values())
752 * @param topoMsg The message received.
756 public void receiveTopoInfoFromRS(TopologyMsg topoMsg) argument
759 replicationServerDomain.receiveTopoInfoFromRS(topoMsg, this, true);
H A DReplicationServerDomain.java2119 * @param topoMsg The just received topo message from remote RS
2126 public void receiveTopoInfoFromRS(TopologyMsg topoMsg, argument
2133 + ":\n" + topoMsg);
2153 rsHandler.processTopoInfoFromRS(topoMsg);
2705 final TopologyMsg topoMsg = createTopologyMsgForDS(handler
2707 sendTopologyMsg("directory", handler, topoMsg);
2714 final TopologyMsg topoMsg = createTopologyMsgForRS();
2717 sendTopologyMsg("replication", handler, topoMsg);
H A DServerHandler.java882 * @param topoMsg
887 public void sendTopoInfo(TopologyMsg topoMsg) throws IOException argument
892 send(topoMsg);
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java2492 final TopologyMsg topoMsg = (TopologyMsg) msg;
2493 receiveTopo(topoMsg, getRsServerId());
2922 * @param topoMsg
2927 private void receiveTopo(TopologyMsg topoMsg, int rsServerId) argument
2929 final Topology newTopo = computeNewTopology(topoMsg, rsServerId);
2937 private Topology computeNewTopology(TopologyMsg topoMsg, int rsServerId) argument
2944 newTopo = new Topology(topoMsg, getServerId(), rsServerId,
2952 sb.append(" received TopologyMsg=").append(topoMsg);
3021 * @param topoMsg
3033 Topology(TopologyMsg topoMsg, in argument
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java2492 final TopologyMsg topoMsg = (TopologyMsg) msg;
2493 receiveTopo(topoMsg, getRsServerId());
2922 * @param topoMsg
2927 private void receiveTopo(TopologyMsg topoMsg, int rsServerId) argument
2929 final Topology newTopo = computeNewTopology(topoMsg, rsServerId);
2937 private Topology computeNewTopology(TopologyMsg topoMsg, int rsServerId) argument
2944 newTopo = new Topology(topoMsg, getServerId(), rsServerId,
2952 sb.append(" received TopologyMsg=").append(topoMsg);
3021 * @param topoMsg
3033 Topology(TopologyMsg topoMsg, in argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java2466 final TopologyMsg topoMsg = (TopologyMsg) msg;
2467 receiveTopo(topoMsg, getRsServerId());
2887 * @param topoMsg
2892 private void receiveTopo(TopologyMsg topoMsg, int rsServerId) argument
2894 final Topology newTopo = computeNewTopology(topoMsg, rsServerId);
2902 private Topology computeNewTopology(TopologyMsg topoMsg, int rsServerId) argument
2909 newTopo = new Topology(topoMsg, getServerId(), rsServerId,
2917 sb.append(" received TopologyMsg=").append(topoMsg);
2986 * @param topoMsg
2998 Topology(TopologyMsg topoMsg, in argument
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java2493 TopologyMsg topoMsg = (TopologyMsg) msg;
2494 receiveTopo(topoMsg);
2977 * @param topoMsg The topology information received from RS.
2979 public void receiveTopo(TopologyMsg topoMsg) argument
2982 TRACER.debugInfo(this + " receive TopologyMsg=" + topoMsg);
2985 dsList = topoMsg.getDsList();
2990 for (RSInfo rsInfo : topoMsg.getRsList())
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java2751 TopologyMsg topoMsg = (TopologyMsg) msg;
2752 receiveTopo(topoMsg);
3237 * @param topoMsg The topology information received from RS.
3239 public void receiveTopo(TopologyMsg topoMsg) argument
3242 debugInfo("receive TopologyMsg=" + topoMsg);
3245 dsList = topoMsg.getDsList();
3250 for (RSInfo rsInfo : topoMsg.getRsList())
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java2493 TopologyMsg topoMsg = (TopologyMsg) msg;
2494 receiveTopo(topoMsg);
2977 * @param topoMsg The topology information received from RS.
2979 public void receiveTopo(TopologyMsg topoMsg) argument
2982 TRACER.debugInfo(this + " receive TopologyMsg=" + topoMsg);
2985 dsList = topoMsg.getDsList();
2990 for (RSInfo rsInfo : topoMsg.getRsList())

Completed in 169 milliseconds

12