Lines Matching refs:promised_downstream
716 auto promised_downstream = std::make_unique<Downstream>( in on_frame_send_callback() local
718 auto &req = promised_downstream->request(); in on_frame_send_callback()
725 promised_downstream.get()); in on_frame_send_callback()
727 promised_downstream->set_assoc_stream_id(frame->hd.stream_id); in on_frame_send_callback()
728 promised_downstream->disable_upstream_rtimer(); in on_frame_send_callback()
736 auto &promised_balloc = promised_downstream->get_block_allocator(); in on_frame_send_callback()
765 promised_downstream->inspect_http2_request(); in on_frame_send_callback()
767 promised_downstream->set_request_state(DownstreamState::MSG_COMPLETE); in on_frame_send_callback()
771 auto ptr = promised_downstream.get(); in on_frame_send_callback()
772 upstream->add_pending_downstream(std::move(promised_downstream)); in on_frame_send_callback()
2327 auto promised_downstream = in on_downstream_push_promise() local
2329 auto &promised_req = promised_downstream->request(); in on_downstream_push_promise()
2331 promised_downstream->set_downstream_stream_id(promised_stream_id); in on_downstream_push_promise()
2333 promised_downstream->set_assoc_stream_id(downstream->get_stream_id()); in on_downstream_push_promise()
2335 promised_downstream->disable_upstream_rtimer(); in on_downstream_push_promise()
2343 auto ptr = promised_downstream.get(); in on_downstream_push_promise()
2344 add_pending_downstream(std::move(promised_downstream)); in on_downstream_push_promise()
2351 Downstream *downstream, Downstream *promised_downstream) { in on_downstream_push_promise_complete() argument
2354 const auto &promised_req = promised_downstream->request(); in on_downstream_push_promise_complete()
2365 nva.size(), promised_downstream); in on_downstream_push_promise_complete()
2370 promised_downstream->set_stream_id(promised_stream_id); in on_downstream_push_promise_complete()
2376 Downstream *promised_downstream) { in cancel_premature_downstream() argument
2379 << promised_downstream; in cancel_premature_downstream()
2381 downstream_queue_.remove_and_get_blocked(promised_downstream, false); in cancel_premature_downstream()