Lines Matching defs:write
68 // The Http2Scope object is used to queue a write to the i/o stream. It is
85 // a write is already scheduled, there's nothing to do.
1230 // If we are currently waiting for a write operation to finish, we should
1583 Debug(this, "write finished with status %d", status);
1615 // Schedule a new write if nghttp2 wants to send data.
1623 // queue), but only if a write has not already been scheduled.
1631 Debug(this, "scheduling write");
1682 // out with the error from the write to the underlying protocol,
1705 void Http2Session::PushOutgoingBuffer(NgHttp2StreamWrite&& write) {
1706 outgoing_length_ += write.buf.len;
1707 outgoing_buffers_.emplace_back(std::move(write));
1731 // Returns non-zero value if a write is already in progress.
1785 for (const NgHttp2StreamWrite& write : outgoing_buffers_) {
1786 statistics_.data_sent += write.buf.len;
1787 if (write.buf.base == nullptr) {
1790 write.buf.len);
1791 offset += write.buf.len;
1793 bufs[i++] = write.buf;
1816 // We take the write information directly out of the stream's data queue.
1842 NgHttp2StreamWrite& write = stream->queue_.front();
1843 if (write.buf.len <= length) {
1844 // This write does not suffice by itself, so we can consume it completely.
1845 length -= write.buf.len;
1846 session->PushOutgoingBuffer(std::move(write));
1851 // Slice off `length` bytes of the first write in the queue.
1853 uv_buf_init(write.buf.base, length)
1855 write.buf.base += length;
1856 write.buf.len -= length;
2301 // to wait until the current write finishes and try again to avoid nghttp2
2398 // Store the req_wrap on the last write info in the queue, so that it is
2492 // This is done here so that .write('', cb) is still a meaningful way to