| | |
| | | |
| | | logTopoHandshakeSNDandRCV(outTopoMsg, inTopoMsg); |
| | | |
| | | replicationServerDomain.startMonitoringPublisher(); |
| | | |
| | | /* |
| | | FIXME: i think this should be done for all protocol version !! |
| | | not only those > V1 |
| | | */ |
| | | registerIntoDomain(); |
| | | replicationServerDomain.register(this); |
| | | |
| | | /* |
| | | Process TopologyMsg sent by remote RS: store matching new info |
| | |
| | | */ |
| | | } |
| | | |
| | | replicationServerDomain.startMonitoringPublisher(); |
| | | |
| | | registerIntoDomain(); |
| | | replicationServerDomain.register(this); |
| | | |
| | | // Process TopologyMsg sent by remote RS: store matching new info |
| | | // (this will also warn our connected DSs of the new received info) |
| | |
| | | } |
| | | |
| | | /** |
| | | * Registers this handler into its related domain and notifies the domain. |
| | | */ |
| | | private void registerIntoDomain() |
| | | { |
| | | // Alright, connected with new RS (either outgoing or incoming |
| | | // connection): store handler. |
| | | Map<Integer, ReplicationServerHandler> connectedRSs = |
| | | replicationServerDomain.getConnectedRSs(); |
| | | connectedRSs.put(serverId, this); |
| | | } |
| | | |
| | | /** |
| | | * Wait receiving the TopologyMsg from the remote RS and process it. |
| | | * @return the topologyMsg received or {@code null} if stop was received. |
| | | * @throws DirectoryException |