Searched refs:promised_downstream (Results 1 – 9 of 9) sorted by relevance
716 auto promised_downstream = std::make_unique<Downstream>( in on_frame_send_callback() local718 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()[all …]
970 auto promised_downstream = promised_sd->dconn->get_downstream(); in on_header_callback2() local975 assert(promised_downstream); in on_header_callback2()977 auto &promised_req = promised_downstream->request(); in on_header_callback2()993 promised_downstream->add_rcbuf(name); in on_header_callback2()994 promised_downstream->add_rcbuf(value); in on_header_callback2()1374 auto promised_downstream = promised_sd->dconn->get_downstream(); in on_frame_recv_callback() local1376 assert(promised_downstream); in on_frame_recv_callback()1379 downstream, promised_downstream) != 0) { in on_frame_recv_callback()2223 auto promised_downstream = in handle_downstream_push_promise() local2225 if (!promised_downstream) { in handle_downstream_push_promise()[all …]
101 Downstream *promised_downstream) = 0;107 virtual void cancel_premature_downstream(Downstream *promised_downstream) = 0;
90 Downstream *promised_downstream);92 virtual void cancel_premature_downstream(Downstream *promised_downstream);
95 Downstream *promised_downstream);97 virtual void cancel_premature_downstream(Downstream *promised_downstream);
86 Downstream *promised_downstream);88 virtual void cancel_premature_downstream(Downstream *promised_downstream);
201 Downstream *promised_downstream);
1549 Downstream *downstream, Downstream *promised_downstream) { in on_downstream_push_promise_complete() argument1556 Downstream *promised_downstream) {} in cancel_premature_downstream() argument
1726 Downstream *downstream, Downstream *promised_downstream) { in on_downstream_push_promise_complete() argument1733 Downstream *promised_downstream) {} in cancel_premature_downstream() argument