buf = new byte[SmbComTransaction.TRANSACTION_BUF_SIZE];

            return buf;
        }
    }
    static void getBuffers( SmbComTransaction req, SmbComTransactionResponse rsp ) {
        synchronized( cache ) {
            req.txn_buf = getBuffer();
            rsp.txn_buf = getBuffer();
        }
    }
    static public void releaseBuffer( byte[] buf ) {
        synchronized( cache ) {

        this.cache = new Object[maxBuffers];
        this.bufferSize = maxSize;
    }


    /**
     * {@inheritDoc}
     *
     * @see jcifs.BufferCache#getBuffer()
     */
    @Override
    public byte[] getBuffer () {
        synchronized ( this.cache ) {
            byte[] buf;

            if ( this.freeBuffers > 0 ) {
                for ( int i = 0; i < this.cache.length; i++ ) {

      OutputStream encodingStream = encoding.encoding.encodingStream(target);
      encodingStream.write(encodingInputs[i & INPUTS_MASK]);
      encodingStream.close();
      tmp += target.getBuffer().length();
    }
    return tmp;
  }

  @Benchmark
  public int decodingStream(int reps) throws IOException {
    int tmp = 0;
    byte[] target = new byte[n];
    for (int i = 0; i < reps; i++) {

 * 
 * @author mbechler
 * @internal
 */
public interface BufferCache {

    /**
     * 
     * @return a buffer from the cache, or a new one
     */
    byte[] getBuffer ();


    /**
     * Return a buffer to the cache
     * 
     * @param buf
     */
    void releaseBuffer ( byte[] buf );

        if ( this.state == 0 ) {
            bind();
        }
        byte[] inB = this.transportContext.getBufferCache().getBuffer();
        byte[] out = this.transportContext.getBufferCache().getBuffer();
        try {
            NdrBuffer buf = encodeMessage(msg, out);
            int off = sendFragments(msg, out, buf);

        boolean isLast, isDirect;
        DcerpcException de;

        if (state == 0) {
            bind();
        }

        isDirect = true;

        stub = jcifs.smb1.smb1.BufferCache.getBuffer();
        try {
            int off, tot, n;

            buf = new NdrBuffer(stub, 0);

            msg.flags = DCERPC_FIRST_FRAG | DCERPC_LAST_FRAG;
            msg.call_id = call_id++;

        this.index = index;
    }
    public int getCapacity() {
        return buf.length - start;
    }
    public int getTailSpace() {
        return buf.length - index;
    }
    public byte[] getBuffer() {
        return buf;
    }
    public int align(int boundary, byte value) {
        int n = align(boundary);
        int i = n;
        while (i > 0) {
            buf[index - i] = value;
            i--;

    public int getCapacity () {
        return this.buf.length - this.start;
    }


    public int getTailSpace () {
        return this.buf.length - this.index;
    }


    public byte[] getBuffer () {
        return this.buf;
    }


    public int align ( int boundary, byte value ) {
        int n = align(boundary);
        int i = n;
        while ( i > 0 ) {

        resp.reset();

        long k;

        /*
         * First request w/ interim response
         */
        try {
            req.setBuffer(getContext().getBufferCache().getBuffer());
            req.nextElement();
            if ( req.hasMoreElements() ) {
                SmbComBlankResponse interim = new SmbComBlankResponse(getContext().getConfig());

HSPLokio/RealBufferedSink;->writeShort(I)Lokio/BufferedSink;
HSPLokio/RealBufferedSource;-><init>(Lokio/Source;)V
HSPLokio/RealBufferedSource;->close()V
HSPLokio/RealBufferedSource;->exhausted()Z
HSPLokio/RealBufferedSource;->getBuffer()Lokio/Buffer;
HSPLokio/RealBufferedSource;->read(Lokio/Buffer;J)J
HSPLokio/RealBufferedSource;->readByte()B
HSPLokio/RealBufferedSource;->readByteString(J)Lokio/ByteString;
HSPLokio/RealBufferedSource;->readInt()I