jcifs.smb1.util.Hexdump.hexdump(log, sbuf, 4, 32);
        }

        for (;;) {
            /* 01234567
             * 00SSFSMB
             * 0 - 0's
             * S - size of payload
             * FSMB - 0xFF SMB magic #
             */

            if (sbuf[0] == (byte) 0x00 && sbuf[1] == (byte) 0x00 && sbuf[4] == (byte) 0xFF && sbuf[5] == (byte) 'S' && sbuf[6] == (byte) 'M'

            }

            doReceiveFragment(stub, isDirect);
            buf.reset();
            buf.setIndex(8);
            buf.setLength(buf.dec_ndr_short());

            if (securityProvider != null) {
                securityProvider.unwrap(buf);
            }

            buf.setIndex(0);

            msg.decode_header(buf);

            off = 24;

        return in;
    }

    /**
     * @param fbuf
     * @throws DcerpcException
     */
    private void setupReceivedFragment(final NdrBuffer fbuf) throws DcerpcException {
        fbuf.reset();
        fbuf.setIndex(8);
        fbuf.setLength(fbuf.dec_ndr_short());

        if (this.securityProvider != null) {
            this.securityProvider.unwrap(fbuf);
        }
    }

    /**

      }
    }

    checkNotNull(from);
    checkNotNull(to);
    long total = 0;
    CharBuffer buf = createBuffer();
    while (from.read(buf) != -1) {
      Java8Compatibility.flip(buf);
      to.append(buf);
      total += buf.remaining();
      Java8Compatibility.clear(buf);
    }
    return total;
  }

            }
        };

        byte[] buf = new byte[128];
        // After header at 0..32
        buf[33] = 4; // wordCount
        buf[34] = (byte) 0xFF; // andxCommand
        // andxOffset (ignored when 0xFF)
        buf[36] = 0;
        buf[37] = 0;
        // byteCount at index start + 1 + wordCount*2 = 33 + 1 + 8 = 42
        ServerMessageBlock.writeInt2(20, buf, 42);

        int len = block.decode(buf, 0);

                    final StringBuilder buf = new StringBuilder();
                    buf.append('{');
                    appendJson("id", entity.getId(), buf).append(',');
                    appendJson("created-at", entity.getCreatedAt(), buf).append(',');
                    appendJson("updated-at", entity.getUpdatedAt(), buf);
                    buf.append('}');
                    buf.append('\n');
                    try {

            buf.append(v);
            if (!v.endsWith("$")) {
                buf.append(".*");
            }
        } else if (v.endsWith("$")) {
            buf.append(".*");
            buf.append(v);
        } else if (v.endsWith("/\\E")) {
            buf.append(".*");
            buf.append(v);
            buf.append(".*");
        } else {
            buf.append(v);
        }

            }
        }
        if (buf.indexOf("MM") == -1) {
            final int pos = buf.indexOf("M");
            if (pos != -1) {
                buf.replace(pos, pos + 1, "MM");
            }
        }
        if (buf.indexOf("dd") == -1) {
            final int pos = buf.indexOf("d");
            if (pos != -1) {
                buf.replace(pos, pos + 1, "dd");
            }

        }

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

            byte[] buf = new byte[4280];

            when(mockSmbPipeHandleInternal.recv(buf, 0, buf.length)).thenAnswer(invocation -> {

                return resp.getResponseLength();
            }
            final SmbPipeOutputStream out = getOutput();
            final SmbPipeInputStream in = getInput();
            out.write(buf, off, length);
            return in.read(inB);
        }
    }

    @Override