| /third_party/grpc/src/core/lib/transport/ |
| D | transport.h | 163 struct grpc_transport_stream_op_batch { struct
164 grpc_transport_stream_op_batch() in grpc_transport_stream_op_batch() argument
414 grpc_transport_stream_op_batch* batch, grpc_error* error,
418 grpc_transport_stream_op_batch* op);
433 grpc_transport_stream_op_batch* op);
459 grpc_transport_stream_op_batch* grpc_make_transport_stream_op(
|
| D | transport.cc | 138 grpc_transport_stream_op_batch* op) {
180 grpc_transport_stream_op_batch* batch, grpc_error* error,
241 grpc_transport_stream_op_batch op;
251 grpc_transport_stream_op_batch* grpc_make_transport_stream_op(
|
| D | transport_op_string.cc | 67 grpc_transport_stream_op_batch* op) { in grpc_transport_stream_op_batch_string()
166 grpc_transport_stream_op_batch* op) { in grpc_call_log_op()
|
| D | transport_impl.h | 49 grpc_transport_stream_op_batch* op);
|
| /third_party/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.h | 72 void StartBatch(grpc_transport_stream_op_batch* batch);
105 grpc_transport_stream_op_batch batch_;
106 grpc_transport_stream_op_batch recv_message_batch_;
107 grpc_transport_stream_op_batch recv_trailing_metadata_batch_;
|
| D | health_check_client.cc | 385 grpc_transport_stream_op_batch* batch = in StartBatchInCallCombiner()
386 static_cast<grpc_transport_stream_op_batch*>(arg); in StartBatchInCallCombiner()
393 grpc_transport_stream_op_batch* batch) { in StartBatch()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 417 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
441 static size_t GetBatchIndex(grpc_transport_stream_op_batch* batch);
443 grpc_transport_stream_op_batch* batch);
487 grpc_transport_stream_op_batch* batch);
530 grpc_transport_stream_op_batch* pending_batches_[MAX_PENDING_BATCHES] = {};
549 void StartTransportStreamOpBatch(grpc_transport_stream_op_batch* batch);
587 grpc_transport_stream_op_batch batch;
664 grpc_transport_stream_op_batch* batch = nullptr;
686 static size_t GetBatchIndex(grpc_transport_stream_op_batch* batch);
687 void PendingBatchesAdd(grpc_transport_stream_op_batch* batch);
[all …]
|
| D | dynamic_filters.h | 52 void StartTransportStreamOpBatch(grpc_transport_stream_op_batch* batch);
|
| D | subchannel.h | 117 void StartTransportStreamOpBatch(grpc_transport_stream_op_batch* batch);
145 grpc_transport_stream_op_batch* batch);
|
| /third_party/grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 67 grpc_transport_stream_op_batch* batch = grpc_make_transport_stream_op( in SendCancelOpInCallCombiner()
149 grpc_deadline_state* deadline_state, grpc_transport_stream_op_batch* op) { in inject_recv_trailing_metadata_ready()
225 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in grpc_deadline_state_client_start_transport_stream_op_batch()
288 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in deadline_client_start_transport_stream_op_batch()
307 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in deadline_server_start_transport_stream_op_batch()
|
| D | deadline_filter.h | 75 grpc_call_element* elem, grpc_transport_stream_op_batch* op);
|
| /third_party/grpc/src/core/lib/security/transport/ |
| D | client_auth_filter.cc | 159 grpc_transport_stream_op_batch* batch = in on_credentials_metadata()
160 static_cast<grpc_transport_stream_op_batch*>(arg); in on_credentials_metadata()
238 grpc_transport_stream_op_batch* batch) { in send_security_metadata()
330 grpc_transport_stream_op_batch* batch = in on_host_checked()
331 static_cast<grpc_transport_stream_op_batch*>(arg); in on_host_checked()
362 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in client_auth_start_transport_stream_op_batch()
|
| D | server_auth_filter.cc | 79 grpc_transport_stream_op_batch* recv_initial_metadata_batch;
140 grpc_transport_stream_op_batch* batch = calld->recv_initial_metadata_batch; in on_md_processing_done_inner()
215 grpc_transport_stream_op_batch* batch = calld->recv_initial_metadata_batch; in recv_initial_metadata_ready()
263 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in server_auth_start_transport_stream_op_batch()
|
| /third_party/grpc/src/core/lib/channel/ |
| D | channel_stack.h | 111 grpc_transport_stream_op_batch* op);
277 grpc_transport_stream_op_batch* op);
293 grpc_transport_stream_op_batch* op);
|
| D | connected_channel.cc | 80 call_data* calld, grpc_transport_stream_op_batch* batch) { in get_state_for_batch()
103 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in connected_channel_start_transport_stream_op_batch()
|
| /third_party/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 128 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
153 grpc_transport_stream_op_batch* send_message_batch_ = nullptr;
295 grpc_transport_stream_op_batch* send_message_batch = send_message_batch_; in SendMessageBatchContinue()
435 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in CompressStartTransportStreamOpBatch()
500 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in CompressStartTransportStreamOpBatch()
|
| D | message_decompress_filter.cc | 89 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
324 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in DecompressStartTransportStreamOpBatch()
353 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in DecompressStartTransportStreamOpBatch()
|
| /third_party/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()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 228 void Op(grpc_transport_stream_op_batch* op) { in Op()
265 grpc_transport_stream_op_batch op; in BM_StreamCreateDestroy()
315 grpc_transport_stream_op_batch op; in BM_StreamCreateSendInitialMetadataDestroy()
373 grpc_transport_stream_op_batch op; in BM_TransportEmptyOp()
414 grpc_transport_stream_op_batch op; in BM_TransportStreamSend()
558 grpc_transport_stream_op_batch op; in BM_TransportStreamRecv()
|
| D | bm_call_create.cc | 349 grpc_transport_stream_op_batch* /*op*/) {} in StartTransportStreamOp() argument
416 grpc_transport_stream_op_batch* op) { in PerformStreamOp()
478 grpc_transport_stream_op_batch op_;
612 grpc_transport_stream_op_batch* op) { in StartTransportStreamOp()
|
| /third_party/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 178 op_and_state(stream_obj* s, const grpc_transport_stream_op_batch& op);
180 grpc_transport_stream_op_batch op;
200 grpc_transport_stream_op_batch* curr_op = nullptr;
322 const grpc_transport_stream_op_batch& op) in op_and_state()
329 grpc_transport_stream_op_batch* op) { in add_to_storage()
823 static bool op_can_be_run(grpc_transport_stream_op_batch* curr_op, in op_can_be_run()
1028 grpc_transport_stream_op_batch* stream_op = &oas->op; in execute_stream_op()
1437 grpc_transport_stream_op_batch* op) { in perform_stream_op()
|
| /third_party/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 251 grpc_transport_stream_op_batch* send_message_op = nullptr;
252 grpc_transport_stream_op_batch* send_trailing_md_op = nullptr;
253 grpc_transport_stream_op_batch* recv_initial_md_op = nullptr;
254 grpc_transport_stream_op_batch* recv_message_op = nullptr;
255 grpc_transport_stream_op_batch* recv_trailing_md_op = nullptr;
378 grpc_transport_stream_op_batch* op, in complete_if_batch_end_locked()
949 grpc_transport_stream_op_batch* op) { in perform_stream_op()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | server.h | 268 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
278 grpc_transport_stream_op_batch* batch);
|
| /third_party/grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 52 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in client_authority_start_transport_stream_op_batch()
|
| /third_party/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 94 grpc_transport_stream_op_batch* send_message_batch;
305 grpc_transport_stream_op_batch* batch) { in update_path_for_get()
354 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in http_client_start_transport_stream_op_batch()
|