assertFalse(target.isOpen());
        assertFalse(target.isStale());

        // After ensureOpen, handle valid -> open
        SmbFileHandleImpl fh = target.ensureOpen();
        assertSame(fileHandle, fh);
        assertTrue(target.isOpen());
        assertFalse(target.isStale());

        // If handle becomes invalid, reflect stale

    }
}

private void reconnectWithDurableHandle(HandleInfo handle) throws IOException {
    Smb2CreateRequest request = new Smb2CreateRequest();
    request.setPath(handle.path);
    request.addReconnectContext(handle.fileId);
    
    // Add lease context if needed
    if (handle.leaseKey != null) {
        request.addLeaseContext(handle.leaseKey, Smb2LeaseState.SMB2_LEASE_NONE, false);
    }
    

R8 / ProGuard
=============

If you use OkHttp as a dependency in an Android project which uses R8 as a default compiler you
don't have to do anything. The specific rules are [already bundled][okhttp3_pro] into the JAR which can be
interpreted by R8 automatically.

If you, however, don't use R8 you have to apply the rules from [this file][okhttp3_pro]. You might
also need rules from [Okio][okio] which is a dependency of this library.

        when(nego.isSigningNegotiated()).thenReturn(true);

        assertEquals(1111, handle.getSendBufferSize());
        assertEquals(2222, handle.getReceiveBufferSize());
        assertEquals(3333, handle.getMaximumBufferSize());
        assertTrue(handle.areSignaturesActive());

        verify(session, times(4)).close();
        verify(transport, times(4)).close();
    }

/**
 * Handle for Security Account Manager (SAM) domain operations.
 * This class represents an open handle to a SAM domain and provides
 * operations for managing domain users, groups, and aliases.
 */
public class SamrDomainHandle extends rpc.policy_handle {

    DcerpcHandle handle;

    /**
     * Creates a new SAM domain handle.
     *
     * @param handle the DCE/RPC handle for communication

import jcifs.smb1.smb1.SmbException;

/**
 * Handle for Security Account Manager (SAM) policy operations.
 * This class represents an open handle to a SAM server and provides
 * high-level access to SAM database operations.
 */
public class SamrPolicyHandle extends rpc.policy_handle {

    DcerpcHandle handle;

    /**
     * Creates a new SAM policy handle.
     *
     * @param handle the DCE/RPC handle for communication

#include "tensorflow/core/protobuf/tensorflow_server.pb.h"

// Return a tensor handle containing a float scalar
TFE_TensorHandle* TestScalarTensorHandle(TFE_Context* ctx, float value);

// Return a tensor handle containing a int scalar
TFE_TensorHandle* TestScalarTensorHandle(TFE_Context* ctx, int value);

// Return a tensor handle containing a bool scalar
TFE_TensorHandle* TestScalarTensorHandle(TFE_Context* ctx, bool value);

        // Verify it's an instance of ServerMessageBlock2Response
        assertTrue(lockResponse instanceof jcifs.internal.smb2.ServerMessageBlock2Response);
    }

    @Test
    @DisplayName("Constructor should handle null configuration")
    void testConstructorWithNullConfig() {
        // Given & When
        Smb2LockResponse lockResponse = new Smb2LockResponse(null);

        // Then
        assertNotNull(lockResponse);
    }

            return CompletableFuture.failedFuture(new IOException("No durable handle available for reconnection: " + path));
        }

        log.debug("Starting reconnection for handle: {} (cause: {})", path, cause.getMessage());
        return attemptReconnect(info, 0, cause);
    }

    /**
     * Attempt to reconnect a specific handle
     * @param handleInfo the handle information

        handle.ensureOpen();
        assertTrue(handle.isOpen());

        // Simulate invalidation
        assertFalse(handle.isOpen(), "Becomes not open when underlying handle invalid");

        // After close, report stale
        handle.close();
        assertTrue(handle.isStale(), "Closed handle reports stale");
    }

    @Test