Lines Matching refs:downstream
95 int Http2DownstreamConnection::attach_downstream(Downstream *downstream) {
97 DCLOG(INFO, this) << "Attaching to DOWNSTREAM:" << downstream;
102 downstream_ = downstream;
115 void Http2DownstreamConnection::detach_downstream(Downstream *downstream) {
117 DCLOG(INFO, this) << "Detaching from DOWNSTREAM:" << downstream;
123 if (submit_rst_stream(downstream) == 0) {
135 downstream->disable_downstream_rtimer();
136 downstream->disable_downstream_wtimer();
140 int Http2DownstreamConnection::submit_rst_stream(Downstream *downstream,
144 downstream->get_downstream_stream_id() != -1) {
145 switch (downstream->get_response_state()) {
152 DCLOG(INFO, this) << "Submit RST_STREAM for DOWNSTREAM:" << downstream
154 << downstream->get_downstream_stream_id()
158 downstream->get_downstream_stream_id(), error_code);
176 auto downstream = dconn->get_downstream();
177 if (!downstream) {
182 const auto &req = downstream->request();
183 auto input = downstream->get_request_buf();
191 downstream->get_request_state() == DownstreamState::MSG_COMPLETE &&
196 (downstream->get_response_state() == DownstreamState::HEADER_COMPLETE &&
197 !downstream->get_upgraded()))) {
220 downstream->disable_downstream_wtimer();