}

    /**
     * Tests whether the output stream is currently open.
     *
     * @return true if the stream is open, false otherwise
     */
    public boolean isOpen() {
        return file.isOpen();
    }

    void ensureOpen() throws IOException {
        // ensure file is open
        if (!file.isOpen()) {
            file.open(openFlags, access | SmbConstants.FILE_WRITE_DATA, SmbFile.ATTR_NORMAL, 0);

/**
 * MSRPC implementation for opening an LSA policy handle.
 * This class provides functionality to open a handle to the LSA policy
 * database on a remote server using the LSA RPC interface.
 */
public class MsrpcLsarOpenPolicy2 extends lsarpc.LsarOpenPolicy2 {

    /**
     * Creates a new request to open an LSA policy handle.
     *
     * @param server the server name to connect to

    public static boolean canCacheEnumeration(int state) {
        return Smb2LeaseState.hasReadCaching(state);
    }

    /**
     * Check if directory can keep handles open
     * @param state lease state
     * @return true if directory handles can be kept open
     */
    public static boolean canKeepHandlesOpen(int state) {
        return Smb2LeaseState.hasHandleCaching(state);
    }

    /**

import jcifs.dcerpc.rpc;

/**
 * MSRPC implementation for opening a domain handle.
 * This class provides functionality to open a handle to a SAM domain
 * using the SAMR RPC interface.
 */
public class MsrpcSamrOpenDomain extends samr.SamrOpenDomain {

    /**
     * Creates a new request to open a domain handle.
     *
     * @param handle the SAM policy handle
     * @param access the desired access rights

    private static final int STRUCTURE_SIZE = 16;

    private byte[] fileId; // 16-byte file ID from previous open

    /**
     * Create a new durable handle reconnect context
     * @param fileId the 16-byte file ID from the previous open
     */
    public DurableHandleReconnect(byte[] fileId) {
        if (fileId.length != 16) {

    /** No process is on the other end of the pipe */
    int NT_STATUS_PIPE_DISCONNECTED = 0xC00000b0;
    /** The pipe is being closed */
    int NT_STATUS_PIPE_CLOSING = 0xC00000b1;
    /** Waiting for a process to open the other end of the pipe */
    int NT_STATUS_PIPE_LISTENING = 0xC00000b3;
    /** The file that was specified is a directory */
    int NT_STATUS_FILE_IS_A_DIRECTORY = 0xC00000ba;

    /**
     * Share flag indicating the share is a DFS root.
     */
    public static final int SMB2_SHAREFLAG_DFS_ROOT = 0x2;
    /**
     * Share flag indicating that exclusive opens are restricted on this share.
     */
    public static final int SMB2_SHAREFLAG_RESTRICT_EXCLUSIVE_OPENS = 0x100;
    /**
     * Share flag indicating that shared delete is forced for this share.
     */

            return 0;
        }
        final long start = fp;

        if (tmp == null) {
            throw new IOException("Bad file descriptor");
        }
        // ensure file is open
        file.open(openFlags, access, SmbFile.ATTR_NORMAL, 0);

        /*
         * Read AndX Request / Response
         */

        if (LogStream.level >= 4) {

        // Arrange
        SmbPipeOutputStream out = newStream();
        CIFSException boom = new CIFSException("open-fail");
        when(handle.ensureOpen()).thenThrow(boom);

        // Act + Assert
        CIFSException ex = assertThrows(CIFSException.class, out::ensureOpen);
        assertEquals("open-fail", ex.getMessage());
        verify(handle, times(1)).ensureOpen();
    }

    @Test

                          example: "Open Source Enterprise Search Server: Fess — Fess 11.0 documentation"
                        content_title:
                          type: string
                          example: "Open Source Enterprise Search Server: Fess — Fe..."
                        digest:
                          type: string