/**
 * A simple {@link Supplier} of {@link SessionBuilder} instances, that on each call supplies newly
 * constructed instance. To create session out of builder, use {@link SessionBuilder#build()}. For proper closing
 * of sessions, use {@link CloseableSession#close()} method on built instance(s).
 * <p>
 * Extend this class and override methods to customize, if needed.
 *
 * @since 4.0.0

            if (rdmaConnection != null) {
                try {
                    rdmaConnection.close();
                } catch (Exception e) {
                    log.warn("Error closing RDMA connection: {}", e.getMessage());
                }
                rdmaConnection = null;
            }
        }
        return delegate.disconnect(hard, inuse);
    }

    @Override

      val connectionPool = it.connectionPool

      connectionPool.evictAll()
      if (connectionPool.connectionCount() > 0) {
        // Minimise test flakiness due to possible race conditions with connections closing.
        // Some number of tests will report here, but not fail due to this delay.
        println("Delaying to avoid flakes")
        Thread.sleep(500L)
        println("After delay: " + connectionPool.connectionCount())

        final SmbTreeHandleImpl t = this.tree;
        try {
            if (t != null && isValid()) {
                if (log.isDebugEnabled()) {
                    log.debug("Closing file handle " + this);
                }

                if (t.isSMB2()) {
                    final Smb2CloseRequest req = new Smb2CloseRequest(this.cfg, this.fileId);

        MsrpcSamrCloseHandle capturedRpc = closeHandleCaptor.getValue();
        assertNotNull(capturedRpc);
        assertEquals(handle, capturedRpc.handle); // Ensure the handle itself is passed for closing
    }

    @Test
    void close_shouldDoNothingIfAlreadyClosed() throws IOException {
        // Arrange
        int access = 0x01;
        // Simulate successful open
        doAnswer(invocation -> {

                AutoCloseable resource = holder.resourceRef.get();
                if (resource != null) {
                    try {
                        log.warn("Auto-closing abandoned resource: {} ({}, age: {} ms)", holder.resourceId, holder.resourceType,
                                holder.getAge());
                        resource.close();
                        holder.closed = true;

        String str = response.toString();

        // Should start with the class name
        assertTrue(str.startsWith("Trans2SetFileInformationResponse["));

        // Should end with closing bracket
        assertTrue(str.endsWith("]"));

        // Should contain parent toString content
        // Note: The parent toString might include various fields
        assertNotNull(str);

	lastStarted time.Time

	wg sync.WaitGroup

	// Channel of log entries.
	// Reading logCh must hold read lock on logChMu (to avoid read race)
	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
	logCh   chan any
	logChMu sync.RWMutex

	// If this webhook is being re-configured we will
	// assign the new webhook target to this field.
	// The Send() method will then re-direct entries

 *
 * Note that [nextPart] will skip any unprocessed data from the preceding part. If the preceding
 * part is particularly large or if the underlying source is particularly slow, the [nextPart] call
 * may be slow!
 *
 * Closing a part **does not** close this multipart reader; callers must explicitly close this with
 * [close].
 *
 * [rfc_2046]: http://www.ietf.org/rfc/rfc2046.txt
 */
class MultipartReader
  @Throws(IOException::class)

        }

        @Test
        @DisplayName("read after close throws 'Bad file descriptor'")
        void readAfterCloseThrows() throws Exception {
            SmbFileInputStream in = newStream();
            // closing should null tmp; subsequent readDirect should fail
            in.close();
            IOException ex = assertThrows(IOException.class, () -> in.readDirect(new byte[8], 0, 4));