Searched refs:wb_ (Results 1 – 12 of 12) 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 | 581 Http2Handler::WriteBuf *Http2Handler::get_wb() { return &wb_; } in get_wb()
589 auto n = std::min(wb_.wleft(), data_pendinglen_); in fill_wb()
590 wb_.write(data_pending_, n); in fill_wb()
613 auto n = wb_.write(data, datalen); in fill_wb()
659 if (wb_.rleft() > 0) { in write_clear()
661 while ((nwrite = write(fd_, wb_.pos, wb_.rleft())) == -1 && in write_clear()
671 wb_.drain(nwrite); in write_clear()
674 wb_.reset(); in write_clear()
678 if (wb_.rleft() == 0) { in write_clear()
683 if (wb_.rleft() == 0) { in write_clear()
[all …]
|
| D | shrpx_http2_session.cc | 192 wb_(worker->get_mcpool()),
241 wb_.reset(); in disconnect()
701 wb_.append(req); in downstream_connect_proxy()
1758 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in downstream_read()
1781 wb_.append(data, datalen); in downstream_write()
1783 if (wb_.rleft() >= MAX_BUFFER_SIZE) { in downstream_write()
1789 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in downstream_write()
2032 if (wb_.rleft() > 0) { in write_clear()
2033 auto iovcnt = wb_.riovec(iov.data(), iov.size()); in write_clear()
2049 wb_.drain(nwrite); in write_clear()
[all …]
|
| D | shrpx_live_check.h | 95 DefaultMemchunks wb_; variable
|
| D | asio_client_session_tcp_impl.cc | 77 boost::asio::async_write(socket_, boost::asio::buffer(wb_, wblen_), h); in write_socket()
|
| D | shrpx_http2_upstream.cc | 1015 : wb_(handler->get_worker()->get_mcpool()), in Http2Upstream()
1160 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_read()
1209 if (wb_.rleft() >= max_buffer_size_) { in on_write()
1224 wb_.append(data, datalen); in on_write()
1228 nghttp2_session_want_write(session_) == 0 && wb_.rleft() == 0) { in on_write()
2291 if (iovcnt == 0 || wb_.rleft() == 0) { in response_riovec()
2295 return wb_.riovec(iov, iovcnt); in response_riovec()
2298 void Http2Upstream::response_drain(size_t n) { wb_.drain(n); } in response_drain()
2300 bool Http2Upstream::response_empty() const { return wb_.rleft() == 0; } in response_empty()
2302 DefaultMemchunks *Http2Upstream::get_response_buf() { return &wb_; } in get_response_buf()
|
| D | asio_client_session_tls_impl.cc | 96 boost::asio::async_write(socket_, boost::asio::buffer(wb_, wblen_), h); in write_socket()
|
| D | asio_client_session_impl.cc | 674 std::copy_n(data_pending_, data_pendinglen_, std::begin(wb_) + wblen_); in do_write()
698 if (wblen_ + n > wb_.size()) { in do_write()
705 std::copy_n(data, n, std::begin(wb_) + wblen_); in do_write()
|
| D | asio_client_session_impl.h | 104 boost::array<uint8_t, 64_k> wb_; variable
|
| D | shrpx_http2_upstream.h | 132 DefaultMemchunks wb_;
|
| D | shrpx_http2_session.h | 252 DefaultMemchunks wb_; variable
|
| D | HttpServer.h | 215 WriteBuf wb_; variable
|