| | |
| | | */ |
| | | public class DataServerHandler extends ServerHandler |
| | | { |
| | | // Temporay generationId received in handshake/phase1, |
| | | // and used after handshake/phase2 |
| | | long tmpGenerationId; |
| | | |
| | | // Status of this DS (only used if this server handler represents a DS) |
| | | private ServerStatus status = ServerStatus.INVALID_STATUS; |
| | | |
| | |
| | | public boolean processStartFromRemote(ServerStartMsg serverStartMsg) |
| | | throws DirectoryException |
| | | { |
| | | generationId = serverStartMsg.getGenerationId(); |
| | | tmpGenerationId = serverStartMsg.getGenerationId(); |
| | | protocolVersion = ProtocolVersion.minWithCurrent( |
| | | serverStartMsg.getVersion()); |
| | | serverId = serverStartMsg.getServerId(); |
| | |
| | | boolean sessionInitiatorSSLEncryption = |
| | | processStartFromRemote(inServerStartMsg); |
| | | |
| | | // lock with no timeout |
| | | lockDomain(false); |
| | | |
| | | localGenerationId = replicationServerDomain.getGenerationId(); |
| | | oldGenerationId = localGenerationId; |
| | | |
| | |
| | | return; |
| | | } |
| | | |
| | | // lock with no timeout |
| | | lockDomain(false); |
| | | |
| | | // |
| | | ReplServerStartMsg outReplServerStartMsg = null; |
| | | try |
| | |
| | | * (unsaved yet on disk . will be set with the 1rst change |
| | | * received) |
| | | */ |
| | | generationId = tmpGenerationId; |
| | | if (localGenerationId > 0) |
| | | { |
| | | if (generationId != localGenerationId) |