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");

    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;

        // Buffer should still contain the event since disabled check should return early
        List<LogNotificationEvent> remaining = ComponentUtil.getLogNotificationHelper().drainAll();
        assertEquals(1, remaining.size());
        assertEquals("should remain", remaining.get(0).getMessage());
    }

    @Test
    public void test_expired_enabled_drainsBuffer() {
        // Enable log notification

     */
    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;
    }

    /**

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

  }

  private void checkOpen() throws IOException {
    if (seq == null) {
      throw new IOException("reader closed");
    }
  }

  private boolean hasRemaining() {
    return remaining() > 0;
  }

  private int remaining() {
    requireNonNull(seq); // safe as long as we call this only after checkOpen
    return seq.length() - pos;
  }

  /*

		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 {