Home
last modified time | relevance | path

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

12

/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dinternal.h210 Chttp2IncomingByteStream(grpc_chttp2_transport* transport,
251 grpc_chttp2_transport* transport_; // Immutable.
281 struct grpc_chttp2_transport { struct
422 grpc_error* (*parser)(void* parser_user_data, grpc_chttp2_transport* t, argument
484 grpc_chttp2_transport* t; argument
629 void grpc_chttp2_initiate_write(grpc_chttp2_transport* t,
642 grpc_chttp2_transport* t);
643 void grpc_chttp2_end_write(grpc_chttp2_transport* t, grpc_error* error);
647 grpc_error* grpc_chttp2_perform_read(grpc_chttp2_transport* t,
650 bool grpc_chttp2_list_add_writable_stream(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.cc108 static void queue_setting_update(grpc_chttp2_transport* t,
111 static void close_from_api(grpc_chttp2_transport* t, grpc_chttp2_stream* s,
115 static void maybe_start_some_streams(grpc_chttp2_transport* t);
117 static void connectivity_state_set(grpc_chttp2_transport* t,
124 static void post_benign_reclaimer(grpc_chttp2_transport* t);
125 static void post_destructive_reclaimer(grpc_chttp2_transport* t);
127 static void close_transport_locked(grpc_chttp2_transport* t, grpc_error* error);
128 static void end_all_the_calls(grpc_chttp2_transport* t, grpc_error* error);
130 static void schedule_bdp_ping_locked(grpc_chttp2_transport* t);
135 static void cancel_pings(grpc_chttp2_transport* t, grpc_error* error);
[all …]
Dparsing.cc36 static grpc_error* init_frame_parser(grpc_chttp2_transport* t);
37 static grpc_error* init_header_frame_parser(grpc_chttp2_transport* t,
39 static grpc_error* init_data_frame_parser(grpc_chttp2_transport* t);
40 static grpc_error* init_rst_stream_parser(grpc_chttp2_transport* t);
41 static grpc_error* init_settings_frame_parser(grpc_chttp2_transport* t);
42 static grpc_error* init_window_update_frame_parser(grpc_chttp2_transport* t);
43 static grpc_error* init_ping_parser(grpc_chttp2_transport* t);
44 static grpc_error* init_goaway_parser(grpc_chttp2_transport* t);
45 static grpc_error* init_skip_frame_parser(grpc_chttp2_transport* t,
48 static grpc_error* parse_frame_slice(grpc_chttp2_transport* t, grpc_slice slice,
[all …]
Dwriting.cc38 static void finish_write_cb(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in finish_write_cb()
46 static void maybe_initiate_ping(grpc_chttp2_transport* t) { in maybe_initiate_ping()
119 static bool update_list(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in update_list()
140 static void report_stall(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in report_stall()
175 static uint32_t target_write_size(grpc_chttp2_transport* t) { in target_write_size()
189 WriteContext(grpc_chttp2_transport* t) : t_(t) { in WriteContext()
293 grpc_chttp2_transport* transport() const { return t_; } in transport()
301 grpc_chttp2_transport* const t_;
314 DataSendContext(WriteContext* write_context, grpc_chttp2_transport* t, in DataSendContext()
398 grpc_chttp2_transport* t_;
[all …]
Dframe.h30 typedef struct grpc_chttp2_transport grpc_chttp2_transport; typedef
Dflow_control.h33 struct grpc_chttp2_transport;
103 void Trace(grpc_chttp2_transport* t) const;
208 TransportFlowControlDisabled(grpc_chttp2_transport* t);
227 TransportFlowControl(const grpc_chttp2_transport* t, bool enable_bdp_probe);
281 const grpc_chttp2_transport* transport() const { return t_; } in transport()
320 const grpc_chttp2_transport* const t_;
Dframe_rst_stream.h39 grpc_chttp2_transport* t,
Dframe_window_update.h40 grpc_chttp2_transport* t,
Dframe_ping.h38 grpc_chttp2_transport* t,
Dframe_settings.h56 grpc_chttp2_transport* t,
/external/rust/crates/grpcio-sys/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 …]
Dframe.h30 typedef struct grpc_chttp2_transport grpc_chttp2_transport; typedef
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_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_ping.h37 grpc_chttp2_transport* t,
Dframe_window_update.h39 grpc_chttp2_transport* t,
Dframe_settings.h56 grpc_chttp2_transport* t,
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_fullstack_trickle.cc133 grpc_chttp2_transport* client = in Log()
134 reinterpret_cast<grpc_chttp2_transport*>(client_transport_); in Log()
135 grpc_chttp2_transport* server = in Log()
136 reinterpret_cast<grpc_chttp2_transport*>(server_transport_); in Log()
196 UpdateStats((grpc_chttp2_transport*)client_transport_, &client_stats_, in Step()
198 UpdateStats((grpc_chttp2_transport*)server_transport_, &server_stats_, in Step()
225 void UpdateStats(grpc_chttp2_transport* t, Stats* s, in UpdateStats()
/external/grpc-grpc/src/core/ext/transport/chttp2/server/
Dchttp2_server.cc65 grpc_chttp2_transport* transport;
140 reinterpret_cast<grpc_chttp2_transport*>(transport); in on_handshake_done()
149 GRPC_CHTTP2_REF_TRANSPORT((grpc_chttp2_transport*)transport, in on_handshake_done()

12