CrawlingParameterUtil.setUrlQueueService(urlQueueService);
        CrawlingParameterUtil.setDataService(dataService);
        try {
            while (crawlerContext.getStatus() != CrawlerStatus.DONE && isContinue(threadCheckCount)) {
                final UrlQueue<?> urlQueue = urlQueueService.poll(crawlerContext.sessionId);
                if (isValid(urlQueue)) {

            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());
        }

            engineObj.numberOfPendingTasks = response.getNumberOfPendingTasks();
            engineObj.numberOfInFlightFetch = response.getNumberOfInFlightFetch();
            engineObj.status = response.getStatus().name().toLowerCase(Locale.ROOT);
        } catch (final Exception e) {
            engineObj.status = "red";
            engineObj.exception = e.getMessage();
        }
        return engineObj;
    }

        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;

        
        RdmaNegotiateResponse response = rdmaConnection.negotiate(request);
        
        if (!response.isSuccess()) {
            throw new IOException("RDMA negotiation failed: " + response.getStatus());
        }
        
        // Update connection parameters based on negotiation
        credits.setCreditsGranted(response.getCreditsGranted());

                    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

        final SearchEngineClient searchEngineClient = ComponentUtil.getSearchEngineClient();
        try {
            final PingResponse pingResponse = searchEngineClient.ping();
            writeJsonResponse(pingResponse.getStatus() == 0 ? HttpServletResponse.SC_OK : HttpServletResponse.SC_SERVICE_UNAVAILABLE,
                    "\"data\":" + pingResponse.getMessage());
        } catch (final Exception e) {
            if (logger.isDebugEnabled()) {

     *
     * @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.

            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();

            DistributionManagement source,
            boolean sourceDominant,
            Map<Object, Object> context) {
        String src = source.getStatus();
        if (src != null) {
            if (sourceDominant || target.getStatus() == null) {
                target.setStatus(src);
                target.setLocation("status", source.getLocation("status"));
            }
        }
    }