}

    @Test
    @DisplayName("getPipe, getPipeType, getUncPath delegate to underlying pipe")
    void testBasicAccessors() {
        when(pipe.getPipeType()).thenReturn(0x123456);
        assertSame(pipe, target.getPipe());
        assertEquals(0x123456, target.getPipeType());
        assertEquals("\\\\pipe\\\\my-pipe", target.getUncPath());
    }

    @Test

        // Arrange
        SmbPipeHandleImpl handle = newHandleWithBasicStubs(0, "\\\\pipe\\\\foo");
        when(pipe.ensureTreeConnected()).thenReturn(tree);
        when(tree.acquire()).thenReturn(tree);
        when(tree.isSMB2()).thenReturn(true);
        when(pipe.openUnshared(eq("\\\\pipe\\\\foo"), eq(0), anyInt(), anyInt(), eq(SmbConstants.ATTR_NORMAL), eq(0))).thenReturn(fh);

 * <ul>
 * <li><code>CallNamedPipe</code> A message-type pipe call that opens,
 * writes to, reads from, and closes the pipe in a single operation.
 * <li><code>TransactNamedPipe</code> A message-type pipe call that
 * writes to and reads from an existing pipe descriptor in one operation.
 * <li><code>CreateFile</code>, <code>ReadFile</code>,
 * <code>WriteFile</code>, and <code>CloseFile</code> A byte-type pipe can

        // When
        SmbPipeResource pipe = context.getPipe("smb://server/IPC$/pipe", 0);

        // Then
        assertNotNull(pipe, "Should create pipe resource");
        assertTrue(pipe.getLocator().getURL().toString().contains("pipe"), "Pipe resource should contain pipe path");
    }

    @Test
    @DisplayName("getPipe method should handle valid pipe URLs")

    private final boolean dcePipe;

    Object lock;

    TransactNamedPipeInputStream(final SmbNamedPipe pipe) throws SmbException, MalformedURLException, UnknownHostException {
        super(pipe, pipe.pipeType & 0xFFFF00FF | SmbFile.O_EXCL);
        this.dcePipe = (pipe.pipeType & SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT) != SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT;
        lock = new Object();
    }

    @Override

        assertEquals(ServerMessageBlock.SMB_COM_TRANSACTION, netServerEnum2.command);
        assertEquals(SmbComTransaction.NET_SERVER_ENUM2, netServerEnum2.subCommand);
        assertEquals("\\PIPE\\LANMAN", netServerEnum2.name);
        assertEquals(8, netServerEnum2.maxParameterCount);
        assertEquals(16384, netServerEnum2.maxDataCount);
        assertEquals(0, netServerEnum2.maxSetupCount);

        return this.handle.ensureOpen();
    }

    /**
     * Gets the pipe handle implementation for this output stream.
     *
     * @return the handle
     */
    protected SmbPipeHandleImpl getHandle() {
        return this.handle;
    }

    @Override
    public void close() {
        // ignore, the shared file descriptor is closed by the pipe handle
    }

import jcifs.CIFSException;
import jcifs.SmbFileHandle;
import jcifs.SmbPipeHandle;

/**
 * Internal interface for SMB pipe handle operations.
 *
 * This interface extends SmbPipeHandle with additional methods needed
 * for internal pipe management and provides access to low-level pipe details.
 *
 * @author mbechler
 *
 * <p>This interface is intended for internal use.</p>
 */

/**
 * Response structure for SMB2 IOCTL pipe peek operation.
 * Provides information about data available in a named pipe.
 *
 * @author svella
 *
 */
public class SrvPipePeekResponse implements Decodable {

    /**
     * Constructs a new SrvPipePeekResponse.
     * This response contains information about data available in a named pipe.
     */
    public SrvPipePeekResponse() {
    }

    @Test
    void testSetOptionEndpointWithVariousValidPipes() throws DcerpcException {
        Object[][] testData = { { "\\pipe\\srvsvc", "srvsvc", "4B324FC8-1670-01D3-1278-5A47BF6EE188", 3, 0 },
                { "\\pipe\\lsarpc", "lsarpc", "12345778-1234-ABCD-EF00-0123456789AB", 2, 1 },
                { "\\pipe\\samr", "samr", "12345778-1234-ABCD-EF00-0123456789AC", 1, 0 } };

        for (Object[] data : testData) {