@Test
        @DisplayName("Should throw IOException for fragment length exceeding max")
        void testDoSendReceiveFragment_FragmentTooLarge() throws Exception {
            DcerpcPipeHandle handle = createMockedDcerpcPipeHandle();

            byte[] buf = new byte[50];
            byte[] inB = new byte[100];

            // Setup fragment length exceeding max (4280)
            Encdec.enc_uint16le((short) 4281, inB, 8);

        SMBUtil.writeInt4(12 + fileNameBytes.length, buffer, offset + 4);

        // Write notification
        int notifyOffset = 80;
        SMBUtil.writeInt4(0, buffer, notifyOffset);
        SMBUtil.writeInt4(1, buffer, notifyOffset + 4);
        SMBUtil.writeInt4(fileNameBytes.length, buffer, notifyOffset + 8);
        System.arraycopy(fileNameBytes, 0, buffer, notifyOffset + 12, fileNameBytes.length);

        // When

        assertEquals(0, used, "readBytesWireFormat is unimplemented and must return 0");
    }

    private static byte[] subArray(byte[] src, int offset, int length) {
        byte[] dst = new byte[length];
        System.arraycopy(src, offset, dst, 0, length);
        return dst;
    }

        int bytesRead = response.readDataWireFormat(data, 0, data.length);

        assertEquals(40, bytesRead, "Should read 40 bytes for the two entries.");
        assertNotNull(response.results, "Results should not be null.");
        assertEquals(2, response.results.length, "Should have 2 share entries.");

        SmbShareInfo share1 = (SmbShareInfo) response.results[0];

        this.type = SESSION_RETARGET_RESPONSE;
        this.length = 6;
    }

    @Override
    int writeTrailerWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override
    int readTrailerWireFormat(final InputStream in, final byte[] buffer, int bufferIndex) throws IOException {
        if (in.read(buffer, bufferIndex, this.length) != this.length) {

                ByteArrayOutputStream baos = new ByteArrayOutputStream()) {
            int length = bis.read(bytes);
            while (length != -1) {
                if (length != 0) {
                    baos.write(bytes, 0, length);
                }
                length = bis.read(bytes);
            }
            return baos.toString(encoding);
        } catch (final Exception e) {

     * @param remoteAddress remote memory address
     * @param remoteKey remote access key
     * @param length number of bytes to read
     * @return number of bytes read
     * @throws IOException if operation fails
     */
    public int rdmaRead(ByteBuffer buffer, long remoteAddress, int remoteKey, int length) throws IOException {
        if (!isRdmaConnected()) {
            throw new IOException("RDMA connection not available");

ls,"$1"+b+"$2$3")},h=!f&&d;b.length&&(b+="/"),h&&(f=1);for(var i=0;f>i;i++){var j,k,n,o;h?(j=d,m.push(g(a))):(j=e[i].match(c.regex.findStyles)&&RegExp.$1,m.push(RegExp.$2&&g(RegExp.$2))),n=j.split(","),o=n.length;for(var p=0;o>p;p++)k=n[p],l.push({media:k.split("(")[0].match(c.regex.only)&&RegExp.$2||"all",rules:m.length-1,hasquery:k.indexOf("(")>-1,minw:k.match(c.regex.minw)&&parseFloat(RegExp.$1)+(RegExp.$2||""),maxw:k.match(c.regex.maxw)&&parseFloat(RegExp.$1)+(RegExp.$2||"")})}u()},w=functio...

    public int compare(int[] left, int[] right) {
      int minLength = Math.min(left.length, right.length);
      for (int i = 0; i < minLength; i++) {
        if (left[i] != right[i]) {
          return UnsignedInts.compare(left[i], right[i]);
        }
      }
      return left.length - right.length;
    }

    @Override
    public String toString() {

        bais.skip(4);
        readPacket.type = buffer[0] & 0xFF;
        readPacket.length = ((buffer[1] & 0x01) << 16) + ((buffer[2] & 0xFF) << 8) + (buffer[3] & 0xFF);

        byte[] readBuffer = new byte[readPacket.length];
        bais.read(readBuffer, 0, readPacket.length);
        ByteArrayInputStream dataStream = new ByteArrayInputStream(readBuffer);