Home
last modified time | relevance | path

Searched refs:on_complete (Results 1 – 25 of 53) sorted by relevance

123

/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc51 callback_state on_complete[6]; // Max number of pending batches. member
82 if (batch->send_initial_metadata) return &calld->on_complete[0]; in get_state_for_batch()
83 if (batch->send_message) return &calld->on_complete[1]; in get_state_for_batch()
84 if (batch->send_trailing_metadata) return &calld->on_complete[2]; in get_state_for_batch()
85 if (batch->recv_initial_metadata) return &calld->on_complete[3]; in get_state_for_batch()
86 if (batch->recv_message) return &calld->on_complete[4]; in get_state_for_batch()
87 if (batch->recv_trailing_metadata) return &calld->on_complete[5]; in get_state_for_batch()
130 &batch->on_complete); in con_start_transport_stream_op_batch()
131 } else if (batch->on_complete != nullptr) { in con_start_transport_stream_op_batch()
133 intercept_callback(calld, state, false, "on_complete", &batch->on_complete); in con_start_transport_stream_op_batch()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dconnected_channel.cc50 callback_state on_complete[6]; // Max number of pending batches. member
81 if (batch->send_initial_metadata) return &calld->on_complete[0]; in get_state_for_batch()
82 if (batch->send_message) return &calld->on_complete[1]; in get_state_for_batch()
83 if (batch->send_trailing_metadata) return &calld->on_complete[2]; in get_state_for_batch()
84 if (batch->recv_initial_metadata) return &calld->on_complete[3]; in get_state_for_batch()
85 if (batch->recv_message) return &calld->on_complete[4]; in get_state_for_batch()
86 if (batch->recv_trailing_metadata) return &calld->on_complete[5]; in get_state_for_batch()
132 &batch->on_complete); in connected_channel_start_transport_stream_op_batch()
133 } else if (batch->on_complete != nullptr) { in connected_channel_start_transport_stream_op_batch()
135 intercept_callback(calld, state, false, "on_complete", &batch->on_complete); in connected_channel_start_transport_stream_op_batch()
/external/grpc-grpc/src/core/lib/http/
Dhttpcli.h87 grpc_closure* on_complete,
109 grpc_millis deadline, grpc_closure* on_complete,
115 grpc_closure* on_complete,
121 grpc_closure* on_complete,
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport.cc204 if (batch->on_complete != nullptr) {
205 closures.Add(batch->on_complete, GRPC_ERROR_REF(error),
229 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_complete) { argument
233 op->inner_on_complete = on_complete;
252 grpc_closure* on_complete) { argument
258 op->inner_on_complete = on_complete;
259 op->op.on_complete = &op->outer_on_complete;
Dbyte_stream.h53 virtual bool Next(size_t max_size_hint, grpc_closure* on_complete) = 0;
99 bool Next(size_t max_size_hint, grpc_closure* on_complete) override;
133 bool Next(size_t max_size_hint, grpc_closure* on_complete) override;
Dtransport.h183 grpc_closure* on_complete = nullptr; member
455 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_complete);
460 grpc_closure* on_complete);
Dbyte_stream.cc113 grpc_closure* on_complete) { in Next() argument
117 return cache_->underlying_stream_->Next(max_size_hint, on_complete); in Next()
/external/grpc-grpc/test/core/client_channel/resolvers/
Ddns_resolver_connectivity_test.cc120 grpc_closure* on_complete; member
126 a->resolver->NextLocked(a->result, a->on_complete); in call_resolver_next_now_lock_taken()
132 grpc_closure* on_complete, in call_resolver_next_after_locking() argument
137 a->on_complete = on_complete; in call_resolver_next_after_locking()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.cc234 if (batch->on_complete != nullptr) {
235 closures.Add(batch->on_complete, GRPC_ERROR_REF(error),
255 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_complete) { argument
260 op->inner_on_complete = on_complete;
281 grpc_closure* on_complete) { argument
287 op->inner_on_complete = on_complete;
288 op->op.on_complete = &op->outer_on_complete;
Dbyte_stream.h49 grpc_closure* on_complete) GRPC_ABSTRACT;
97 bool Next(size_t max_size_hint, grpc_closure* on_complete) override;
132 bool Next(size_t max_size_hint, grpc_closure* on_complete) override;
Dbyte_stream.cc57 grpc_closure* on_complete) { in Next() argument
115 grpc_closure* on_complete) { in Next() argument
119 return cache_->underlying_stream_->Next(max_size_hint, on_complete); in Next()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc67 grpc_closure on_complete; member
121 nullptr, &w->on_complete, nullptr); in partly_done()
221 GRPC_CLOSURE_INIT(&w->on_complete, watch_complete, w, in grpc_channel_watch_connectivity_state()
244 &w->on_complete, &w->watcher_timer_init); in grpc_channel_watch_connectivity_state()
Dclient_channel.cc582 pick_state.on_complete = nullptr; in start_transport_op_locked()
840 grpc_closure on_complete; member
999 static void on_complete(void* arg, grpc_error* error);
1323 if (batch->on_complete == nullptr && in maybe_clear_pending_batch()
1567 GRPC_CLOSURE_INIT(&batch_data->on_complete, on_complete, batch_data, in batch_data_create()
1569 batch_data->batch.on_complete = &batch_data->on_complete; in batch_data_create()
1885 if (pending->batch == nullptr || pending->batch->on_complete == nullptr) { in pending_batch_is_unstarted()
1919 closures->Add(pending->batch->on_complete, GRPC_ERROR_REF(error), in add_closures_to_fail_unstarted_pending_batches()
1921 pending->batch->on_complete = nullptr; in add_closures_to_fail_unstarted_pending_batches()
2028 return batch->on_complete != nullptr && in add_closure_for_completed_pending_batch()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dchannel_connectivity.cc68 grpc_closure on_complete; member
128 nullptr, &w->on_complete, nullptr); in partly_done()
237 GRPC_CLOSURE_INIT(&w->on_complete, watch_complete, w, in grpc_channel_watch_connectivity_state()
260 &w->on_complete, &w->watcher_timer_init); in grpc_channel_watch_connectivity_state()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/http/
Dhttpcli.h113 grpc_closure* on_complete,
119 grpc_closure* on_complete,
/external/pigweed/pw_watch/py/pw_watch/
Ddebounce.py37 def on_complete(self, cancelled: bool = False) -> None: member in DebouncedFunction
149 self.function.on_complete(cancelled=False)
152 self.function.on_complete(cancelled=True)
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/sockaddr/
Dsockaddr_resolver.cc51 grpc_closure* on_complete) override;
84 grpc_closure* on_complete) { in NextLocked() argument
86 next_completion_ = on_complete; in NextLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/pick_first/
Dpick_first.cc185 GRPC_CLOSURE_SCHED(pick->on_complete, error); in HandOffPendingPicksLocked()
201 GRPC_CLOSURE_SCHED(pick->on_complete, GRPC_ERROR_REF(error)); in ShutdownLocked()
218 GRPC_CLOSURE_SCHED(pick->on_complete, in CancelPickLocked()
239 GRPC_CLOSURE_SCHED(pick->on_complete, in CancelMatchingPicksLocked()
279 if (pick->on_complete == nullptr) { in PickLocked()
594 GRPC_CLOSURE_SCHED(pick->on_complete, GRPC_ERROR_NONE); in ProcessUnselectedReadyLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc109 calld->original_on_complete_for_send = batch->on_complete; in start_transport_stream_op_batch()
112 batch->on_complete = &calld->on_complete_for_send; in start_transport_stream_op_batch()
Dgrpclb.cc160 grpc_closure on_complete; member
1117 GRPC_CLOSURE_SCHED(&pp->on_complete, GRPC_ERROR_REF(error)); in ShutdownLocked()
1130 pp->pick->on_complete = pp->original_on_complete; in HandOffPendingPicksLocked()
1135 GRPC_CLOSURE_SCHED(pp->pick->on_complete, error); in HandOffPendingPicksLocked()
1160 GRPC_CLOSURE_SCHED(&pp->on_complete, in CancelPickLocked()
1196 GRPC_CLOSURE_SCHED(&pp->on_complete, in CancelMatchingPicksLocked()
1239 if (pick->on_complete == nullptr) { in PickLocked()
1560 GRPC_CLOSURE_INIT(&pp->on_complete, &GrpcLb::OnPendingPickComplete, pp, in PendingPickCreate()
1562 pp->original_on_complete = pick->on_complete; in PendingPickCreate()
1563 pick->on_complete = &pp->on_complete; in PendingPickCreate()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/fake/
Dfake_resolver.cc55 grpc_closure* on_complete) override;
98 grpc_closure* on_complete) { in NextLocked() argument
100 next_completion_ = on_complete; in NextLocked()
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/round_robin/
Dround_robin.cc262 GRPC_CLOSURE_SCHED(pick->on_complete, error); in HandOffPendingPicksLocked()
278 GRPC_CLOSURE_SCHED(pick->on_complete, GRPC_ERROR_REF(error)); in ShutdownLocked()
295 GRPC_CLOSURE_SCHED(pick->on_complete, in CancelPickLocked()
317 GRPC_CLOSURE_SCHED(pick->on_complete, in CancelMatchingPicksLocked()
378 GRPC_CLOSURE_SCHED(pick->on_complete, GRPC_ERROR_NONE); in DrainPendingPicksLocked()
390 if (pick->on_complete == nullptr) { in PickLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc121 calld->original_on_complete_for_send = batch->on_complete; in clr_start_transport_stream_op_batch()
124 batch->on_complete = &calld->on_complete_for_send; in clr_start_transport_stream_op_batch()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc336 op.on_complete = done.get(); in BM_StreamCreateSendInitialMetadataDestroy()
372 op.on_complete = c.get(); in BM_TransportEmptyOp()
437 op.on_complete = c.get(); in BM_TransportStreamSend()
446 op.on_complete = c.get(); in BM_TransportStreamSend()
569 op.on_complete = do_nothing.get(); in BM_TransportStreamRecv()
613 op.on_complete = c.get(); in BM_TransportStreamRecv()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/native/
Ddns_resolver.cc57 grpc_closure* on_complete) override;
146 grpc_closure* on_complete) { in NextLocked() argument
148 next_completion_ = on_complete; in NextLocked()

123