}
            }
            return new NtlmChallenge(trans.getServerEncryptionKey(), dc);
        } catch (final SmbException e) {
            throw e;
        } catch (final IOException e) {
            throw new SmbException("Connection failed", e);
        }
    }

    /**
     * @return
     */
    private CIFSContext getTransportContext() {

     * the smb URL syntax.
     *
     * @param file
     *            An <code>SmbFile</code> specifying the file to write to
     * @throws SmbException if an SMB error occurs
     */
    public SmbFileOutputStream(final SmbFile file) throws SmbException {
        this(file, false);
    }

    /**
     * Creates an {@link java.io.OutputStream} for writing bytes to a file

            rpc.retval = errorCode; // Simulate error
            return null;
        }).when(mockDcerpcHandle).sendrecv(any(MsrpcSamrOpenDomain.class));

        // Act & Assert
        SmbException thrown = assertThrows(SmbException.class, () -> {
            new SamrDomainHandle(mockDcerpcHandle, mockPolicyHandle, access, mockSid);
        });
        assertEquals(errorCode, thrown.getNtStatus());

        when(config.getTransactionBufferSize()).thenReturn(65535);
        when(tree.send(any(Smb2IoctlRequest.class), eq(RequestParam.NO_RETRY))).thenThrow(new SmbException("boom"));

        IOException ex = assertThrows(IOException.class, stream::available, "Should convert SmbException to IOException");
        assertTrue(ex.getMessage().contains("boom"));
    }

    @Test
    @DisplayName("ensureTreeConnected delegates to handle")

    }

    @Override
    public synchronized SmbFileHandleImpl ensureOpen() throws CIFSException {
        if (!this.open) {
            throw new SmbException("Pipe handle already closed");
        }

        if (!isOpen()) {
            try (SmbTreeHandleImpl th = ensureTreeConnected()) {

                if (th.isSMB2()) {

            rpc.retval = errorCode; // Simulate RPC error
            return null;
        }).when(mockDcerpcHandle).sendrecv(any(MsrpcLsarOpenPolicy2.class));

        // Act & Assert
        SmbException thrown = assertThrows(SmbException.class, () -> {
            new LsaPolicyHandle(mockDcerpcHandle, server, access);
        });

        // The error code gets mapped to NT_STATUS_UNSUCCESSFUL because it's not a valid NT status code

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

        SmbException ex = assertThrows(SmbException.class, sut::watch, "Expected SmbException when handle invalid");
        assertTrue(ex.getMessage().contains("Watch was broken by tree disconnect"));
    }

 *
 * @author mbechler
 */
public class SmbPipeInputStream extends SmbFileInputStream {

    private final SmbPipeHandleImpl handle;

    /**
     * @param handle
     * @param th
     * @throws SmbException
     */
    SmbPipeInputStream(final SmbPipeHandleImpl handle, final SmbTreeHandleImpl th) throws CIFSException {
        super(handle.getPipe(), th, null);
        this.handle = handle;
    }

    /**

    @Test
    @DisplayName("getFid/getFileId throw SmbException when invalid")
    void getters_throw_whenInvalid() {
        when(cfg.isTraceResourceUsage()).thenReturn(false);
        stubValidTree(1L, true, true);
        SmbFileHandleImpl h = new SmbFileHandleImpl(cfg, new byte[] { 0x01, 0x02 }, tree, "//x", 0, 0, 0, 0, 0L);
        // invalidate
        h.markClosed();

        SmbException ex1 = assertThrows(SmbException.class, h::getFid);

            return trans.getServerEncryptionKey();
        } catch (final SmbException e) {
            throw e;
        } catch (final IOException e) {
            throw new SmbException("Connection failed", e);
        }
    }

    @Override
    public void logon(final CIFSContext tf, final Address dc) throws SmbException {
        logon(tf, dc, 0);
    }

    @Override
    @Deprecated