assertTrue(testMessage.getLength() > 0);
        }

        @Test
        @DisplayName("Should get status")
        void testGetStatus() {
            assertEquals(0, testMessage.getStatus());
        }

        @Test
        @DisplayName("Should get next command offset")
        void testGetNextCommandOffset() {
            assertEquals(0, testMessage.getNextCommandOffset());
        }

                    handleManager.completeReconnect(info.path, true);
                    return file;
                } else {
                    throw new IOException("Reconnect failed: " + response.getStatus());
                }
                
            } catch (Exception e) {
                log.debug("Reconnect attempt {} failed: {}", attempt + 1, e.getMessage());
                
                // Retry

            channel.getTransport().send(request);
        
        if (!response.isSuccess()) {
            throw new IOException("Channel binding failed: " + response.getStatus());
        }
    }
    
    private byte[] calculateBindingInfo(ChannelInfo channel) {
        // Combine session key with channel-specific data
        ByteArrayOutputStream baos = new ByteArrayOutputStream();

        return getConfig().equals(tc.getConfig());
    }

    @Override
    public boolean isValid(final CIFSContext tc, final SmbNegotiationRequest req) {
        if (!isReceived() || getStatus() != 0) {
            return false;
        }

        if (req.isSigningEnforced() && !isSigningEnabled()) {
            log.debug("Signing is enforced but server does not allow it");
            return false;

     *
     * @return the cluster health status name
     */
    public String getStatus() {
        return admin().cluster()
                .prepareHealth()
                .execute()
                .actionGet(ComponentUtil.getFessConfig().getIndexHealthTimeout())
                .getStatus()
                .name();
    }

    /**
     * Sets the OpenSearch runner for embedded mode.

        final ServerMessageBlock2Response resp = (ServerMessageBlock2Response) response;
        synchronized (resp) {
            if (resp.isAsync() && !resp.isAsyncHandled() && resp.getStatus() == NtStatus.NT_STATUS_PENDING && resp.getAsyncId() != 0) {
                resp.setAsyncHandled(true);
                final boolean first = !req.isAsync();
                req.setAsyncId(resp.getAsyncId());

                // make sure that the handle is closed when one of the requests fails
                final Smb2CreateResponse createResp = cr.getResponse();
                if (createResp.isReceived() && createResp.getStatus() == NtStatus.NT_STATUS_SUCCESS) {
                    th.send(new Smb2CloseRequest(th.getConfig(), createResp.getFileId()), RequestParam.NO_RETRY);
                }
            } catch (final Exception e2) {