| | |
| | | |
| | | import static org.opends.messages.ToolMessages.*; |
| | | import static org.opends.server.config.ConfigConstants.*; |
| | | import static org.opends.server.types.ResultCode.*; |
| | | import static org.forgerock.opendj.ldap.ResultCode.*; |
| | | |
| | | import java.io.IOException; |
| | | import java.text.SimpleDateFormat; |
| | |
| | | LDAPMessage responseMessage = reader.readMessage(); |
| | | if (responseMessage == null) { |
| | | LocalizableMessage message = ERR_TASK_CLIENT_UNEXPECTED_CONNECTION_CLOSURE.get(); |
| | | throw new LDAPException(UNAVAILABLE.getIntValue(), message); |
| | | throw new LDAPException(UNAVAILABLE.intValue(), message); |
| | | } else { |
| | | opType = responseMessage.getProtocolOpType(); |
| | | if (opType == LDAPConstants.OP_TYPE_SEARCH_RESULT_ENTRY) { |
| | |
| | | |
| | | if (responseMessage == null) { |
| | | LocalizableMessage message = ERR_TASK_CLIENT_UNEXPECTED_CONNECTION_CLOSURE.get(); |
| | | throw new LDAPException(UNAVAILABLE.getIntValue(), message); |
| | | throw new LDAPException(UNAVAILABLE.intValue(), message); |
| | | } |
| | | |
| | | if (responseMessage.getProtocolOpType() != |
| | |
| | | |
| | | if (responseMessage == null) { |
| | | LocalizableMessage message = ERR_TASK_CLIENT_UNEXPECTED_CONNECTION_CLOSURE.get(); |
| | | throw new LDAPException(UNAVAILABLE.getIntValue(), message); |
| | | throw new LDAPException(UNAVAILABLE.intValue(), message); |
| | | } |
| | | |
| | | if (responseMessage.getProtocolOpType() != |