Searched refs:wb_ (Results 1 – 8 of 8) sorted by relevance
| /third_party/nghttp2/src/ |
| D | shrpx_live_check.cc | 110 wb_(worker->get_mcpool()),
164 wb_.reset(); in disconnect()
480 if (wb_.rleft() > 0) { in write_tls()
481 auto iovcnt = wb_.riovec(&iov, 1); in write_tls()
496 wb_.drain(nwrite); in write_tls()
505 if (wb_.rleft() == 0) { in write_tls()
549 if (wb_.rleft() > 0) { in write_clear()
550 auto iovcnt = wb_.riovec(&iov, 1); in write_clear()
565 wb_.drain(nwrite); in write_clear()
574 if (wb_.rleft() == 0) { in write_clear()
[all …]
|
| D | HttpServer.cc | 588 Http2Handler::WriteBuf *Http2Handler::get_wb() { return &wb_; } in get_wb()
596 auto n = std::min(wb_.wleft(), data_pendinglen_); in fill_wb()
597 wb_.write(data_pending_, n); in fill_wb()
620 auto n = wb_.write(data, datalen); in fill_wb()
666 if (wb_.rleft() > 0) { in write_clear()
668 while ((nwrite = write(fd_, wb_.pos, wb_.rleft())) == -1 && in write_clear()
678 wb_.drain(nwrite); in write_clear()
681 wb_.reset(); in write_clear()
685 if (wb_.rleft() == 0) { in write_clear()
690 if (wb_.rleft() == 0) { in write_clear()
[all …]
|
| D | shrpx_http2_session.cc | 192 wb_(worker->get_mcpool()),
241 wb_.reset(); in disconnect()
714 wb_.append(req); in downstream_connect_proxy()
1774 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in downstream_read()
1797 wb_.append(data, datalen); in downstream_write()
1799 if (wb_.rleft() >= MAX_BUFFER_SIZE) { in downstream_write()
1805 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in downstream_write()
2048 if (wb_.rleft() > 0) { in write_clear()
2049 auto iovcnt = wb_.riovec(iov.data(), iov.size()); in write_clear()
2065 wb_.drain(nwrite); in write_clear()
[all …]
|
| D | shrpx_live_check.h | 95 DefaultMemchunks wb_; variable
|
| D | shrpx_http2_upstream.cc | 1023 : wb_(handler->get_worker()->get_mcpool()), in Http2Upstream()
1170 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_read()
1219 if (wb_.rleft() >= max_buffer_size_) { in on_write()
1234 wb_.append(data, datalen); in on_write()
1238 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_write()
2309 if (iovcnt == 0 || wb_.rleft() == 0) { in response_riovec()
2313 return wb_.riovec(iov, iovcnt); in response_riovec()
2316 void Http2Upstream::response_drain(size_t n) { wb_.drain(n); } in response_drain()
2318 bool Http2Upstream::response_empty() const { return wb_.rleft() == 0; } in response_empty()
2320 DefaultMemchunks *Http2Upstream::get_response_buf() { return &wb_; } in get_response_buf()
|
| D | shrpx_http2_upstream.h | 132 DefaultMemchunks wb_;
|
| D | shrpx_http2_session.h | 252 DefaultMemchunks wb_; variable
|
| D | HttpServer.h | 217 WriteBuf wb_; variable
|