private String message = StringUtil.EMPTY;

    public PingResponse(final ClusterHealthResponse response) {
        status = response.getStatus() == ClusterHealthStatus.RED ? 1 : 0;
        clusterName = response.getClusterName();
        clusterStatus = response.getStatus().toString();
        final Set<String> fieldSet = ComponentUtil.getFessConfig().getApiPingEsFieldSet();

            doClose();
        }
        return n;
    }


    /**
     * @throws SmbException
     */
    private void checkStatus () throws SmbException {
        int status = this.response.getStatus();
        if ( status == WinError.ERROR_SERVICE_NOT_INSTALLED ) {
            throw new SmbUnsupportedOperationException();
        }
        if ( status != WinError.ERROR_SUCCESS && status != WinError.ERROR_MORE_DATA ) {

    }


    /**
     * {@inheritDoc}
     *
     * @see jcifs.util.transport.Response#received()
     */
    @Override
    public final void received () {
        if ( isAsync() && getStatus() == NtStatus.NT_STATUS_PENDING ) {
            synchronized ( this ) {
                notifyAll();
            }
            return;
        }
        this.received = true;
        synchronized ( this ) {

        final StringBuilder resultBuf = new StringBuilder();

        final PingResponse ping = searchEngineClient.ping();
        final int status = ping.getStatus();
        if (systemHelper.isChangedClusterState(status)) {
            if (fessConfig.hasNotification()) {
                final String toStrs = fessConfig.getNotificationTo();
                final String[] toAddresses;

        try {
            createResp = th.send(create);
        }
        catch ( SmbException e ) {
            Smb2CreateResponse cr = create.getResponse();
            if ( cr != null && cr.isReceived() && cr.getStatus() == NtStatus.NT_STATUS_OK ) {
                try {
                    th.send(new Smb2CloseRequest(th.getConfig(), cr.getFileId()));
                }
                catch ( SmbException e2 ) {

            TransPeekNamedPipeResponse resp = new TransPeekNamedPipeResponse(th.getConfig());
            th.send(req, resp, RequestParam.NO_RETRY);
            if ( resp.getStatus() == TransPeekNamedPipeResponse.STATUS_DISCONNECTED
                    || resp.getStatus() == TransPeekNamedPipeResponse.STATUS_SERVER_END_CLOSED ) {
                fd.markClosed();
                return 0;
            }
            return resp.getAvailable();

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.smb2.ServerMessageBlock2#isErrorResponseStatus()
     */
    @Override
    protected boolean isErrorResponseStatus () {
        return getStatus() != NtStatus.NT_STATUS_NOTIFY_ENUM_DIR && super.isErrorResponseStatus();
    }

        return bufferIndex - start;
    }


    @Override
    public String toString () {
        return new String(
            "NetShareEnumResponse[" + super.toString() + ",status=" + getStatus() + ",converter=" + this.converter + ",entriesReturned="
                    + getNumEntries() + ",totalAvailableEntries=" + this.totalAvailableEntries + "]");
    }

     */
    public final void setSubCommand ( byte subCommand ) {
        this.subCommand = subCommand;
    }


    /**
     * @return the status
     */
    public final int getStatus () {
        return this.status;
    }


    /**
     * @param status
     *            the status to set
     */
    protected final void setStatus ( int status ) {

        this.response.reset();
        try {
            getTreeHandle().send(this.nextRequest, this.response);
            return this.response.getStatus() != NtStatus.NT_STATUS_NO_MORE_FILES;
        }
        catch ( SmbException e ) {
            if ( e.getNtStatus() == NtStatus.NT_STATUS_NO_MORE_FILES ) {
                log.debug("No more entries", e);