when(mockSmbPipeHandleInternal.sendrecv(buf, 0, 50, inB, 4280)).thenReturn(40);
            when(mockSmbPipeHandleInternal.recv(inB, 40, 40)).thenReturn(40);

            int result = handle.doSendReceiveFragment(buf, 0, 50, inB);
            assertEquals(80, result);
            verify(mockSmbPipeHandleInternal).recv(inB, 40, 40);
        }

        @Test
        @DisplayName("Should throw IOException when handle is stale")

        if (fraglen > getMaxRecv()) {
            throw new IOException("Unexpected fragment length: " + fraglen);
        }

        while (have < fraglen) {
            final int r = this.handle.recv(inB, have, fraglen - have);
            if (r == 0) {
                throw new IOException("Unexpected EOF");
            }
            have += r;
        }

        return have;
    }

     * @param off offset in the buffer
     * @param length maximum length to receive
     * @return number of bytes received
     * @throws IOException if an I/O error occurs
     */
    int recv(byte[] buf, int off, int length) throws IOException;

    /**
     * Send data to the pipe
     *
     * @param buf buffer containing data to send
     * @param off offset in the buffer

            Field maxRecvField = DcerpcBind.class.getDeclaredField("max_recv");
            maxRecvField.setAccessible(true);
            assertEquals(maxRecv, maxRecvField.get(bindWithParams), "Max recv should be set");
        }

        @Test
        @DisplayName("Package constructor should handle null binding")
        void testPackageConstructorWithNullBinding() throws Exception {
            // Given

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

    @Override
    public int recv(final byte[] buf, final int off, final int len) throws IOException {
        return getInput().readDirect(buf, off, len);

    }

    @Override

                    log.trace("Remote closed connection");
                } else if (timeout) {
                    log.debug("socket timeout in non peek state", ex);
                } else {
                    log.debug("recv failed", ex);
                }

                synchronized (this) {
                    try {
                        disconnect(!timeout, false);
                    } catch (final IOException ioe) {

            return false;
        }

        EncryptionNegotiateContext rec = null;
        for (final NegotiateContextRequest rnc : req.getNegotiateContexts()) {
            if (rnc instanceof EncryptionNegotiateContext) {
                rec = (EncryptionNegotiateContext) rnc;
            }
        }
        if (rec == null) {
            return false;
        }

        boolean valid = false;

    <acronym>JBIG2</acronym>
    <_comment>
      A lossless image compression standard from the
      Joint Bi-level Image Experts Group.
    </_comment>
    <tika:link>http://www.itu.int/rec/T-REC-T.88/en</tika:link>
    <magic priority="50">
      <match value="0x974A42320D0A1A0A" type="string" offset="0"/>
    </magic>
    <glob pattern="*.jb2"/>
    <glob pattern="*.jbig2"/>
  </mime-type>