Home
last modified time | relevance | path

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

123

/external/grpc-grpc/src/core/client_channel/
Dretry_filter_legacy_call_data.h65 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
74 grpc_transport_stream_op_batch* batch = nullptr;
97 void CancelFromSurface(grpc_transport_stream_op_batch* cancel_batch);
112 grpc_transport_stream_op_batch* batch() { return &batch_; } in batch()
193 grpc_transport_stream_op_batch batch_;
213 void AddClosureForBatch(grpc_transport_stream_op_batch* batch,
327 void StartTransportStreamOpBatch(grpc_transport_stream_op_batch* batch);
330 static size_t GetBatchIndex(grpc_transport_stream_op_batch* batch);
331 PendingBatch* PendingBatchesAdd(grpc_transport_stream_op_batch* batch);
Dsubchannel_stream_client.h129 void StartBatch(grpc_transport_stream_op_batch* batch);
159 grpc_transport_stream_op_batch batch_;
160 grpc_transport_stream_op_batch recv_message_batch_;
161 grpc_transport_stream_op_batch recv_trailing_metadata_batch_;
Dretry_filter_legacy_call_data.cc311 grpc_transport_stream_op_batch* batch = in StartBatchInCallCombiner()
312 static_cast<grpc_transport_stream_op_batch*>(arg); in StartBatchInCallCombiner()
323 grpc_transport_stream_op_batch* batch, const char* reason, in AddClosureForBatch()
371 grpc_transport_stream_op_batch* batch = pending->batch; in AddBatchesForPendingBatches()
548 grpc_transport_stream_op_batch* cancel_batch) { in CancelFromSurface()
805 [](grpc_transport_stream_op_batch* batch) { in MaybeAddClosureForRecvInitialMetadataCallback()
908 [](grpc_transport_stream_op_batch* batch) { in MaybeAddClosureForRecvMessageCallback()
1035 [](grpc_transport_stream_op_batch* batch) { in MaybeAddClosureForRecvTrailingMetadataReady()
1235 "completed", [this](grpc_transport_stream_op_batch* batch) { in AddClosuresForCompletedPendingBatch()
1270 grpc_transport_stream_op_batch* batch = pending->batch; in AddClosuresForReplayOrPendingSendOps()
[all …]
Dclient_channel_filter.cc203 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
231 static size_t GetBatchIndex(grpc_transport_stream_op_batch* batch);
232 void PendingBatchesAdd(grpc_transport_stream_op_batch* batch);
308 grpc_transport_stream_op_batch* pending_batches_[MAX_PENDING_BATCHES] = {};
525 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in StartTransportStreamOpBatch()
2255 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in StartTransportStreamOpBatch()
2369 grpc_transport_stream_op_batch* batch) { in GetBatchIndex()
2383 grpc_transport_stream_op_batch* batch) { in PendingBatchesAdd()
2390 grpc_transport_stream_op_batch*& pending = pending_batches_[idx]; in PendingBatchesAdd()
2398 grpc_transport_stream_op_batch* batch = in FailPendingBatchInCallCombiner()
[all …]
Dclient_channel_filter.h492 void StartTransportStreamOpBatch(grpc_transport_stream_op_batch* batch);
514 static size_t GetBatchIndex(grpc_transport_stream_op_batch* batch);
515 void PendingBatchesAdd(grpc_transport_stream_op_batch* batch);
596 grpc_transport_stream_op_batch* pending_batches_[MAX_PENDING_BATCHES] = {};
/external/grpc-grpc/test/core/transport/binder/
Dbinder_transport_test.cc71 grpc_transport_stream_op_batch* op) { in PerformStreamOp()
219 grpc_transport_stream_op_batch* op) { in MakeSendInitialMetadata()
248 grpc_transport_stream_op_batch* op) { in MakeSendMessage()
260 grpc_transport_stream_op_batch* op) { in MakeSendTrailingMetadata()
278 explicit MakeRecvInitialMetadata(grpc_transport_stream_op_batch* op, in MakeRecvInitialMetadata()
307 explicit MakeRecvMessage(grpc_transport_stream_op_batch* op, in MakeRecvMessage()
326 explicit MakeRecvTrailingMetadata(grpc_transport_stream_op_batch* op, in MakeRecvTrailingMetadata()
398 grpc_transport_stream_op_batch op{}; in TEST_F()
418 grpc_transport_stream_op_batch op{}; in TEST_F()
441 grpc_transport_stream_op_batch op{}; in TEST_F()
[all …]
/external/grpc-grpc/src/core/lib/transport/
Dtransport.h258 struct grpc_transport_stream_op_batch { struct
259 grpc_transport_stream_op_batch() in grpc_transport_stream_op_batch() function
486 grpc_transport_stream_op_batch* batch, grpc_error_handle error,
489 grpc_transport_stream_op_batch* batch, grpc_error_handle error,
494 grpc_transport_stream_op_batch* batch, grpc_error_handle error);
497 grpc_transport_stream_op_batch* op, bool truncate);
527 grpc_transport_stream_op_batch* op) = 0;
613 grpc_transport_stream_op_batch* grpc_make_transport_stream_op(
Dtransport.cc112 grpc_transport_stream_op_batch* batch, grpc_error_handle error,
122 grpc_transport_stream_op_batch* batch, grpc_error_handle error,
145 grpc_transport_stream_op_batch* batch, grpc_error_handle error) {
195 grpc_transport_stream_op_batch op;
208 grpc_transport_stream_op_batch* grpc_make_transport_stream_op(
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport.h349 struct grpc_transport_stream_op_batch {
350 grpc_transport_stream_op_batch()
597 grpc_transport_stream_op_batch* batch, grpc_error_handle error,
600 grpc_transport_stream_op_batch* batch, grpc_error_handle error,
605 grpc_transport_stream_op_batch* batch, grpc_error_handle error);
608 grpc_transport_stream_op_batch* op, bool truncate);
623 grpc_transport_stream_op_batch* op);
649 grpc_transport_stream_op_batch* grpc_make_transport_stream_op(
Dtransport.cc124 grpc_transport_stream_op_batch* op) {
166 grpc_transport_stream_op_batch* batch, grpc_error_handle error,
176 grpc_transport_stream_op_batch* batch, grpc_error_handle error,
199 grpc_transport_stream_op_batch* batch, grpc_error_handle error) {
249 grpc_transport_stream_op_batch op;
262 grpc_transport_stream_op_batch* grpc_make_transport_stream_op(
Dtransport_op_string.cc44 grpc_transport_stream_op_batch* op, bool truncate) { in grpc_transport_stream_op_batch_string()
155 grpc_transport_stream_op_batch* op) { in grpc_call_log_op()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dsubchannel_stream_client.h129 void StartBatch(grpc_transport_stream_op_batch* batch);
159 grpc_transport_stream_op_batch batch_;
160 grpc_transport_stream_op_batch recv_message_batch_;
161 grpc_transport_stream_op_batch recv_trailing_metadata_batch_;
Dretry_filter.cc235 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
244 grpc_transport_stream_op_batch* batch = nullptr;
266 void CancelFromSurface(grpc_transport_stream_op_batch* cancel_batch);
281 grpc_transport_stream_op_batch* batch() { return &batch_; } in batch()
362 grpc_transport_stream_op_batch batch_;
382 void AddClosureForBatch(grpc_transport_stream_op_batch* batch,
495 void StartTransportStreamOpBatch(grpc_transport_stream_op_batch* batch);
498 static size_t GetBatchIndex(grpc_transport_stream_op_batch* batch);
499 PendingBatch* PendingBatchesAdd(grpc_transport_stream_op_batch* batch);
857 grpc_transport_stream_op_batch* batch = in StartBatchInCallCombiner()
[all …]
Dclient_channel.cc187 grpc_call_element* elem, grpc_transport_stream_op_batch* batch);
215 static size_t GetBatchIndex(grpc_transport_stream_op_batch* batch);
216 void PendingBatchesAdd(grpc_transport_stream_op_batch* batch);
292 grpc_transport_stream_op_batch* pending_batches_[MAX_PENDING_BATCHES] = {};
382 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in StartTransportStreamOpBatch()
1986 grpc_call_element* elem, grpc_transport_stream_op_batch* batch) { in StartTransportStreamOpBatch()
2100 grpc_transport_stream_op_batch* batch) { in GetBatchIndex()
2114 grpc_transport_stream_op_batch* batch) { in PendingBatchesAdd()
2121 grpc_transport_stream_op_batch*& pending = pending_batches_[idx]; in PendingBatchesAdd()
2129 grpc_transport_stream_op_batch* batch = in FailPendingBatchInCallCombiner()
[all …]
Dclient_channel.h481 void StartTransportStreamOpBatch(grpc_transport_stream_op_batch* batch);
506 static size_t GetBatchIndex(grpc_transport_stream_op_batch* batch);
507 void PendingBatchesAdd(grpc_transport_stream_op_batch* batch);
590 grpc_transport_stream_op_batch* pending_batches_[MAX_PENDING_BATCHES] = {};
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/channel/
Dpromise_based_filter.h194 virtual void StartBatch(grpc_transport_stream_op_batch* batch) = 0;
224 void Resume(grpc_transport_stream_op_batch* batch) { in Resume()
233 void Cancel(grpc_transport_stream_op_batch* batch, in Cancel()
239 void Complete(grpc_transport_stream_op_batch* batch) { in Complete()
252 absl::InlinedVector<grpc_transport_stream_op_batch*, 1> release_;
264 explicit CapturedBatch(grpc_transport_stream_op_batch* batch);
271 grpc_transport_stream_op_batch* operator->() { return batch_; }
285 grpc_transport_stream_op_batch* batch_;
579 void StartBatch(grpc_transport_stream_op_batch* batch) override;
692 void StartBatch(grpc_transport_stream_op_batch* batch) override;
[all …]
Dchannel_stack.h118 grpc_transport_stream_op_batch* op);
364 grpc_transport_stream_op_batch* op);
380 grpc_transport_stream_op_batch* op);
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc78 grpc_transport_stream_op_batch* batch = grpc_make_transport_stream_op( in SendCancelOpInCallCombiner()
157 grpc_deadline_state* deadline_state, grpc_transport_stream_op_batch* op) { in inject_recv_trailing_metadata_ready()
233 grpc_deadline_state* deadline_state, grpc_transport_stream_op_batch* op) { in grpc_deadline_state_client_start_transport_stream_op_batch()
289 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in deadline_client_start_transport_stream_op_batch()
311 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in deadline_server_start_transport_stream_op_batch()
Ddeadline_filter.h78 grpc_deadline_state* deadline_state, grpc_transport_stream_op_batch* op);
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc75 grpc_transport_stream_op_batch* batch = grpc_make_transport_stream_op( in SendCancelOpInCallCombiner()
154 grpc_deadline_state* deadline_state, grpc_transport_stream_op_batch* op) { in inject_recv_trailing_metadata_ready()
230 grpc_deadline_state* deadline_state, 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 deadline_client_start_transport_stream_op_batch()
308 grpc_call_element* elem, grpc_transport_stream_op_batch* op) { in deadline_server_start_transport_stream_op_batch()
Ddeadline_filter.h77 grpc_deadline_state* deadline_state, grpc_transport_stream_op_batch* op);
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.h103 explicit TransportStreamOpBatch(grpc_transport_stream_op_batch* op) in TransportStreamOpBatch()
122 grpc_transport_stream_op_batch* op() const { return op_; } in op()
174 grpc_transport_stream_op_batch* op_; // Not owned.
289 grpc_transport_stream_op_batch* op) { in StartTransportStreamOpBatch()
/external/grpc-grpc/src/core/lib/channel/
Dchannel_stack.h110 grpc_transport_stream_op_batch* op);
369 grpc_transport_stream_op_batch* op);
385 grpc_transport_stream_op_batch* op);
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc230 void Op(grpc_transport_stream_op_batch* op) { in Op()
269 grpc_transport_stream_op_batch op; in BM_StreamCreateDestroy()
321 grpc_transport_stream_op_batch op; in BM_StreamCreateSendInitialMetadataDestroy()
374 grpc_transport_stream_op_batch op; in BM_TransportEmptyOp()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dlegacy_inproc_transport.cc88 void ResetSendMessage(grpc_transport_stream_op_batch* batch) { in ResetSendMessage()
146 grpc_transport_stream_op_batch* op) override;
290 grpc_transport_stream_op_batch* send_message_op = nullptr;
291 grpc_transport_stream_op_batch* send_trailing_md_op = nullptr;
292 grpc_transport_stream_op_batch* recv_initial_md_op = nullptr;
293 grpc_transport_stream_op_batch* recv_message_op = nullptr;
294 grpc_transport_stream_op_batch* recv_trailing_md_op = nullptr;
426 grpc_transport_stream_op_batch* op, in complete_if_batch_end_locked()
947 grpc_transport_stream_op_batch* op) { in PerformStreamOp()

123