| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | internal.h | 172 grpc_chttp2_stream* head;
173 grpc_chttp2_stream* tail;
177 grpc_chttp2_stream* next;
178 grpc_chttp2_stream* prev;
211 grpc_chttp2_stream* stream, uint32_t frame_size,
252 grpc_chttp2_stream* stream_; // Immutable.
326 grpc_chttp2_stream** accepting_stream;
421 grpc_chttp2_stream* incoming_stream;
423 grpc_chttp2_stream* s, grpc_slice slice, int is_last);
483 struct grpc_chttp2_stream { struct
[all …]
|
| D | stream_lists.cc | 54 grpc_chttp2_stream** stream, in stream_list_pop()
56 grpc_chttp2_stream* s = t->lists[id].head; in stream_list_pop()
58 grpc_chttp2_stream* new_head = s->links[id].next; in stream_list_pop()
77 static void stream_list_remove(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in stream_list_remove()
99 grpc_chttp2_stream* s, in stream_list_maybe_remove()
110 grpc_chttp2_stream* s, in stream_list_add_tail()
112 grpc_chttp2_stream* old_tail; in stream_list_add_tail()
130 static bool stream_list_add(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in stream_list_add()
142 grpc_chttp2_stream* s) { in grpc_chttp2_list_add_writable_stream()
148 grpc_chttp2_stream** s) { in grpc_chttp2_list_pop_writable_stream()
[all …]
|
| D | writing.cc | 38 static void finish_write_cb(grpc_chttp2_transport* t, grpc_chttp2_stream* s, in finish_write_cb()
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()
252 grpc_chttp2_stream* s; in UpdateStreamsNoLongerStalled()
263 grpc_chttp2_stream* NextStream() { in NextStream()
269 grpc_chttp2_stream* s; in NextStream()
315 grpc_chttp2_stream* s) in DataSendContext()
399 grpc_chttp2_stream* s_;
406 StreamWriteContext(WriteContext* write_context, grpc_chttp2_stream* s) in StreamWriteContext()
584 grpc_chttp2_stream* const s_;
[all …]
|
| D | chttp2_transport.cc | 111 static void close_from_api(grpc_chttp2_transport* t, grpc_chttp2_stream* s,
636 grpc_chttp2_stream* s; in close_transport_locked()
651 void grpc_chttp2_stream_ref(grpc_chttp2_stream* s, const char* reason) { in grpc_chttp2_stream_ref()
654 void grpc_chttp2_stream_unref(grpc_chttp2_stream* s, const char* reason) { in grpc_chttp2_stream_unref()
658 void grpc_chttp2_stream_ref(grpc_chttp2_stream* s) { in grpc_chttp2_stream_ref()
661 void grpc_chttp2_stream_unref(grpc_chttp2_stream* s) { in grpc_chttp2_stream_unref()
671 grpc_chttp2_stream* s = reinterpret_cast<grpc_chttp2_stream*>(gs); in init_stream()
720 grpc_chttp2_stream* s = static_cast<grpc_chttp2_stream*>(sp); in destroy_stream_locked()
769 grpc_chttp2_stream* s = reinterpret_cast<grpc_chttp2_stream*>(gs); in destroy_stream()
787 grpc_chttp2_stream* grpc_chttp2_parsing_lookup_stream(grpc_chttp2_transport* t, in grpc_chttp2_parsing_lookup_stream()
[all …]
|
| D | frame_data.h | 65 grpc_chttp2_stream* s);
71 grpc_chttp2_stream* s,
80 grpc_chttp2_data_parser* p, grpc_chttp2_stream* s,
|
| D | frame.h | 29 typedef struct grpc_chttp2_stream grpc_chttp2_stream; typedef
|
| D | parsing.cc | 315 grpc_chttp2_stream* s, grpc_slice slice, in skip_parser()
343 grpc_chttp2_stream* s = in init_data_frame_parser()
399 grpc_chttp2_stream* s = t->incoming_stream; in on_initial_header()
481 grpc_chttp2_stream* s = t->incoming_stream; in on_trailing_header()
534 grpc_chttp2_stream* s; in init_header_frame_parser()
653 grpc_chttp2_stream* s = t->incoming_stream = in init_window_update_frame_parser()
678 grpc_chttp2_stream* s = t->incoming_stream = in init_rst_stream_parser()
726 grpc_chttp2_stream* s = t->incoming_stream; in parse_frame_slice()
|
| D | flow_control.h | 34 struct grpc_chttp2_stream;
421 StreamFlowControl(TransportFlowControl* tfc, const grpc_chttp2_stream* s);
460 const grpc_chttp2_stream* stream() const { return s_; } in stream()
470 const grpc_chttp2_stream* const s_;
|
| D | frame_data.cc | 52 grpc_chttp2_stream* s) { in grpc_chttp2_data_parser_begin_frame()
101 grpc_chttp2_data_parser* p, grpc_chttp2_stream* s, in grpc_deframe_unprocessed_incoming_frames()
291 grpc_chttp2_stream* s, in grpc_chttp2_data_parser_parse()
|
| D | frame_rst_stream.h | 40 grpc_chttp2_stream* s,
|
| D | frame_ping.h | 39 grpc_chttp2_stream* s,
|
| D | frame_window_update.h | 41 grpc_chttp2_stream* s,
|
| D | frame_settings.h | 57 grpc_chttp2_stream* s,
|
| D | frame_goaway.h | 55 grpc_chttp2_stream* s,
|
| D | hpack_parser.h | 106 grpc_chttp2_stream* s,
|
| D | frame_rst_stream.cc | 76 grpc_chttp2_stream* s, in grpc_chttp2_rst_stream_parser_parse()
|
| D | frame_ping.cc | 75 grpc_chttp2_stream* s, in grpc_chttp2_ping_parser_parse()
|
| D | frame_window_update.cc | 71 grpc_chttp2_stream* s, in grpc_chttp2_window_update_parser_parse()
|
| D | frame_goaway.cc | 59 grpc_chttp2_stream* s, in grpc_chttp2_goaway_parser_parse()
|
| D | hpack_parser.cc | 1591 grpc_chttp2_stream* s);
1597 grpc_chttp2_stream* s = static_cast<grpc_chttp2_stream*>(sp); in force_client_rst_stream()
1610 grpc_chttp2_stream* s, in parse_stream_compression_md()
1623 grpc_chttp2_stream* s, in grpc_chttp2_header_parser_parse()
|
| D | frame_settings.cc | 113 grpc_chttp2_stream* s, in grpc_chttp2_settings_parser_parse()
|
| D | flow_control.cc | 219 const grpc_chttp2_stream* s) in StreamFlowControl()
|
| /external/grpc-grpc/test/core/util/ |
| D | debugger_macros.cc | 56 grpc_chttp2_stream* grpc_chttp2_stream_from_call(grpc_call* call) { in grpc_chttp2_stream_from_call()
57 return reinterpret_cast<grpc_chttp2_stream*>( in grpc_chttp2_stream_from_call()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_trickle.cc | 137 grpc_chttp2_stream* client_stream = in Log()
139 ? static_cast<grpc_chttp2_stream*>(client->stream_map.values[0]) in Log()
141 grpc_chttp2_stream* server_stream = in Log()
143 ? static_cast<grpc_chttp2_stream*>(server->stream_map.values[0]) in Log()
|
| D | bm_chttp2_transport.cc | 233 grpc_chttp2_stream* chttp2_stream() { in chttp2_stream()
234 return static_cast<grpc_chttp2_stream*>(stream_); in chttp2_stream()
|