| | |
| | | return newStatus; |
| | | } |
| | | |
| | | private void createStatusAnalyzer() |
| | | { |
| | | if (!replicationServerDomain.isRunningStatusAnalyzer()) |
| | | { |
| | | replicationServerDomain.startStatusAnalyzer(); |
| | | } |
| | | } |
| | | |
| | | /** |
| | | * Retrieves a set of attributes containing monitor data that should be |
| | | * returned to the client if the corresponding monitor entry is requested. |
| | |
| | | localGenerationId = replicationServerDomain.getGenerationId(); |
| | | oldGenerationId = localGenerationId; |
| | | |
| | | // Duplicate server ? |
| | | if (!replicationServerDomain.checkForDuplicateDS(this)) |
| | | if (replicationServerDomain.isAlreadyConnectedToDS(this)) |
| | | { |
| | | abortStart(null); |
| | | return; |
| | |
| | | { |
| | | StartMsg outStartMsg = sendStartToRemote(); |
| | | |
| | | // log |
| | | logStartHandshakeRCVandSND(inServerStartMsg, outStartMsg); |
| | | |
| | | // The session initiator decides whether to use SSL. |
| | |
| | | throw new DirectoryException(ResultCode.OTHER, null, null); |
| | | } |
| | | |
| | | // Create the status analyzer for the domain if not already started |
| | | createStatusAnalyzer(); |
| | | |
| | | // Create the monitoring publisher for the domain if not already started |
| | | createMonitoringPublisher(); |
| | | replicationServerDomain.startStatusAnalyzer(); |
| | | replicationServerDomain.startMonitoringPublisher(); |
| | | |
| | | registerIntoDomain(); |
| | | |