| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.h | 124 typedef struct grpc_transport_stream_op_batch { struct
166 } grpc_transport_stream_op_batch; typedef
331 grpc_transport_stream_op_batch* op, grpc_error* error,
334 char* grpc_transport_stream_op_batch_string(grpc_transport_stream_op_batch* op);
349 grpc_transport_stream_op_batch* op);
375 grpc_transport_stream_op_batch* grpc_make_transport_stream_op(
|
| D | transport.cc | 168 grpc_transport_stream_op_batch* op) {
210 grpc_transport_stream_op_batch* batch, grpc_error* error,
269 grpc_transport_stream_op_batch op;
280 grpc_transport_stream_op_batch* grpc_make_transport_stream_op(
|
| D | transport_op_string.cc | 61 grpc_transport_stream_op_batch* op) { in grpc_transport_stream_op_batch_string()
203 grpc_transport_stream_op_batch* op) { in grpc_call_log_op()
|
| D | transport_impl.h | 49 grpc_transport_stream_op_batch* op);
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 53 grpc_transport_stream_op_batch* batch = grpc_make_transport_stream_op( in send_cancel_op_in_call_combiner()
142 grpc_deadline_state* deadline_state, grpc_transport_stream_op_batch* op) { in inject_recv_trailing_metadata_ready()
224 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in grpc_deadline_state_client_start_transport_stream_op_batch()
286 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in client_start_transport_stream_op_batch()
304 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in server_start_transport_stream_op_batch()
|
| D | deadline_filter.h | 82 grpc_call_element* elem, grpc_transport_stream_op_batch* op);
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | client_auth_filter.cc | 97 grpc_transport_stream_op_batch* batch = in on_credentials_metadata()
98 static_cast<grpc_transport_stream_op_batch*>(arg); in on_credentials_metadata()
173 grpc_transport_stream_op_batch* batch) { in send_security_metadata()
233 grpc_transport_stream_op_batch* batch = in on_host_checked()
234 static_cast<grpc_transport_stream_op_batch*>(arg); in on_host_checked()
269 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in auth_start_transport_stream_op_batch()
|
| D | server_auth_filter.cc | 41 grpc_transport_stream_op_batch* recv_initial_metadata_batch;
103 grpc_transport_stream_op_batch* batch = calld->recv_initial_metadata_batch; in on_md_processing_done_inner()
169 grpc_transport_stream_op_batch* batch = calld->recv_initial_metadata_batch; in recv_initial_metadata_ready()
199 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in auth_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | channel_stack.h | 102 grpc_transport_stream_op_batch* op);
257 grpc_transport_stream_op_batch* op);
273 grpc_transport_stream_op_batch* op);
|
| D | connected_channel.cc | 81 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch()
101 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in con_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | channel_filter.h | 133 explicit TransportStreamOpBatch(grpc_transport_stream_op_batch* op) in TransportStreamOpBatch()
152 grpc_transport_stream_op_batch* op() const { return op_; } in op()
223 grpc_transport_stream_op_batch* op_; // Not owned.
338 grpc_transport_stream_op_batch* op) { in StartTransportStreamOpBatch()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 838 grpc_transport_stream_op_batch batch;
898 grpc_transport_stream_op_batch* batch;
1003 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
1015 grpc_transport_stream_op_batch* batch = pending->batch; in maybe_cache_send_ops_for_batch()
1131 static size_t get_batch_index(grpc_transport_stream_op_batch* batch) { in get_batch_index()
1145 grpc_transport_stream_op_batch* batch) { in pending_batches_add()
1221 grpc_transport_stream_op_batch* batch = in fail_pending_batch_in_call_combiner()
1222 static_cast<grpc_transport_stream_op_batch*>(arg); in fail_pending_batch_in_call_combiner()
1248 grpc_transport_stream_op_batch* batch = pending->batch; in pending_batches_fail()
1270 grpc_transport_stream_op_batch* batch = in resume_pending_batch_in_call_combiner()
[all …]
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 228 void Op(grpc_transport_stream_op_batch* op) { in Op()
264 grpc_transport_stream_op_batch op; in BM_StreamCreateDestroy()
310 grpc_transport_stream_op_batch op; in BM_StreamCreateSendInitialMetadataDestroy()
362 grpc_transport_stream_op_batch op; in BM_TransportEmptyOp()
395 grpc_transport_stream_op_batch op; in BM_TransportStreamSend()
531 grpc_transport_stream_op_batch op; in BM_TransportStreamRecv()
|
| D | bm_call_create.cc | 365 grpc_transport_stream_op_batch* op) {} in StartTransportStreamOp()
432 grpc_transport_stream_op_batch* op) { in PerformStreamOp()
494 grpc_transport_stream_op_batch op_;
625 grpc_transport_stream_op_batch* op) { in StartTransportStreamOp()
|
| /external/grpc-grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 64 grpc_transport_stream_op_batch* send_message_batch;
213 grpc_transport_stream_op_batch* send_message_batch = in send_message_batch_continue()
351 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in compress_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 96 grpc_transport_stream_op_batch* send_message_op;
97 grpc_transport_stream_op_batch* send_trailing_md_op;
98 grpc_transport_stream_op_batch* recv_initial_md_op;
99 grpc_transport_stream_op_batch* recv_message_op;
100 grpc_transport_stream_op_batch* recv_trailing_md_op;
371 grpc_transport_stream_op_batch* op, in complete_if_batch_end_locked()
906 grpc_transport_stream_op_batch* op) { in perform_stream_op()
|
| /external/grpc-grpc/test/core/channel/ |
| D | channel_stack_builder_test.cc | 49 grpc_transport_stream_op_batch* op) {} in call_func()
|
| D | channel_stack_test.cc | 58 grpc_transport_stream_op_batch* op) { in call_func()
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 62 grpc_transport_stream_op_batch* send_message_batch;
255 grpc_transport_stream_op_batch* batch) { in update_path_for_get()
304 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in hc_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 164 grpc_transport_stream_op_batch op;
179 grpc_transport_stream_op_batch* curr_op;
313 grpc_transport_stream_op_batch* op) { in add_to_storage()
319 memcpy(&new_op->op, op, sizeof(grpc_transport_stream_op_batch)); in add_to_storage()
805 static bool op_can_be_run(grpc_transport_stream_op_batch* curr_op, in op_can_be_run()
993 grpc_transport_stream_op_batch* stream_op = &oas->op; in execute_stream_op()
1397 grpc_transport_stream_op_batch* op) { in perform_stream_op()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 103 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 51 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in authority_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 100 grpc_transport_stream_op_batch op;
246 static void execute_batch(grpc_call* call, grpc_transport_stream_op_batch* op,
594 grpc_transport_stream_op_batch* batch = in execute_batch_in_call_combiner()
595 static_cast<grpc_transport_stream_op_batch*>(arg); in execute_batch_in_call_combiner()
605 grpc_transport_stream_op_batch* batch, in execute_batch()
675 grpc_transport_stream_op_batch* op = in cancel_with_error()
1485 grpc_transport_stream_op_batch* stream_op; in call_start_batch()
|
| /external/grpc-grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 79 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 341 grpc_transport_stream_op_batch* op) { in hs_mutate_op()
401 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in hs_start_transport_stream_op_batch()
|