Searched refs:NgHttp2StreamWrite (Results 1 – 2 of 2) sorted by relevance
146 struct NgHttp2StreamWrite : public MemoryRetainer { struct150 inline explicit NgHttp2StreamWrite(uv_buf_t buf_) : buf(buf_) {} in NgHttp2StreamWrite() argument151 inline NgHttp2StreamWrite(BaseObjectPtr<AsyncWrap> req_wrap, uv_buf_t buf_) : in NgHttp2StreamWrite() argument155 SET_MEMORY_INFO_NAME(NgHttp2StreamWrite)156 SET_SELF_SIZE(NgHttp2StreamWrite)499 std::queue<NgHttp2StreamWrite> queue_;911 std::vector<NgHttp2StreamWrite> outgoing_buffers_;923 void PushOutgoingBuffer(NgHttp2StreamWrite&& write);
1551 std::vector<NgHttp2StreamWrite> current_outgoing_buffers_; in ClearOutgoing()1553 for (const NgHttp2StreamWrite& wr : current_outgoing_buffers_) { in ClearOutgoing()1580 void Http2Session::PushOutgoingBuffer(NgHttp2StreamWrite&& write) { in PushOutgoingBuffer()1597 PushOutgoingBuffer(NgHttp2StreamWrite { in CopyDataIntoOutgoing()1660 for (const NgHttp2StreamWrite& write : outgoing_buffers_) { in SendPendingData()1717 NgHttp2StreamWrite& write = stream->queue_.front(); in OnSendData()1727 session->PushOutgoingBuffer(NgHttp2StreamWrite { in OnSendData()1737 session->PushOutgoingBuffer(NgHttp2StreamWrite { in OnSendData()1841 for (const NgHttp2StreamWrite& wr : outgoing_buffers_) { in HasWritesOnSocketForStream()2021 NgHttp2StreamWrite& head = queue_.front(); in Destroy()[all …]