| | |
| | | import org.opends.server.replication.common.StatusMachine; |
| | | import org.opends.server.replication.common.StatusMachineEvent; |
| | | import org.opends.server.replication.protocol.ChangeStatusMsg; |
| | | import org.opends.server.replication.protocol.PacketTooLargeException; |
| | | import org.opends.server.replication.protocol.ProtocolVersion; |
| | | import org.opends.server.replication.protocol.ReplServerStartDSMsg; |
| | | import org.opends.server.replication.protocol.ReplicationMsg; |
| | |
| | | |
| | | logStartSessionHandshake(inStartSessionMsg, outTopoMsg); |
| | | } |
| | | catch (PacketTooLargeException e) |
| | | { |
| | | // Not the peer going away, see PacketTooLargeException. |
| | | logger.traceException(e); |
| | | abortStart(LocalizableMessage.raw( |
| | | e.getLocalizedMessage() + " Peer: " + session.getReadableRemoteAddress())); |
| | | return; |
| | | } |
| | | catch(IOException e) |
| | | { |
| | | LocalizableMessage errMessage = ERR_DS_DISCONNECTED_DURING_HANDSHAKE.get( |
| | | inServerStartMsg.getServerId(), replicationServer.getServerId()); |
| | | throw new DirectoryException(ResultCode.OTHER, errMessage); |
| | | abortStartWithWarning(WARN_DS_DISCONNECTED_DURING_HANDSHAKE.get( |
| | | inServerStartMsg.getServerId(), replicationServer.getServerId())); |
| | | return; |
| | | } |
| | | catch (Exception e) |
| | | { |