Searched defs:topologyMsg (Results 1 - 6 of 6) sorted by relevance
| /forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 963 TopologyMsg topologyMsg = performPhaseTwoHandshake(
966 if (topologyMsg != null) // Handshake phase 2 exchange went well
968 connectToReplicationServer(electedRsInfo, initStatus, topologyMsg);
1039 * @param topologyMsg
1043 ServerStatus initStatus, TopologyMsg topologyMsg)
1053 receiveTopo(topologyMsg);
1400 TopologyMsg topologyMsg = null;
1411 topologyMsg = (TopologyMsg) session.receive();
1432 topologyMsg = null;
1434 return topologyMsg;
1042 connectToReplicationServer(ReplicationServerInfo rsInfo, ServerStatus initStatus, TopologyMsg topologyMsg) argument
[all...] |
| /forgerock/opendj2/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 819 final TopologyMsg topologyMsg =
822 if (topologyMsg != null) // Handshake phase 2 exchange went well
824 connectToReplicationServer(electedRS, initStatus, topologyMsg);
919 * @param topologyMsg
923 ServerStatus initStatus, TopologyMsg topologyMsg)
933 receiveTopo(topologyMsg, rs.getServerId());
1225 final TopologyMsg topologyMsg = (TopologyMsg) session.receive();
1230 + "\nAND RECEIVED:\n" + topologyMsg);
1236 return topologyMsg;
922 connectToReplicationServer(ConnectedRS rs, ServerStatus initStatus, TopologyMsg topologyMsg) argument
|
| /forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 962 TopologyMsg topologyMsg = performPhaseTwoHandshake(
965 if (topologyMsg != null) // Handshake phase 2 exchange went well
967 connectToReplicationServer(electedRsInfo, initStatus, topologyMsg);
1038 * @param topologyMsg
1042 ServerStatus initStatus, TopologyMsg topologyMsg)
1052 receiveTopo(topologyMsg);
1401 TopologyMsg topologyMsg = null;
1412 topologyMsg = (TopologyMsg) session.receive();
1432 topologyMsg = null;
1434 return topologyMsg;
1041 connectToReplicationServer(ReplicationServerInfo rsInfo, ServerStatus initStatus, TopologyMsg topologyMsg) argument
[all...] |
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 963 TopologyMsg topologyMsg = performPhaseTwoHandshake(
966 if (topologyMsg != null) // Handshake phase 2 exchange went well
968 connectToReplicationServer(electedRsInfo, initStatus, topologyMsg);
1039 * @param topologyMsg
1043 ServerStatus initStatus, TopologyMsg topologyMsg)
1053 receiveTopo(topologyMsg);
1400 TopologyMsg topologyMsg = null;
1411 topologyMsg = (TopologyMsg) session.receive();
1432 topologyMsg = null;
1434 return topologyMsg;
1042 connectToReplicationServer(ReplicationServerInfo rsInfo, ServerStatus initStatus, TopologyMsg topologyMsg) argument
[all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 819 final TopologyMsg topologyMsg =
822 if (topologyMsg != null) // Handshake phase 2 exchange went well
824 connectToReplicationServer(electedRS, initStatus, topologyMsg);
919 * @param topologyMsg
923 ServerStatus initStatus, TopologyMsg topologyMsg)
933 receiveTopo(topologyMsg, rs.getServerId());
1225 final TopologyMsg topologyMsg = (TopologyMsg) session.receive();
1230 + "\nAND RECEIVED:\n" + topologyMsg);
1236 return topologyMsg;
922 connectToReplicationServer(ConnectedRS rs, ServerStatus initStatus, TopologyMsg topologyMsg) argument
|
| /forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
| H A D | ReplicationBroker.java | 811 final TopologyMsg topologyMsg =
814 if (topologyMsg != null) // Handshake phase 2 exchange went well
816 connectToReplicationServer(electedRS, initStatus, topologyMsg);
907 * @param topologyMsg
911 ServerStatus initStatus, TopologyMsg topologyMsg)
921 receiveTopo(topologyMsg, rs.getServerId());
1206 final TopologyMsg topologyMsg = (TopologyMsg) session.receive();
1211 + "\nAND RECEIVED:\n" + topologyMsg);
1217 return topologyMsg;
910 connectToReplicationServer(ConnectedRS rs, ServerStatus initStatus, TopologyMsg topologyMsg) argument
|
Completed in 50 milliseconds