// Simulate RDMA read operation
            log.debug("DiSNI RDMA read request: {} bytes from remote address 0x{}", bytesToRead, Long.toHexString(remoteAddress));

            return bytesToRead;

        } catch (Exception e) {
            state = RdmaConnectionState.ERROR;
            throw new IOException("DiSNI RDMA read failed", e);
        }
    }

    @Override

        assertEquals(0, response.writeParametersWireFormat(buffer, 0));
        assertEquals(0, response.writeDataWireFormat(buffer, 0));
    }

    @Test
    @DisplayName("All read methods should consistently return 0")
    void testAllReadMethodsReturnZero() {
        // Arrange
        byte[] buffer = new byte[100];

        // Act & Assert

        NameServicePacket.writeInt2(2, src, 6);
        NameServicePacket.writeInt2(3, src, 8);
        NameServicePacket.writeInt2(4, src, 10);

        int read = packet.readHeaderWireFormat(src, 0);
        assertEquals(NameServicePacket.HEADER_LENGTH, read);

        assertEquals(0x1234, packet.nameTrnId);
        assertTrue(packet.isResponse);
        assertEquals(NameServicePacket.QUERY, packet.opCode);

        assertEquals("/path/to/document.pdf", result.getContent());
    }

    /**
     * Test that input stream content is not read (only validated).
     */
    public void test_getText_doesNotReadInputStream() throws Exception {
        final byte[] testData = "This data should not be read".getBytes();
        final InputStream in = new ByteArrayInputStream(testData);
        final Map<String, String> params = new HashMap<>();

                throw new PACDecodingException("Not a kerberos token");
            }

            int readLow = stream.read() & 0xff;
            int readHigh = stream.read() & 0xff;
            int read = (readHigh << 8) + readLow;
            if (read != 0x01) {
                throw new PACDecodingException("Malformed kerberos token");
            }

        trans2FindNext2 = new Trans2FindNext2(config, TEST_SID, TEST_RESUME_KEY, TEST_FILENAME, TEST_BATCH_COUNT, TEST_BATCH_SIZE);

        byte[] buffer = new byte[10];
        int read = trans2FindNext2.readSetupWireFormat(buffer, 0, 10);

        assertEquals(0, read);
    }

    @Test
    void testReadParametersWireFormat() {
        // Test parameters wire format reading (should return 0)

#### 2. Start Fess Server

    $ unzip target/releases/fess-*.zip
    $ ./fess-*/bin/fess &

Wait for Fess to be ready (this may take up to 60 seconds):

    $ curl -s "http://localhost:8080/api/v1/health"

You should see a JSON response when Fess is ready.

#### 3. Clone Test Data

Required for SearchApiTests:

    $ git clone https://github.com/codelibs/fess-testdata.git /tmp/fess-testdata

            off = in.read(buf, 0, 1024);
        } else {
            off = in.readDirect(buf, 0, buf.length);
        }

        if (buf[0] != 5 && buf[1] != 0) {
            throw new IOException("Unexpected DCERPC PDU header");
        }

        flags = buf[3] & 0xFF;
        // next read is start of new frag

         * @return True if the process was terminated, false otherwise.
         */
        public boolean isTeminated() {
            return teminated;
        }
    }

    /**
     * Thread that reads input stream data and buffers it for later retrieval.
     * Captures output from command execution with configurable line buffering.
     */
    protected static class InputStreamThread extends Thread {

                0x05, 0x00 // totalAvailableEntries = 5
        };

        int bytesRead = response.readParametersWireFormat(buffer, 0, buffer.length);

        assertEquals(8, bytesRead, "Should read 8 bytes for parameters.");
        assertEquals(0, response.status, "Status should be 0.");
        assertEquals(2, response.numEntries, "Number of entries should be 2.");
    }

    /**