| | |
| | | requested servers. Log problem |
| | | */ |
| | | logger.error(NOTE_DS_RECEIVED_ACK_ERROR.get( |
| | | getBaseDNString(), Integer.toString(getServerId()), |
| | | update.toString(), ack.errorsToString())); |
| | | getBaseDN(), getServerId(), update, ack.errorsToString())); |
| | | |
| | | List<Integer> failedServers = ack.getFailedServers(); |
| | | |
| | |
| | | throw new DirectoryException( |
| | | ResultCode.OTHER, |
| | | ERR_INIT_NO_SUCCESS_START_FROM_SERVERS.get( |
| | | ieCtx.failureList.toString())); |
| | | ieCtx.failureList)); |
| | | } |
| | | |
| | | exportBackend(new BufferedOutputStream(new ReplOutputStream(this))); |
| | |
| | | exportRootException = new DirectoryException(ResultCode.OTHER, |
| | | ERR_INIT_NO_SUCCESS_END_FROM_SERVERS.get( |
| | | Long.toString(getGenerationID()), |
| | | ieCtx.failureList.toString())); |
| | | ieCtx.failureList)); |
| | | } |
| | | |
| | | // Don't forget to release IEcontext acquired at beginning. |
| | |
| | | if (newStatus == ServerStatus.INVALID_STATUS) |
| | | { |
| | | logger.error(ERR_DS_CANNOT_CHANGE_STATUS.get(getBaseDNString(), |
| | | String.valueOf(getServerId()), status.toString(), event.toString())); |
| | | String.valueOf(getServerId()), status, event)); |
| | | return; |
| | | } |
| | | |
| | |
| | | else if (getAssuredMode() != AssuredMode.SAFE_DATA_MODE) |
| | | { |
| | | logger.error(ERR_DS_UNKNOWN_ASSURED_MODE.get(String.valueOf(getServerId()), |
| | | msg.getAssuredMode().toString(), getBaseDNString(), |
| | | msg.toString())); |
| | | msg.getAssuredMode(), getBaseDNString(), |
| | | msg)); |
| | | } |
| | | // Nothing to do in Assured safe data mode, only RS ack updates. |
| | | } |
| | |
| | | { |
| | | // This exception may only be raised if assured replication is enabled |
| | | logger.error(NOTE_DS_ACK_TIMEOUT.get(getBaseDNString(), |
| | | Long.toString(getAssuredTimeout()), update.toString())); |
| | | Long.toString(getAssuredTimeout()), update)); |
| | | } |
| | | } |
| | | |