when(mockSmbPipeHandleInternal.sendrecv(buf, 0, 50, inB, 4280)).thenReturn(40);

            int result = handle.doSendReceiveFragment(buf, 0, 50, inB);
            assertEquals(40, result);
            verify(mockSmbPipeHandleInternal).sendrecv(buf, 0, 50, inB, 4280);
        }

        @Test
        @DisplayName("Should handle multiple receives for fragment")

    joinHelper(10, 20, 1);
    joinHelper(1, 1, 1, 1, 1, 1, 1, 1);
    joinHelper(1, 0, 1, 0, 1, 0, 1, 0);
  }

  public void testOnlyOneOpen() throws Exception {
    ByteSource source = newByteSource(0, 50);
    int[] counter = new int[1];
    ByteSource checker =
        new ByteSource() {
          @Override
          public InputStream openStream() throws IOException {
            if (counter[0]++ != 0) {

    joinHelper(10, 20, 1);
    joinHelper(1, 1, 1, 1, 1, 1, 1, 1);
    joinHelper(1, 0, 1, 0, 1, 0, 1, 0);
  }

  public void testOnlyOneOpen() throws Exception {
    ByteSource source = newByteSource(0, 50);
    int[] counter = new int[1];
    ByteSource checker =
        new ByteSource() {
          @Override
          public InputStream openStream() throws IOException {
            if (counter[0]++ != 0) {

            MockCreateContextResponse mock = new MockCreateContextResponse("TEST");
            byte[] buffer = new byte[100];

            int result = mock.decode(buffer, 0, 50);
            assertEquals(0, result);
        }

        @ParameterizedTest
        @ValueSource(strings = { "", "SHORT", "VERY_LONG_CONTEXT_NAME_FOR_TESTING", "特殊字符" })

    serverSocket = serverSocketFactory.createServerSocket()
    val serverAddress = InetAddress.getByName("localhost")
    serverSocket!!.bind(InetSocketAddress(serverAddress, 0), 50)
    return InetSocketAddress(serverAddress, serverSocket!!.localPort)
  }

  private fun doServerHandshake(server: HandshakeCertificates): Future<Handshake> {
    return executorService.submit<Handshake> {

            Trans2QueryPathInformationResponse resp = new Trans2QueryPathInformationResponse(0x999);

            byte[] buffer = new byte[100];
            int result = resp.readDataWireFormat(buffer, 0, 50);
            assertEquals(0, result);
            assertNull(resp.info);
        }
    }

    @Nested
    @DisplayName("Mock Interaction Tests")
    class MockInteractionTests {

        @Test

        byte[] buffer = new byte[100];

        assertThrows(NullPointerException.class, () -> nullBufferResponse.readDataWireFormat(buffer, 0, 50));
    }

    @Test
    void testReadDataWireFormatEmptyOutputBuffer() throws SMBProtocolDecodingException {
        // Test with empty outputBuffer

        // Fill test pattern
        for (int i = 0; i < buffer.length; i++) {
            buffer[i] = (byte) (i % 256);
        }

        int bytesConsumed = response.decode(buffer, 0, 50);

        assertEquals(28, bytesConsumed, "Should consume exactly 28 bytes regardless of extra length");

        byte[] resumeKey = response.getResumeKey();

        assertEquals("16/50 kB", format.formatProgress(16000L, 50000L));
        assertEquals("50 kB", format.formatProgress(50000L, 50000L));

        assertEquals("0/5.0 MB", format.formatProgress(0L, 5000000L));
        assertEquals("0.5/5.0 MB", format.formatProgress(500000L, 5000000L));
        assertEquals("1.0/5.0 MB", format.formatProgress(1000000L, 5000000L));

   * 3. Different case
   *
   * ```
   * content-type: text/html
   * content-length: 50
   * ```
   *
   * 4. Different values
   *
   * ```
   * Content-Type: text/html
   * Content-Length: 050
   * ```
   *
   * Applications that require semantically equal headers should convert them into a canonical form
   * before comparing them for equality.
   */