Home
last modified time | relevance | path

Searched refs:grpc_chttp2_transport (Results 1 – 25 of 25) sorted by relevance

/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dinternal.h213 Chttp2IncomingByteStream(grpc_chttp2_transport* transport,
258 grpc_chttp2_transport* transport_; // Immutable.
288 struct grpc_chttp2_transport { struct
289 grpc_chttp2_transport(const grpc_channel_args* channel_args,
292 ~grpc_chttp2_transport();
430 grpc_error* (*parser)(void* parser_user_data, grpc_chttp2_transport* t, argument
509 grpc_chttp2_stream(grpc_chttp2_transport* t, grpc_stream_refcount* refcount, argument
514 grpc_chttp2_transport* t;
685 void grpc_chttp2_initiate_write(grpc_chttp2_transport* t,
697 grpc_chttp2_transport* t);
[all …]
Dstream_lists.cc48 static bool stream_list_empty(grpc_chttp2_transport* t, in stream_list_empty()
53 static bool stream_list_pop(grpc_chttp2_transport* t, in stream_list_pop()
77 static void stream_list_remove(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in stream_list_remove()
98 static bool stream_list_maybe_remove(grpc_chttp2_transport* t, in stream_list_maybe_remove()
109 static void stream_list_add_tail(grpc_chttp2_transport* t, in stream_list_add_tail()
130 static bool stream_list_add(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in stream_list_add()
141 bool grpc_chttp2_list_add_writable_stream(grpc_chttp2_transport* t, in grpc_chttp2_list_add_writable_stream()
147 bool grpc_chttp2_list_pop_writable_stream(grpc_chttp2_transport* t, in grpc_chttp2_list_pop_writable_stream()
152 bool grpc_chttp2_list_remove_writable_stream(grpc_chttp2_transport* t, in grpc_chttp2_list_remove_writable_stream()
157 bool grpc_chttp2_list_add_writing_stream(grpc_chttp2_transport* t, in grpc_chttp2_list_add_writing_stream()
[all …]
Dchttp2_transport.cc110 static void continue_read_action_locked(grpc_chttp2_transport* t);
115 static void queue_setting_update(grpc_chttp2_transport* t,
118 static void close_from_api(grpc_chttp2_transport* t, grpc_chttp2_stream* s,
122 static void maybe_start_some_streams(grpc_chttp2_transport* t);
124 static void connectivity_state_set(grpc_chttp2_transport* t,
134 static void post_benign_reclaimer(grpc_chttp2_transport* t);
135 static void post_destructive_reclaimer(grpc_chttp2_transport* t);
137 static void close_transport_locked(grpc_chttp2_transport* t, grpc_error* error);
138 static void end_all_the_calls(grpc_chttp2_transport* t, grpc_error* error);
147 static void cancel_pings(grpc_chttp2_transport* t, grpc_error* error);
[all …]
Dparsing.cc39 static grpc_error* init_frame_parser(grpc_chttp2_transport* t);
40 static grpc_error* init_header_frame_parser(grpc_chttp2_transport* t,
42 static grpc_error* init_data_frame_parser(grpc_chttp2_transport* t);
43 static grpc_error* init_rst_stream_parser(grpc_chttp2_transport* t);
44 static grpc_error* init_settings_frame_parser(grpc_chttp2_transport* t);
45 static grpc_error* init_window_update_frame_parser(grpc_chttp2_transport* t);
46 static grpc_error* init_ping_parser(grpc_chttp2_transport* t);
47 static grpc_error* init_goaway_parser(grpc_chttp2_transport* t);
48 static grpc_error* init_skip_frame_parser(grpc_chttp2_transport* t,
51 static grpc_error* parse_frame_slice(grpc_chttp2_transport* t,
[all …]
Dwriting.cc41 static void finish_write_cb(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in finish_write_cb()
49 static void maybe_initiate_ping(grpc_chttp2_transport* t) { in maybe_initiate_ping()
135 static bool update_list(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in update_list()
156 static void report_stall(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in report_stall()
187 static uint32_t target_write_size(grpc_chttp2_transport* /*t*/) { in target_write_size() argument
201 explicit WriteContext(grpc_chttp2_transport* t) : t_(t) { in WriteContext()
297 grpc_chttp2_transport* transport() const { return t_; } in transport()
305 grpc_chttp2_transport* const t_;
318 DataSendContext(WriteContext* write_context, grpc_chttp2_transport* t, in DataSendContext()
421 grpc_chttp2_transport* t_;
[all …]
Dflow_control.h32 struct grpc_chttp2_transport;
102 void Trace(grpc_chttp2_transport* t) const;
204 explicit TransportFlowControlDisabled(grpc_chttp2_transport* t);
223 TransportFlowControl(const grpc_chttp2_transport* t, bool enable_bdp_probe);
277 const grpc_chttp2_transport* transport() const { return t_; } in transport()
312 const grpc_chttp2_transport* const t_;
Dframe.h30 typedef struct grpc_chttp2_transport grpc_chttp2_transport; typedef
Dframe_rst_stream.h39 grpc_chttp2_transport* t, uint32_t id, uint32_t code,
45 grpc_chttp2_transport* t,
Dframe_rst_stream.cc64 grpc_chttp2_transport* t, uint32_t id, uint32_t code, in grpc_chttp2_add_rst_stream_to_next_write()
84 grpc_chttp2_transport* t, in grpc_chttp2_rst_stream_parser_parse()
Dframe_window_update.h39 grpc_chttp2_transport* t,
Dframe_ping.h37 grpc_chttp2_transport* t,
Dframe_settings.h56 grpc_chttp2_transport* t,
Dframe_goaway.h53 grpc_chttp2_transport* t,
Dflow_control.cc142 void FlowControlAction::Trace(grpc_chttp2_transport* t) const { in Trace()
159 grpc_chttp2_transport* t) { in TransportFlowControlDisabled()
177 TransportFlowControl::TransportFlowControl(const grpc_chttp2_transport* t, in TransportFlowControl()
Dframe_data.h68 grpc_chttp2_transport* t,
Dhpack_parser.h112 grpc_chttp2_transport* t,
Dframe_data.cc97 grpc_chttp2_transport* t = s->t; in grpc_deframe_unprocessed_incoming_frames()
279 grpc_chttp2_transport* t, in grpc_chttp2_data_parser_parse()
Dframe_window_update.cc70 grpc_chttp2_transport* t, in grpc_chttp2_window_update_parser_parse()
Dframe_ping.cc73 grpc_chttp2_transport* t, in grpc_chttp2_ping_parser_parse()
Dframe_goaway.cc56 grpc_chttp2_transport* t, in grpc_chttp2_goaway_parser_parse()
Dframe_settings.cc113 grpc_error* grpc_chttp2_settings_parser_parse(void* p, grpc_chttp2_transport* t, in grpc_chttp2_settings_parser_parse()
Dhpack_parser.cc1666 typedef void (*maybe_complete_func_type)(grpc_chttp2_transport* t,
1674 grpc_chttp2_transport* t = s->t; in force_client_rst_stream()
1684 static void parse_stream_compression_md(grpc_chttp2_transport* /*t*/, in parse_stream_compression_md() argument
1703 grpc_chttp2_transport* t, in grpc_chttp2_header_parser_parse()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_fullstack_trickle.cc134 grpc_chttp2_transport* client = in Log()
135 reinterpret_cast<grpc_chttp2_transport*>(client_transport_); in Log()
136 grpc_chttp2_transport* server = in Log()
137 reinterpret_cast<grpc_chttp2_transport*>(server_transport_); in Log()
197 UpdateStats((grpc_chttp2_transport*)client_transport_, &client_stats_, in Step()
199 UpdateStats((grpc_chttp2_transport*)server_transport_, &server_stats_, in Step()
226 void UpdateStats(grpc_chttp2_transport* t, Stats* s, in UpdateStats()
Dbm_chttp2_transport.cc146 grpc_chttp2_transport* chttp2_transport() { in chttp2_transport()
147 return reinterpret_cast<grpc_chttp2_transport*>(t_); in chttp2_transport()
/third_party/grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc148 grpc_chttp2_transport* transport_ = nullptr;
291 reinterpret_cast<grpc_chttp2_transport*>(transport); in OnHandshakeDone()
300 reinterpret_cast<grpc_chttp2_transport*>(transport), in OnHandshakeDone()