* @return normalized safe path
     * @throws SmbException if path is invalid or dangerous
     */
    public String validatePath(String path) throws SmbException {
        if (path == null || path.isEmpty()) {
            throw new SmbException("Path cannot be null or empty");
        }

        // Check length
        if (path.length() > maxPathLength) {

    /**
     * Creates a new witness RPC client.
     *
     * @param serverAddress the witness server address
     * @param context the CIFS context
     * @throws IOException if connection fails
     */
    public WitnessRpcClient(InetAddress serverAddress, CIFSContext context) throws IOException {
        this.serverAddress = serverAddress;
        this.context = context;

        try {

      certificates as Array<Certificate>
    }

  @Throws(
    SSLPeerUnverifiedException::class,
  )
  override fun getPeerCertificateChain(): Array<X509Certificate> = throw UnsupportedOperationException()

  override fun getPeerHost(): String = throw UnsupportedOperationException()

  override fun getPeerPort(): Int = throw UnsupportedOperationException()

  @Throws(SSLPeerUnverifiedException::class)

        smbTree.close();
        smbTree.close();
        smbTree.close();

        verify(smbTree, times(3)).close();
    }

    /**
     * Test for close() method throwing exception.
     * Verifies behavior when close throws an exception.
     */
    @Test
    void testClose_throwsException() {
        doThrow(new RuntimeException("Failed to close")).when(smbTree).close();

      private final OkHttpClient client = new OkHttpClient();

      public void run() throws Exception {
        RequestBody requestBody = new RequestBody() {
          @Override public MediaType contentType() {
            return MEDIA_TYPE_MARKDOWN;
          }

          @Override public void writeTo(BufferedSink sink) throws IOException {
            sink.writeUtf8("Numbers\n");
            sink.writeUtf8("-------\n");

  }

  public void testFrom_failedInput() throws Exception {
    assertFinallyFailsWithException(failedClosingFuture());
  }

  public void testFrom_cancelledInput() throws Exception {
    assertBecomesCanceled(ClosingFuture.from(immediateCancelledFuture()));
  }

  public void testEventuallyClosing() throws Exception {
    ClosingFuture<String> closingFuture =

        public void encode(NdrBuffer _dst) throws NdrException {
            _dst.align(4);
            _dst.enc_ndr_referent(this.entry_path, 1);

            if (this.entry_path != null) {
                _dst = _dst.deferred;
                _dst.enc_ndr_string(this.entry_path);

            }
        }

        @Override
        public void decode(NdrBuffer _src) throws NdrException {
            _src.align(4);

     * @param key
     * @param cipher
     * @return
     * @throws GeneralSecurityException
     * @throws InvalidKeyException
     * @throws InvalidAlgorithmParameterException
     * @throws IllegalBlockSizeException
     * @throws BadPaddingException
     */
    private static byte[] decryptDES(byte[] data, Key key, Cipher cipher) throws GeneralSecurityException, InvalidKeyException,

        this.delegate = delegate;
    }

    /**
     * {@inheritDoc}
     *
     * @throws CIFSException if the URL is malformed or there is an error creating the SMB resource
     *
     * @see jcifs.CIFSContext#get(java.lang.String)
     */
    @Override
    public SmbResource get(final String url) throws CIFSException {
        try {
            return new SmbFile(url, this);

            throws CIFSException {
        return delegate.getDfsReferrals(ctx, name, targetHost, targetDomain, rn);
    }

    @Override
    public boolean isSigningOptional() throws SmbException {
        return delegate.isSigningOptional();
    }

    @Override
    public boolean isSigningEnforced() throws SmbException {
        return delegate.isSigningEnforced();