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

	public final fun getPushPromises ()Ljava/util/List;
	public final fun getSettings ()Lokhttp3/internal/http2/Settings;
	public final fun getSocketPolicy ()Lokhttp3/mockwebserver/SocketPolicy;
	public final fun getStatus ()Ljava/lang/String;
	public final fun getThrottleBytesPerPeriod ()J
	public final fun getThrottlePeriod (Ljava/util/concurrent/TimeUnit;)J
	public final fun getTrailers ()Lokhttp3/Headers;

                            final Smb2IoctlResponse response = copy.getResponse();
                            if (!retry && response.isReceived() && !response.isError()
                                    && response.getStatus() == NtStatus.NT_STATUS_INVALID_PARAMETER) {
                                retry = true;
                                final SrvCopyChunkCopyResponse outputData = response.getOutputData(SrvCopyChunkCopyResponse.class);

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

        setupEpg(_epgMap, et -> ((User) et).getRoomNumber(), (et, vl) -> ((User) et).setRoomNumber(DfTypeUtil.toString(vl)), "roomNumber");
        setupEpg(_epgMap, et -> ((User) et).getState(), (et, vl) -> ((User) et).setState(DfTypeUtil.toString(vl)), "state");
        setupEpg(_epgMap, et -> ((User) et).getStreet(), (et, vl) -> ((User) et).setStreet(DfTypeUtil.toString(vl)), "street");

                    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

            return "http://test.example.com";
        }

        @Override
        public String getParentUrl() {
            return null;
        }

        @Override
        public Integer getStatus() {
            return 200;
        }

        @Override
        public Integer getHttpStatusCode() {
            return 200;
        }

        @Override
        public String getMethod() {

        return convertEmptyToNull(roomNumber);
    }

    public void setRoomNumber(String value) {
        registerModifiedProperty("roomNumber");
        this.roomNumber = value;
    }

    public String getState() {
        checkSpecifiedProperty("state");
        return convertEmptyToNull(state);
    }

    public void setState(String value) {
        registerModifiedProperty("state");
        this.state = value;

        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.