| | |
| | | } |
| | | |
| | | /** |
| | | * Stop operations with a list of servers. |
| | | * Stop operations with a list of replication servers. |
| | | * |
| | | * @param replServers the replication servers for which |
| | | * we want to stop operations |
| | | */ |
| | | public void stopServers(Collection<String> replServers) |
| | | public void stopReplicationServers(Collection<String> replServers) |
| | | { |
| | | for (ServerHandler handler : replicationServers.values()) |
| | | { |
| | |
| | | } |
| | | |
| | | /** |
| | | * Stop operations with all servers this domain is connected with (RS and DS). |
| | | */ |
| | | public void stopAllServers() |
| | | { |
| | | // Close session with other replication servers |
| | | for (ServerHandler serverHandler : replicationServers.values()) |
| | | { |
| | | stopServer(serverHandler); |
| | | } |
| | | |
| | | // Close session with other LDAP servers |
| | | for (ServerHandler serverHandler : directoryServers.values()) |
| | | { |
| | | stopServer(serverHandler); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * Checks that a DS is not connected with same id. |
| | | * |
| | | * @param handler the DS we want to check |
| | |
| | | // Terminate the assured timer |
| | | assuredTimeoutTimer.cancel(); |
| | | |
| | | // Close session with other changelogs |
| | | for (ServerHandler serverHandler : replicationServers.values()) |
| | | { |
| | | stopServer(serverHandler); |
| | | } |
| | | |
| | | // Close session with other LDAP servers |
| | | for (ServerHandler serverHandler : directoryServers.values()) |
| | | { |
| | | stopServer(serverHandler); |
| | | } |
| | | stopAllServers(); |
| | | |
| | | // Shutdown the dbHandlers |
| | | synchronized (sourceDbHandlers) |