this.openTimeout = openTimeout;
    }

    /**
     * Sets the remaining bytes count.
     *
     * @param remaining
     *            the remaining to set
     */
    public final void setRemaining(final int remaining) {
        this.remaining = remaining;
    }

    void setParam(final int fid, final long offset, final int maxCount) {
        this.fid = fid;

        this.count = len;
        this.offset = offset;
        this.remaining = remaining;
        this.b = b;
        this.off = off;
    }

    /**
     * Sets the parameters for this write request.
     *
     * @param fid the file identifier
     * @param offset the file offset at which to write
     * @param remaining the number of bytes remaining to be written
     * @param b the data buffer containing bytes to write

        this.offset = offset;
        this.remaining = remaining;
        this.b = b;
        this.off = off;
        dataLength = len;
        command = SMB_COM_WRITE_ANDX;
    }

    void setParam(final int fid, final long offset, final int remaining, final byte[] b, final int off, final int len) {
        this.fid = fid;
        this.offset = offset;
        this.remaining = remaining;
        this.b = b;
        this.off = off;

        assertEquals(offset, getFieldValue(write, "offset"), "Offset should match constructor arg");
        assertEquals(remaining, getFieldValue(write, "remaining"), "Remaining should match constructor arg");
        assertEquals(buffer, getFieldValue(write, "b"), "Buffer reference should be set");
        assertEquals(off, getFieldValue(write, "off"), "Off should match constructor arg");
        assertEquals(len, getFieldValue(write, "count"), "Count should equal len");

        }

        @ParameterizedTest
        @DisplayName("Should read various remaining values")
        @ValueSource(ints = { 0, 1, 100, 1024, 65536, Integer.MAX_VALUE })
        void testReadVariousRemainingValues(int remaining) throws SMBProtocolDecodingException {
            byte[] buffer = createValidWriteResponse(0, remaining);

            int bytesRead = response.readBytesWireFormat(buffer, 0);

    public String toString() {
        return ("SmbComReadAndX[" + super.toString() + ",fid=" + fid + ",offset=" + offset + ",maxCount=" + maxCount + ",minCount="
                + minCount + ",openTimeout=" + openTimeout + ",remaining=" + remaining + ",offset=" + offset + "]");
    }

		maxEntries = opts.count
	}

	done := false
	remaining := opts.count

	for !done {
		// Read up to max number of entries.
		fis, err := d.Readdir(maxEntries)
		if err != nil {
			if err == io.EOF {
				break
			}
			return nil, osErrToFileErr(err)
		}
		if opts.count > -1 {
			if remaining <= len(fis) {
				fis = fis[:remaining]
				done = true
			}
		}
		for _, fi := range fis {

    private int fid, count, offset, remaining, off;
    private byte[] b;

    SmbComWrite() {
        command = SMB_COM_WRITE;
    }

    SmbComWrite(final int fid, final int offset, final int remaining, final byte[] b, final int off, final int len) {
        this.fid = fid;
        this.count = len;
        this.offset = offset;
        this.remaining = remaining;
        this.b = b;
        this.off = off;

          int bufIndex = 0;
          int remaining = buffer.length;
          try (InputStreamReader reader = new InputStreamReader(byteSource.openStream(), cs)) {
            int nRead = 0;
            while (remaining > 0 && (nRead = reader.read(buffer, bufIndex, remaining)) != -1) {
              bufIndex += nRead;
              remaining -= nRead;
            }
            if (nRead == -1) {

  @CanIgnoreReturnValue
  public Hasher putBytes(ByteBuffer b) {
    if (b.hasArray()) {
      putBytes(b.array(), b.arrayOffset() + b.position(), b.remaining());
      Java8Compatibility.position(b, b.limit());
    } else {
      for (int remaining = b.remaining(); remaining > 0; remaining--) {
        putByte(b.get());
      }
    }
    return this;
  }

  @Override
  @CanIgnoreReturnValue