*/
  @Throws(IOException::class)
  fun processNextFrame() {
    check(!closed) { "closed" }

    readHeader()
    if (isControlFrame) {
      readControlFrame()
    } else {
      readMessageFrame()
    }
  }

  @Throws(IOException::class, ProtocolException::class)
  private fun readHeader() {
    if (receivedCloseFrame) throw IOException("closed")

    @Test
    @DisplayName("Test decode throws exception when length is too short")
    void testDecodeThrowsExceptionWhenLengthTooShort() {
        byte[] buffer = new byte[28];

        // Test with len = 23 (one byte too short)
        SMBProtocolDecodingException exception = assertThrows(SMBProtocolDecodingException.class, () -> response.decode(buffer, 0, 23),
                "Should throw exception when length < 24");

        @Override
        public void encode(NdrBuffer _dst) throws NdrException {
            _dst.align(4);
            _dst.enc_ndr_referent(netname, 1);

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

            }
        }

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

        assertEquals(expected, result);
        verify(transport, times(1)).disconnect(hard, inuse);
    }

    // Error case: disconnect throws IOException
    @Test
    @DisplayName("disconnect throws IOException when underlying close fails")
    void disconnect_throwsIOException() throws Exception {
        doThrow(new java.io.IOException("close error")).when(transport).disconnect(true, true);

    }

    @Test
    void testWrapMethodThrowsDcerpcException() throws DcerpcException {
        // Configure the mock to throw DcerpcException when wrap is called
        doThrow(new DcerpcException("Test wrap exception")).when(dcerpcSecurityProvider).wrap(mockNdrBuffer);

        // Assert that calling wrap throws DcerpcException
        assertThrows(DcerpcException.class, () -> dcerpcSecurityProvider.wrap(mockNdrBuffer));

            off += fragSize;
        }
        throw new IOException();
    }

    /**
     * @param msg
     * @param in
     * @param off
     * @param isDirect
     * @return
     * @throws IOException
     * @throws DcerpcException
     * @throws NdrException
     */
    private byte[] receiveMoreFragments(final DcerpcMessage msg, byte[] in) throws IOException, DcerpcException, NdrException {

    @DisplayName("Constructor: invalid mode throws IllegalArgumentException")
    void constructor_invalidMode_throws() {
        SmbFile file = mock(SmbFile.class);
        assertThrows(IllegalArgumentException.class, () -> new SmbRandomAccessFile(file, "badmode"));
    }

    @Test
    @DisplayName("open(): acquires and releases handle (no I/O)")
    void open_acquiresAndReleasesHandle() throws Exception {

        assertTrue(result > 0);
        assertNotNull(response.getSecurityDescriptor());
    }

    @Test
    @DisplayName("Test readDataWireFormat with IOException throws ArrayIndexOutOfBoundsException")
    void testReadDataWireFormatWithIOException() throws Exception {
        // Create an invalid security descriptor buffer that will cause ArrayIndexOutOfBoundsException
        byte[] buffer = new byte[4];

            PhaseRecorder phaseRecorder)
            throws LifecycleExecutionException {
        execute(session, mojoExecution, dependencyContext);
        phaseRecorder.observeExecution(mojoExecution);
    }

    private void execute(MavenSession session, MojoExecution mojoExecution, DependencyContext dependencyContext)
            throws LifecycleExecutionException {

    /**
     * @throws Exception
     */
    public void testEncode() throws Exception {
        assertEquals("1", ENCODED_DATA, Base64Util.encode(BINARY_DATA));
        System.out.println(Base64Util.encode(new byte[] { 'a', 'b', 'c' }));
    }

    /**
     * @throws Exception
     */
    public void testDecode() throws Exception {