dos.writeInt(Integer.reverseBytes(3)); // 3 buffers
            dos.writeInt(Integer.reverseBytes(PacConstants.PAC_VERSION));

            // Write buffer entries
            dos.writeInt(Integer.reverseBytes(PacConstants.LOGON_INFO));
            dos.writeInt(Integer.reverseBytes(10));
            dos.writeLong(Long.reverseBytes(100));

      Multiset<E> multiset, ObjectOutputStream stream) throws IOException {
    int entryCount = multiset.entrySet().size();
    stream.writeInt(entryCount);
    for (Multiset.Entry<E> entry : multiset.entrySet()) {
      stream.writeObject(entry.getElement());
      stream.writeInt(entry.getCount());
    }
  }

  /**
   * Populates a multiset by reading an input stream, as part of deserialization. See {@link

        Encdec.enc_uint16be((short) v, tmp, 0);
        write(tmp, 0, 2);
    }

    @Override
    public final void writeInt(final int v) throws SmbException {
        Encdec.enc_uint32be(v, tmp, 0);
        write(tmp, 0, 4);
    }

    @Override
    public final void writeLong(final long v) throws SmbException {
        Encdec.enc_uint64be(v, tmp, 0);
        write(tmp, 0, 8);
    }

    @Override

        ?: InflaterSource(deflatedBytes, inflater).also { this.inflaterSource = it }

    if (noContextTakeover) {
      inflater.reset()
    }

    deflatedBytes.writeAll(buffer)
    deflatedBytes.writeInt(OCTETS_TO_ADD_BEFORE_INFLATION)

    val totalBytesToRead = inflater.bytesRead + deflatedBytes.size

    // We cannot read all, as the source does not close.

	if err != nil {
		return
	}
	err = en.WriteInt(z.PartNumber)
	if err != nil {
		err = msgp.WrapError(err, "PartNumber")
		return
	}
	// write "Algorithm"
	err = en.Append(0xa9, 0x41, 0x6c, 0x67, 0x6f, 0x72, 0x69, 0x74, 0x68, 0x6d)
	if err != nil {
		return
	}
	err = en.WriteUint(uint(z.Algorithm))
	if err != nil {
		err = msgp.WrapError(err, "Algorithm")
		return

        long MILLISECONDS_BETWEEN_1970_AND_1601 = 11644473600000L;
        writeLong(buffer, 0, (create + MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L);
        writeLong(buffer, 8, (lastAccess + MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L);
        writeLong(buffer, 16, (lastWrite + MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L);
        writeLong(buffer, 24, (change + MILLISECONDS_BETWEEN_1970_AND_1601) * 10000L);

				time.Sleep(time.Duration(readRng.Intn(maxSleep)))
			}
		}
	}()

	// Writer
	{
		buf := make([]byte, 1024)
		writeRng := rand.New(rand.NewSource(2))
		for range 2500 {
			writeRng.Read(buf)
			// Write
			n, err := rb.Write(buf[:writeRng.Intn(len(buf))])
			if err != nil {
				t.Fatalf("write failed: %v", err)
			}
			wroteBytes += n
			wrote.Write(buf[:n])

     */
    protected boolean done = false;

    /**
     * Constructs a ContentOutputStream with a specified threshold and temporary directory.
     *
     * @param threshold the threshold in bytes for writing to memory before writing to a file
     * @param tmpDir the temporary directory to create the file in
     */
    public ContentOutputStream(final int threshold, final File tmpDir) {
        super(threshold, PREFIX, SUFFIX, tmpDir);

 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and

    private SmbComWriteAndX reqx;
    private SmbComWriteAndXResponse rspx;
    private SmbComWrite req;
    private SmbComWriteResponse rsp;

    /**
     * Creates an {@link java.io.OutputStream} for writing to a file
     * on an SMB server addressed by the URL parameter. See {@link
     * jcifs.smb1.smb1.SmbFile} for a detailed description and examples of
     * the smb URL syntax.
     *