| | |
| | | long referenceGenerationId = handler.getReferenceGenId(); |
| | | if (dsStatus == BAD_GEN_ID_STATUS) |
| | | logger.warn(WARN_IGNORING_UPDATE_FROM_DS_BADGENID.get(handler.getReplicationServerId(), |
| | | updateMsg.getCSN().toString(), |
| | | handler.getBaseDNString(), handler.getServerId(), |
| | | updateMsg.getCSN(), handler.getBaseDN(), handler.getServerId(), |
| | | session.getReadableRemoteAddress(), |
| | | handler.getGenerationId(), |
| | | referenceGenerationId)); |
| | | if (dsStatus == FULL_UPDATE_STATUS) |
| | | logger.warn(WARN_IGNORING_UPDATE_FROM_DS_FULLUP.get(handler.getReplicationServerId(), |
| | | updateMsg.getCSN().toString(), |
| | | handler.getBaseDNString(), handler.getServerId(), |
| | | updateMsg.getCSN(), handler.getBaseDN(), handler.getServerId(), |
| | | session.getReadableRemoteAddress())); |
| | | filtered = true; |
| | | } |
| | |
| | | logger.error( |
| | | WARN_IGNORING_UPDATE_FROM_RS.get( |
| | | handler.getReplicationServerId(), |
| | | updateMsg.getCSN().toString(), |
| | | handler.getBaseDNString(), |
| | | handler.getServerId(), |
| | | updateMsg.getCSN(), handler.getBaseDN(), handler.getServerId(), |
| | | session.getReadableRemoteAddress(), |
| | | handler.getGenerationId(), |
| | | referenceGenerationId)); |
| | |
| | | } |
| | | catch(Exception e) |
| | | { |
| | | errMessage = |
| | | ERR_RECEIVED_CHANGE_STATUS_NOT_FROM_DS.get( |
| | | handler.getBaseDNString(), |
| | | Integer.toString(handler.getServerId()), |
| | | csMsg.toString()); |
| | | errMessage = ERR_RECEIVED_CHANGE_STATUS_NOT_FROM_DS.get( |
| | | handler.getBaseDN(), handler.getServerId(), csMsg); |
| | | logger.error(errMessage); |
| | | } |
| | | } else if (msg instanceof ChangeTimeHeartbeatMsg) |
| | |
| | | * The remote server has sent an unknown message, |
| | | * close the connection. |
| | | */ |
| | | errMessage = NOTE_READER_EXCEPTION.get( |
| | | handler.toString(), stackTraceToSingleLineString(e)); |
| | | errMessage = NOTE_READER_EXCEPTION.get(handler, stackTraceToSingleLineString(e)); |
| | | logger.error(errMessage); |
| | | } |
| | | finally |