valueAndCloser.closeAsync();
    }
    super.waitUntilClosed(closingFuture);
  }

  @Override
  void cancelFinalStepAndWait(ClosingFuture<TestCloseable> closingFuture) {
    assertThat(closingFuture.cancel(false)).isTrue();
    ValueAndCloser<?> unused = finishToValueAndCloser(closingFuture);
    waitUntilClosed(closingFuture);
    futureCancelled.countDown();
  }

		Path:   pathJoin(healthCheckPathPrefix, healthCheckLivenessPath),
	}

	httpClient := &http.Client{
		Transport: globalInternodeTransport,
	}

	ctx, cancel := context.WithTimeout(GlobalContext, timeout)
	defer cancel()

	req, err := http.NewRequestWithContext(ctx, http.MethodGet, serverURL.String(), nil)
	if err != nil {
		return err
	}
	// Indicate that the liveness check for a peer call

                        accessTimeoutTarget.stop();
                        if (accessTimeoutTask != null && !accessTimeoutTask.isCanceled()) {
                            accessTimeoutTask.cancel();
                        }
                    }
                }
            }

            @Override
            protected ResponseData getResponseData(final String uri, final boolean includeContent) {

	if err != nil {
		// invalid worker size.
		return err
	}

	ctx, cancel := context.WithCancel(ctx)

	results := make(chan itemOrErr[ObjectInfo], 100)
	if err := api.Walk(ctx, r.Bucket, r.Prefix, results, WalkOptions{
		Marker: lastObject,
		Filter: selectObj,
	}); err != nil {
		cancel()
		// Do not need to retry if we can't list objects on source.
		return err
	}
	failed := false

	if _, ok := tx.ConnPool.(*gorm.PreparedStmtDB); !ok {
		t.Fatalf("should assign PreparedStatement Manager back to database when using PrepareStmt mode")
	}

	ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)
	defer cancel()
	txCtx := tx.WithContext(ctx)

	user := *GetUser("prepared_stmt", Config{})

	txCtx.Create(&user)

	var result1 User

    */
    int NTLMSSP_REQUEST_TARGET = 0x00000004;

    /**
    * Specifies that communication across the authenticated channel
    * should carry a digital signature (message integrity).
    */
    int NTLMSSP_NEGOTIATE_SIGN = 0x00000010;

    /**
    * Specifies that communication across the authenticated channel
    * should be encrypted (message confidentiality).
    */
    int NTLMSSP_NEGOTIATE_SEAL = 0x00000020;

    /**

        int result = request.size();

        // Then
        assertEquals(largeSize, result);
        verify(request, times(1)).size();
    }

    @Test
    @DisplayName("Test createCancel returns cancel request")
    void testCreateCancelReturnsRequest() {
        // Given
        when(request.createCancel()).thenReturn(cancelRequest);

        // When

        }

        @Test
        @DisplayName("Should handle read request with RDMA channel")
        void testReadRequestWithRdmaChannel() {
            request.setReadLength(65536);
            request.setOffset(0L);
            // Note: channel is private and not settable via public API
            // This test documents that channel defaults to SMB2_CHANNEL_NONE

            byte[] buffer = new byte[256];

    int getMaxChannels();

    /**
     * Channel binding policy
     *
     * Property {@code jcifs.smb.client.channelBindingPolicy} (String, default "preferred")
     * Values: "disabled", "preferred", "required"
     *
     * @return channel binding policy
     */
    int getChannelBindingPolicy();

    /**
     * Load balancing strategy for multi-channel
     *

    @Test
    @DisplayName("Should write channel field as zero")
    void testChannelFieldAlwaysZero() throws Exception {
        // Given
        byte[] buffer = new byte[512];

        // When
        request.encode(buffer, 0);

        // Then
        int bodyOffset = Smb2Constants.SMB2_HEADER_LENGTH;
        assertEquals(0, SMBUtil.readInt4(buffer, bodyOffset + 8)); // Channel field should always be 0
    }