Home
last modified time | relevance | path

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

/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 …]
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.h30 typedef struct grpc_chttp2_transport grpc_chttp2_transport; typedef
Dflow_control.cc140 void FlowControlAction::Trace(grpc_chttp2_transport* t) const { in Trace()
157 grpc_chttp2_transport* t) { in TransportFlowControlDisabled()
175 TransportFlowControl::TransportFlowControl(const grpc_chttp2_transport* t, in TransportFlowControl()
Dframe_rst_stream.h39 grpc_chttp2_transport* t,
Dframe_ping.h38 grpc_chttp2_transport* t,
Dframe_window_update.h40 grpc_chttp2_transport* t,
Dframe_settings.h56 grpc_chttp2_transport* t,
Dframe_goaway.h54 grpc_chttp2_transport* t,
Dframe_data.h70 grpc_chttp2_transport* t,
Dhpack_parser.h105 grpc_chttp2_transport* t,
Dframe_data.cc105 grpc_chttp2_transport* t = s->t; in grpc_deframe_unprocessed_incoming_frames()
290 grpc_chttp2_transport* t, in grpc_chttp2_data_parser_parse()
Dframe_rst_stream.cc75 grpc_chttp2_transport* t, in grpc_chttp2_rst_stream_parser_parse()
Dframe_ping.cc74 grpc_chttp2_transport* t, in grpc_chttp2_ping_parser_parse()
Dframe_window_update.cc70 grpc_chttp2_transport* t, in grpc_chttp2_window_update_parser_parse()
Dframe_goaway.cc58 grpc_chttp2_transport* t, in grpc_chttp2_goaway_parser_parse()
Dframe_settings.cc112 grpc_error* grpc_chttp2_settings_parser_parse(void* p, grpc_chttp2_transport* t, in grpc_chttp2_settings_parser_parse()
Dhpack_parser.cc1590 typedef void (*maybe_complete_func_type)(grpc_chttp2_transport* t,
1598 grpc_chttp2_transport* t = s->t; in force_client_rst_stream()
1609 static void parse_stream_compression_md(grpc_chttp2_transport* t, in parse_stream_compression_md()
1622 grpc_chttp2_transport* t, in grpc_chttp2_header_parser_parse()
/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()
Dbm_chttp2_transport.cc144 grpc_chttp2_transport* chttp2_transport() { in chttp2_transport()
145 return reinterpret_cast<grpc_chttp2_transport*>(t_); in chttp2_transport()
/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()