directoryLeaseManager.shutdown();
        }
        if (baseLeaseManager != null) {
            baseLeaseManager.shutdown();
        }
        if (mocks != null) {
            mocks.close();
        }
    }

    @Test
    public void testCompleteDirectoryLeasingWorkflow() throws Exception {
        String directoryPath = "/test/integration";

        // Setup mock files

          .url(server.url("/"))
          .build(),
      ).execute()
      .close()
    listener.removeUpToEvent<CallEnd>()
    val call =
      client.newCall(
        Request
          .Builder()
          .url(server.url("/"))
          .build(),
      )
    val response = call.execute()
    response.close()
    assertThat(listener.recordedEventTypes()).containsExactly(
      "CallStart",

     */
    @Test
    void testClose_multipleTimes() {
        doNothing().when(smbTree).close();

        smbTree.close();
        smbTree.close();
        smbTree.close();

        verify(smbTree, times(3)).close();
    }

    /**
     * Test for close() method throwing exception.
     * Verifies behavior when close throws an exception.
     */
    @Test
    void testClose_throwsException() {

                mockSession.close();
            }, "Multiple close() calls should not throw exceptions");

            verify(mockSession, times(2)).close();
        }

        @Test
        @DisplayName("Should handle close with exception gracefully")
        void shouldHandleCloseExceptionGracefully() throws Exception {
            SmbSession mockSession = mock(SmbSession.class);

    }

    /**
     * Test for close() method.
     * Verifies that the close method can be called without throwing an exception.
     * @throws CIFSException
     */
    @Test
    void testClose() throws CIFSException {
        smbTreeHandle.close();
        // Verify that close() was called on the mock
        verify(smbTreeHandle).close();
    }

    /**
     * Test for close() method throwing CIFSException.

          val source = Buffer().writeUtf8("hello")
          return object : ForwardingSource(source) {
            override fun close() {
              closed = true
              super.close()
            }
          }.buffer()
        }
      }
    body.source().close()
    assertThat(closed).isTrue()
  }

  @Test
  fun throwingUnderlyingSourceClosesQuietly() {
    val body: ResponseBody =

    // Confirm all sent messages were received, followed by a client-initiated close.
    val server = serverListener.assertOpen()
    for (i in 0 until messageCount) {
      serverListener.assertBinaryMessage(message)
    }
    serverListener.assertClosing(1001, "")

    // When the server acknowledges the close the connection shuts down gracefully.
    server.close(1000, null)
    clientListener.assertClosing(1000, "")

   * CharStreams} method returns a singleton writer whose {@code close} method has no effect, while
   * the {@link Writer#nullWriter()} method returns a new instance whose methods throw after the
   * instance is {@link Writer#close() closed}.
   *
   * @since 15.0
   */
  public static Writer nullWriter() {
    return NullWriter.INSTANCE;
  }

        // Simulate successful close
        doAnswer(invocation -> {
            MsrpcSamrCloseHandle rpc = invocation.getArgument(0);
            rpc.retval = 0;
            return null;
        }).when(mockDcerpcHandle).sendrecv(any(MsrpcSamrCloseHandle.class));

        // First close call
        handle.close();

        // Act
        // Second close call
        handle.close();

        assertEquals("working", result);

        // Close it
        cbToClose.close();

        // Should not throw exception (close should be idempotent)
        cbToClose.close();
    }

    @Test
    public void testEnhancedMetricsTracking() throws Exception {
        SmbCircuitBreaker cbWithEnhanced = new SmbCircuitBreaker("enhanced-test");

        try {