*
 * 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)

        /** Connection is fully established and ready for RDMA operations */
        ESTABLISHED,
        /** Connection encountered an error */
        ERROR,
        /** Connection is being closed */
        CLOSING,
        /** Connection is closed */
        CLOSED
    }

    /** Remote endpoint address */
    protected final InetSocketAddress remoteAddress;
    /** Local endpoint address */

        assertFalse(auth.isClosed());

        // Close the authenticator
        auth.close();

        // Verify it's closed
        assertTrue(auth.isClosed());
        // Cannot check password after closing as it now throws IllegalStateException
        // This is actually good security practice - closed authenticators cannot be accessed

        // Verify multiple closes don't cause issues

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

                if (channel != null) {
                    try {
                        channel.close();
                    } catch (IOException e) {
                        getLogger().debug("Error closing FileChannel for resolution tracking file: " + touchfile, e);
                    }
                }
            }
        }
    }

    Date readLastUpdated(File touchfile, String key) {

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

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

            throw new IOException("DiSNI RDMA write failed", e);
        }
    }

    @Override
    public void close() throws IOException {
        state = RdmaConnectionState.CLOSING;

        try {
            // In real implementation, this would close the DiSNI endpoint:
            // if (endpoint != null) {
            //     endpoint.close();
            // }
        } finally {

        }

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

The connection lock is never held while doing I/O (even closing a socket) to prevent contention.