mockContext = mock(CIFSContext.class);
        when(mockContext.getConfig()).thenReturn(mockConfig);
        when(mockConfig.getMaximumBufferSize()).thenReturn(65536);
        when(mockConfig.getListSize()).thenReturn(65536);

        testFileId = new byte[16];
        for (int i = 0; i < 16; i++) {
            testFileId[i] = (byte) i;
        }
    }

    @Test

        response.setSelectedVersion(request.getMaxVersion());
        response.setCreditsGranted(request.getCreditsRequested());
        response.setMaxReceiveSize(Math.min(request.getMaxReceiveSize(), 65536));
        response.setMaxReadWriteSize(0); // No RDMA read/write support
        response.setMaxFragmentedSize(request.getMaxFragmentedSize());

        state = RdmaConnectionState.ESTABLISHED;

  }

  companion object {
    /**
     * From the HTTP/2 specs, the default initial window size for all streams is 64 KiB. (Chrome 25
     * uses 10 MiB).
     */
    const val DEFAULT_INITIAL_WINDOW_SIZE = 65535

    /** HTTP/2: Size in bytes of the table used to decode the sender's header blocks. */
    const val HEADER_TABLE_SIZE = 1

    /** HTTP/2: The peer must not send a PUSH_PROMISE frame when this is 0. */

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
        when(mockConfig.getNotifyBufferSize()).thenReturn(4096);
        when(mockConfig.getTransactionBufferSize()).thenReturn(65535);
    }

    @Test
    @DisplayName("Test constructor initialization with basic parameters")
    void testConstructorBasic() {
        int fid = 0x1234;
        int completionFilter = FILE_NOTIFY_CHANGE_FILE_NAME;

- Fix controller-manager crashes when flex plugin is removed from flex plugin directory ([#65536](https://github.com/kubernetes/kubernetes/pull/65536), [@gnufied](https://github.com/gnufied))
- Fix local volume directory can't be deleted because of volumeMode error ([#65310](https://github.com/kubernetes/kubernetes/pull/65310), [@wenlxie](https://github.com/wenlxie))

    assertThat(escapeAsString(e, TEST_STRING)).isEqualTo(TEST_STRING);
  }

  public void testSimpleEscaper() {
    UnicodeEscaper e = SIMPLE_ESCAPER;
    String expected =
        "[0]abyz[128][256][2048][4096]ABYZ[65535]"
            + "["
            + Character.MIN_SUPPLEMENTARY_CODE_POINT
            + "]"
            + "0189["
            + Character.MAX_CODE_POINT
            + "]";

    assertThat(escapeAsString(e, TEST_STRING)).isEqualTo(TEST_STRING);
  }

  public void testSimpleEscaper() {
    UnicodeEscaper e = SIMPLE_ESCAPER;
    String expected =
        "[0]abyz[128][256][2048][4096]ABYZ[65535]"
            + "["
            + Character.MIN_SUPPLEMENTARY_CODE_POINT
            + "]"
            + "0189["
            + Character.MAX_CODE_POINT
            + "]";

    class EdgeCaseTests {

        @Test
        @DisplayName("Should handle large buffer decoding")
        void testLargeBufferDecode() throws SMBProtocolDecodingException {
            byte[] largeBuffer = new byte[65536];
            Arrays.fill(largeBuffer, (byte) 0xFF);

            TestCreateContextResponse response = new TestCreateContextResponse("LARGE_BUFFER_TEST".getBytes(StandardCharsets.UTF_8));

        assertDoesNotThrow(() -> InputValidator.validatePort(65535));

        assertThrows(IllegalArgumentException.class, () -> InputValidator.validatePort(0));
        assertThrows(IllegalArgumentException.class, () -> InputValidator.validatePort(-1));
        assertThrows(IllegalArgumentException.class, () -> InputValidator.validatePort(65536));
    }

    @Test
    @DisplayName("Test timeout validation")

      assertThat(ioe.message).isEqualTo("google.com")
      val cause = ioe.cause!!
      assertThat(cause).isInstanceOf<IOException>()
      assertThat(cause).hasMessage("response size exceeds limit (65536 bytes): 65537 bytes")
    }
  }

  @Test
  fun failOnBadResponse() {
    server.enqueue(dnsResponse("00"))
    try {
      dns.lookup("google.com")
      fail<Any>()
    } catch (ioe: IOException) {