*
     * @param tf the CIFS context to use
     * @param name the server name or address
     * @param port the port number
     * @param exclusive whether to acquire an unshared connection
     * @param forceSigning whether to enforce SMB signing
     * @return a connected transport
     * @throws UnknownHostException if the host cannot be resolved
     * @throws IOException if an I/O error occurs

     * @param tc the CIFS context for connection configuration
     * @param unshared whether to use an exclusive connection
     * @throws DcerpcException if DCERPC initialization fails
     * @throws MalformedURLException if the URL is malformed
     */
    public DcerpcPipeHandle(final String url, final CIFSContext tc, final boolean unshared) throws DcerpcException, MalformedURLException {
        super(tc, DcerpcHandle.parseBinding(url));

        }

        @Test
        @DisplayName("Second constructor sets unshared based on flags")
        void secondCtorUnsharedFlagPath() throws Exception {
            // Arrange: include UNSHARED flag to exercise that branch
            int flags = SmbPipeResource.PIPE_TYPE_RDWR | SmbPipeResource.PIPE_TYPE_UNSHARED;

            // Act

     * @param pipeType the type of the pipe
     * @param unshared
     *            whether to use an exclusive connection for this pipe
     * @param tc the CIFS context to use
     * @throws MalformedURLException if the URL is not properly formatted
     */

    public SmbNamedPipe(final String url, final int pipeType, final boolean unshared, final CIFSContext tc) throws MalformedURLException {
        super(url, tc);

     */
    public static DcerpcHandle getHandle(final String url, final CIFSContext tc, final boolean unshared)
            throws MalformedURLException, DcerpcException {
        if (url.startsWith("ncacn_np:")) {
            return new DcerpcPipeHandle(url, tc, unshared);
        }
        throw new DcerpcException("DCERPC transport not supported: " + url);
    }

    /**
     * Bind the handle

        when(fh.getFileId()).thenReturn(new byte[16]);
        when(fh.getFid()).thenReturn(1);

        // build via package-private constructor to control unshared flag
        return new SmbRandomAccessFile(file, mode, SmbConstants.DEFAULT_SHARING, unshared);
    }

    @Test
    @DisplayName("Constructor: invalid mode throws IllegalArgumentException")
    void constructor_invalidMode_throws() {

    }

    SmbFileInputStream(final SmbFile file, final int openFlags, final int access, final int sharing, final boolean unshared)
            throws SmbException {
        this.file = file;
        this.unsharedFile = unshared;
        this.openFlags = openFlags;
        this.access = access;
        this.sharing = sharing;

        try (SmbTreeHandleInternal th = file.ensureTreeConnected()) {

            verify(mockHandle, times(1)).close();
            verify(mockHandle, atLeastOnce()).acquire();
        }

        @Test
        @DisplayName("close() closes handle; does not close file when not unshared")
        void closeClosesHandle() throws Exception {
            SmbFileInputStream in = newStream();
            in.close();
            verify(mockHandle, times(1)).close();

Sebastián Ramírez <******@****.***> 1770834732 -0800

from .shared import PYDANTIC_VERSION_MINOR_TUPLE as PYDANTIC_VERSION_MINOR_TUPLE
from .shared import annotation_is_pydantic_v1 as annotation_is_pydantic_v1
from .shared import field_annotation_is_scalar as field_annotation_is_scalar
from .shared import (
    field_annotation_is_scalar_sequence as field_annotation_is_scalar_sequence,
)
from .shared import field_annotation_is_sequence as field_annotation_is_sequence
from .shared import (