QuickStreamEndPoint.java

    @Override
    public boolean flush(ByteBuffer... buffers) throws IOException
    {
        int length = buffers.length;
        boolean last = buffers[length - 1] == LAST_FLAG;
        if (last)
            --length;

        int bufSize = 0;

        for (int i = 0; i < length; i++)
        {
            ByteBuffer buffer = buffers[i];
            int remaining = buffer.remaining();
            bufSize += remaining;
        }

        ByteBuffer byteBuffer = ByteBuffer.allocate(bufSize);

        for (int i = 0; i < length; i++)
        {
            ByteBuffer buffer = buffers[i];
            byteBuffer.put(buffer);
        }
        byteBuffer.flip();

        return flush(byteBuffer, last);
    }

    public boolean flush(ByteBuffer buffer, boolean last) throws IOException
    {
        // TODO: session.flush(streamId, buffer) feeds Quiche and then calls flush().
        //  Can we call flush() only after the for loop below?

        if (LOG.isDebugEnabled())
            LOG.debug("flushing 1 buffer(s) to {}", this);
        {
            int flushed = session.flush(streamId, buffer, last);
            if (LOG.isDebugEnabled())
                LOG.debug("stream #{} (last? {}) flushed {} bytes window={}/{} to {}", streamId, last, flushed, session.getWindowCapacity(streamId), session.getWindowCapacity(), this);
            if (buffer.hasRemaining())
            {
                if (LOG.isDebugEnabled())
                    LOG.debug("incomplete flushing of {}", this);
                return false;
            }
        }
        if (LOG.isDebugEnabled())
            LOG.debug("flushed {}", this);
        return true;
    }