*/
    public SmbComWriteAndX(final Configuration config, final int fid, final long offset, final int remaining, final byte[] b, final int off,
            final int len, final ServerMessageBlock andx) {
        super(config, SMB_COM_WRITE_ANDX, andx);
        this.fid = fid;
        this.offset = offset;
        this.remaining = remaining;
        this.b = b;
        this.off = off;
        this.dataLength = len;
    }

    /**

package http

import (
	"io"

	xioutil "github.com/minio/minio/internal/ioutil"
)

// DrainBody close non nil response with any response Body.
// convenient wrapper to drain any remaining data on response body.
//
// Subsequently this allows golang http RoundTripper
// to reuse the same connection for future requests.
func DrainBody(respBody io.ReadCloser) {

     * @return the count
     */
    public final int getCount() {
        return this.count;
    }

    /**
     * Returns the number of bytes remaining to be written.
     *
     * @return the remaining
     */
    public final int getRemaining() {
        return this.remaining;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.smb2.ServerMessageBlock2#writeBytesWireFormat(byte[], int)
     */

    }
    // Replace some of chars by non-matching.
    int remaining = (int) ((100 - percentMatching) * result.length / 100.0 + 0.5);
    while (remaining > 0) {
      char c = (char) random.nextInt();
      if (bitSet.get(c)) {
        int pos = random.nextInt(result.length);
        if (bitSet.get(result[pos])) {
          result[pos] = c;
          remaining--;
        }
      }
    }
    return new String(result);

  protected void update(ByteBuffer b) {
    if (b.hasArray()) {
      update(b.array(), b.arrayOffset() + b.position(), b.remaining());
      Java8Compatibility.position(b, b.limit());
    } else {
      for (int remaining = b.remaining(); remaining > 0; remaining--) {
        update(b.get());
      }
    }
  }

  /** Updates the sink with the given number of bytes from the buffer. */

      readBuffer.order(order);
    }
  }

  @CanIgnoreReturnValue
  private Hasher putBytesInternal(ByteBuffer readBuffer) {
    // If we have room for all of it, this is easy
    if (readBuffer.remaining() <= buffer.remaining()) {
      buffer.put(readBuffer);
      munchIfFull();
      return this;
    }

    // First add just enough to fill buffer size, and munch that

            // sge.setLength(data.remaining());
            // sge.setLkey(disniRegion.getLocalKey());
            // sgeList.add(sge);
            //
            // sendWR.setSg_list(sgeList);
            // endpoint.postSend(Arrays.asList(sendWR)).execute().free();

            log.debug("DiSNI RDMA send completed, {} bytes", data.remaining());

        } catch (Exception e) {

  // & this future completes. Released when the future releases the reference to the running state
  private @Nullable Set<Throwable> seenExceptions = null;
  private int remaining;

  AggregateFutureState(int remainingFutures) {
    this.remaining = remainingFutures;
  }

  final Set<Throwable> getOrInitSeenExceptions() {
    if (seenExceptions == null) {
      seenExceptions = newHashSet();

            assertEquals("Hello", new String(buffer, 0, bytesRead, "UTF-8"));

            // Read remaining bytes
            byte[] remaining = new byte[20];
            int remainingBytes = stream.read(remaining);
            assertEquals(8, remainingBytes); // ", World!"
            assertEquals(", World!", new String(remaining, 0, remainingBytes, "UTF-8"));
        }
    }

            // Parse SMB URL manually
            String remaining = urlStr.substring(6); // Remove "smb://"
            int slashIndex = remaining.indexOf('/');
            if (slashIndex == -1) {
                this.host = remaining;
                this.path = "/";
            } else {
                this.host = remaining.substring(0, slashIndex);
                this.path = remaining.substring(slashIndex);
            }