/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerHandler.java | 665 * @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 D | ReplicationServerDomain.java | 1880 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 D | ServerHandler.java | 971 * @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 D | ReplicationServerHandler.java | 601 * @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 D | ServerHandler.java | 882 * @param topoMsg 887 public void sendTopoInfo(TopologyMsg topoMsg) throws IOException argument 892 send(topoMsg);
|
H A D | ReplicationServerDomain.java | 2119 * @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);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerHandler.java | 665 * @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 D | ServerHandler.java | 997 * @param topoMsg 1002 public void sendTopoInfo(TopologyMsg topoMsg) throws IOException argument 1007 send(topoMsg);
|
H A D | ReplicationServerDomain.java | 2437 * @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 D | ReplicationServerHandler.java | 665 * @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 D | ReplicationServerDomain.java | 1880 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 D | ServerHandler.java | 971 * @param topoMsg 976 public void sendTopoInfo(TopologyMsg topoMsg) throws IOException argument 981 send(topoMsg);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServerHandler.java | 601 * @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 D | ServerHandler.java | 882 * @param topoMsg 887 public void sendTopoInfo(TopologyMsg topoMsg) throws IOException argument 892 send(topoMsg);
|
H A D | ReplicationServerDomain.java | 2119 * @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);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ReplicationServerHandler.java | 575 * @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 D | ServerHandler.java | 845 * @param topoMsg 850 public void sendTopoInfo(TopologyMsg topoMsg) throws IOException argument 855 send(topoMsg);
|
H A D | ReplicationServerDomain.java | 2056 * @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);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 2493 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/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 2492 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.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 2751 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 D | ReplicationBroker.java | 2493 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-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 2492 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 D | ReplicationBroker.java | 2466 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...] |