private int flags;
    private HandleGuid createGuid;

    /**
     * Create a new durable handle V2 request
     * @param timeoutMs the timeout in milliseconds (0 for persistent handles)
     * @param persistent true if this should be a persistent handle
     */
    public DurableHandleV2Request(long timeoutMs, boolean persistent) {
        this.timeoutMs = timeoutMs;

         * Constructs a SamrCloseHandle request.
         *
         * @param handle The policy handle to close
         */
        public SamrCloseHandle(final rpc.policy_handle handle) {
            this.handle = handle;
        }

        @Override
        public void encode_in(final NdrBuffer _dst) throws NdrException {
            this.handle.encode(_dst);
        }

        @Override

         * Constructs a SamrCloseHandle request.
         *
         * @param handle The policy handle to close
         */
        public SamrCloseHandle(final rpc.policy_handle handle) {
            this.handle = handle;
        }

        @Override
        public void encode_in(final NdrBuffer _dst) throws NdrException {
            handle.encode(_dst);
        }

        @Override

        when(handle.isValid()).thenReturn(true);
        SmbWatchHandleImpl sut = new SmbWatchHandleImpl(handle, 0, false);

        sut.close();

        verify(handle, times(1)).close(0L);
    }

    // close() should do nothing when handle is invalid
    @Test
    @DisplayName("close() does nothing when handle invalid")

        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

        int offset = 10;

        // When
        int bytesRead = request.readBytesWireFormat(buffer, offset);

        // Then
        assertEquals(0, bytesRead);
    }

    @DisplayName("Should handle different completion filter combinations")
    @ParameterizedTest
    @CsvSource({ "1, FILE_NOTIFY_CHANGE_FILE_NAME", "2, FILE_NOTIFY_CHANGE_DIR_NAME", "4, FILE_NOTIFY_CHANGE_ATTRIBUTES",

            return null;
        }).when(mockDcerpcHandle).sendrecv(any(MsrpcLsarOpenPolicy2.class));

        // Act
        LsaPolicyHandle handle = new LsaPolicyHandle(mockDcerpcHandle, server, access);

        // Assert
        assertNotNull(handle);
        verify(mockDcerpcHandle, times(1)).sendrecv(any(MsrpcLsarOpenPolicy2.class));
    }

    @Test

    /**
     * Checks if this tree handle refers to the same tree as another
     * @param th the tree handle to compare with
     * @return whether the handles refer to the same tree
     */
    boolean isSameTree(SmbTreeHandle th);

    /**
     * Checks if this tree handle uses SMB2 or later protocol
     * @return whether this tree handle uses SMB2+
     */
    boolean isSMB2();

    /**

                log.warn("Tree handle was not properly released, performing emergency cleanup: "
                        + (this.resourceLoc != null ? this.resourceLoc.getURL() : "unknown"));
                emergencyReleaseHandle();
            }
        } catch (Exception e) {
            log.error("Error during tree handle finalization", e);
        } finally {
            super.finalize();

            assertEquals(mockBinding, handle.getBinding());
            assertTrue(handle.getMaxRecv() > 0);
            assertTrue(handle.getMaxXmit() > 0);
            assertEquals("test_server", handle.getServer());
            assertEquals("test_server_dfs", handle.getServerWithDfs());
            assertEquals(mockContext, handle.getTransportContext());