* @param msg2 the Type 2 message received from the server
     * @return the Type 3 message to send to the server
     * @throws GeneralSecurityException if a cryptographic error occurs
     * @throws CIFSException if a CIFS protocol error occurs
     */
    protected Type3Message createType3Message(final Type2Message msg2) throws GeneralSecurityException, CIFSException {
        if (this.auth instanceof NtlmNtHashAuthenticator) {

            String invalidUrl = "invalid:server";
            assertThrows(DcerpcException.class, () -> new DcerpcPipeHandle(invalidUrl, mockContext, false),
                    "Should throw DcerpcException for invalid protocol");
        }

        @Test
        @DisplayName("Should throw DcerpcException for missing endpoint")
        void testConstructor_MissingEndpoint() {
            String urlWithoutEndpoint = "ncacn_np:server";

import jcifs.internal.util.SMBUtil;

/**
 * SMB1 COM_WRITE command implementation.
 *
 * This command writes data to an open file on the server.
 * It's the basic write operation in the SMB1 protocol.
 */
public class SmbComWrite extends ServerMessageBlock {

    private int fid, count, offset, remaining, off;
    private byte[] b;

    /**
     * Constructs an empty write request.
     *

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

package jcifs.smb1.smb1;

/**
 * Interface defining DOS error codes and their mappings to NT status codes for SMB1 protocol.
 * Provides lookup tables for converting between DOS and NT error representations.
 */
public interface DosError {

    /**
     * Mapping table from DOS error codes to NT status codes.

    void testDecodeMethodIntegration() throws Exception {
        byte[] buffer = new byte[1024];
        int bufferIndex = 0;

        // Prepare SMB2 header (64 bytes)
        // Protocol ID
        System.arraycopy(new byte[] { (byte) 0xFE, 'S', 'M', 'B' }, 0, buffer, bufferIndex, 4);
        // Header length
        SMBUtil.writeInt2(64, buffer, bufferIndex + 4);
        // Credit charge

 * This class manages the rules defined in a robots.txt file, including user agent directives,
 * allowed/disallowed paths, crawl delays, and sitemap URLs.
 *
 * <p>The robots.txt protocol is implemented according to the standard specification,
 * supporting pattern matching for user agents, path-based access control, and crawl delay settings.</p>
 *
 * <p>Key features:</p>
 * <ul>

import okio.Buffer
import okio.BufferedSink
import okio.BufferedSource
import okio.buffer
import okio.sink
import okio.source
import okio.use

/**
 * A limited implementation of SOCKS Protocol Version 5, intended to be similar to MockWebServer.
 * See [RFC 1928](https://www.ietf.org/rfc/rfc1928.txt).
 */
class SocksProxy {
  private val executor = Executors.newCachedThreadPool(threadFactory("SocksProxy"))

            throw IOException("cipherSuite == $cipherSuiteString")
          }

          else -> CipherSuite.forJavaName(cipherSuiteString)
        }

      val tlsVersionString = checkNotNull(protocol) { "tlsVersion == null" }
      if ("NONE" == tlsVersionString) throw IOException("tlsVersion == NONE")
      val tlsVersion = TlsVersion.forJavaName(tlsVersionString)

      val peerCertificatesCopy =
        try {

    fun onReadPing(payload: ByteString)

    fun onReadPong(payload: ByteString)

    fun onReadClose(
      code: Int,
      reason: String,
    )
  }

  /**
   * Process the next protocol frame.
   *
   *  * If it is a control frame this will result in a single call to [FrameCallback].
   *  * If it is a message frame this will result in a single call to [FrameCallback.onReadMessage].

import jcifs.internal.SMBProtocolDecodingException;
import jcifs.internal.SMBSigningDigest;
import jcifs.internal.util.SMBUtil;
import jcifs.smb.SmbException;
import jcifs.util.Hexdump;

/**
 * Base class for SMB2/SMB3 protocol messages.
 *
 * This abstract class provides common functionality for all SMB2/SMB3
 * message types including encoding, decoding, and message handling.
 *
 * @author mbechler
 */