Home
last modified time | relevance | path

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

123

/external/grpc-grpc/src/core/lib/transport/
Dtransport.h124 typedef struct grpc_transport_stream_op_batch { struct
166 } grpc_transport_stream_op_batch; argument
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(
Dtransport.cc168 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(
Dtransport_op_string.cc61 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()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport.h163 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(
Dtransport.cc138 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(
Dtransport_op_string.cc67 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()
Dtransport_impl.h49 grpc_transport_stream_op_batch* op);
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.h72 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_;
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc417 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 …]
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc53 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()
Ddeadline_filter.h82 grpc_call_element* elem, grpc_transport_stream_op_batch* op);
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc67 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()
Ddeadline_filter.h75 grpc_call_element* elem, grpc_transport_stream_op_batch* op);
/external/grpc-grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc97 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()
Dserver_auth_filter.cc41 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/
Dchannel_stack.h102 grpc_transport_stream_op_batch* op);
257 grpc_transport_stream_op_batch* op);
273 grpc_transport_stream_op_batch* op);
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dchannel_stack.h111 grpc_transport_stream_op_batch* op);
277 grpc_transport_stream_op_batch* op);
293 grpc_transport_stream_op_batch* op);
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc159 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()
Dserver_auth_filter.cc79 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()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc128 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()
Dmessage_decompress_filter.cc89 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()
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.h133 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/rust/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.h133 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/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc228 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()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc838 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 …]

123