Home
last modified time | relevance | path

Searched refs:resume_read (Results 1 – 19 of 19) sorted by relevance

/third_party/nghttp2/src/
Dshrpx_io_control.h47 bool resume_read(IOCtrlReason reason);
Dshrpx_io_control.cc47 bool IOControl::resume_read(IOCtrlReason reason) { in resume_read() function in shrpx::IOControl
Dshrpx_health_monitor_downstream_connection.h46 virtual int resume_read(IOCtrlReason reason, size_t consumed);
Dshrpx_downstream_connection.h54 virtual int resume_read(IOCtrlReason reason, size_t consumed) = 0;
Dshrpx_http2_downstream_connection.h54 virtual int resume_read(IOCtrlReason reason, size_t consumed);
Dshrpx_health_monitor_downstream_connection.cc90 int HealthMonitorDownstreamConnection::resume_read(IOCtrlReason reason, in resume_read() function in shrpx::HealthMonitorDownstreamConnection
Dshrpx_api_downstream_connection.h78 virtual int resume_read(IOCtrlReason reason, size_t consumed);
Dshrpx_upstream.h71 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
Dshrpx_http_downstream_connection.h59 virtual int resume_read(IOCtrlReason reason, size_t consumed);
Dshrpx_https_upstream.h69 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
Dshrpx_http_downstream_connection.cc873 int HttpDownstreamConnection::resume_read(IOCtrlReason reason, in resume_read() function in shrpx::HttpDownstreamConnection
879 ioctrl_.resume_read(reason); in resume_read()
1010 if (upstream->resume_read(SHRPX_NO_BUFFER, downstream, 0) != 0) { in htp_hdrs_completecb()
1197 upstream->resume_read(SHRPX_NO_BUFFER, downstream_, in write_first()
1270 upstream->resume_read(SHRPX_NO_BUFFER, downstream_, in write_clear()
1394 upstream->resume_read(SHRPX_NO_BUFFER, downstream_, in write_tls()
Dshrpx_http2_upstream.h74 virtual int resume_read(IOCtrlReason reason, Downstream *downstream,
Dshrpx_https_upstream.cc750 return resume_read(SHRPX_NO_BUFFER, nullptr, 0); in on_write()
754 return downstream->resume_read(SHRPX_NO_BUFFER, resp.unconsumed_body_length); in on_write()
765 int HttpsUpstream::resume_read(IOCtrlReason reason, Downstream *downstream, in resume_read() function in shrpx::HttpsUpstream
771 if (ioctrl_.resume_read(reason)) { in resume_read()
Dshrpx_downstream.h331 int resume_read(IOCtrlReason reason, size_t consumed);
Dshrpx_api_downstream_connection.cc456 int APIDownstreamConnection::resume_read(IOCtrlReason reason, size_t consumed) { in resume_read() function in shrpx::APIDownstreamConnection
Dshrpx_downstream.cc273 int Downstream::resume_read(IOCtrlReason reason, size_t consumed) { in resume_read() function in shrpx::Downstream
275 return dconn_->resume_read(reason, consumed); in resume_read()
Dshrpx_http2_downstream_connection.cc551 int Http2DownstreamConnection::resume_read(IOCtrlReason reason, in resume_read() function in shrpx::Http2DownstreamConnection
Dshrpx_http2_session.cc1147 if (upstream->resume_read(SHRPX_NO_BUFFER, downstream, 0) != 0) { in on_response_headers()
1590 if (downstream->get_upstream()->resume_read(SHRPX_NO_BUFFER, downstream, in send_data_callback()
1941 upstream->resume_read(SHRPX_NO_BUFFER, downstream, 0); in submit_pending_requests()
Dshrpx_http2_upstream.cc857 if (length > 0 && downstream->resume_read(SHRPX_NO_BUFFER, length) != 0) { in send_data_callback()
1912 int Http2Upstream::resume_read(IOCtrlReason reason, Downstream *downstream, in resume_read() function in shrpx::Http2Upstream