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