Home
last modified time | relevance | path

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

12

/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/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/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/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/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 …]
Dclient_channel.h55 grpc_connectivity_state* state, grpc_closure* on_complete,
Dresolver.h69 grpc_closure* on_complete) GRPC_ABSTRACT;
Dlb_policy.h75 grpc_closure* on_complete; member
/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/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/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/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/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()
Dbm_call_create.cc433 GRPC_CLOSURE_SCHED(op->on_complete, GRPC_ERROR_NONE); in PerformStreamOp()
472 op_.on_complete = GRPC_CLOSURE_INIT(&closure_, DoNothing, nullptr, in SendEmptyMetadata()
642 if (op->on_complete != nullptr) { in StartTransportStreamOp()
643 closures.Add(op->on_complete, GRPC_ERROR_NONE, "on_complete"); in StartTransportStreamOp()
/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()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc138 grpc_closure* on_complete);
1376 op->on_complete); in perform_stream_op_locked()
1388 grpc_closure* on_complete = op->on_complete; in perform_stream_op_locked() local
1394 if (on_complete == nullptr) { in perform_stream_op_locked()
1395 on_complete = GRPC_CLOSURE_INIT(&op->handler_private.closure, do_nothing, in perform_stream_op_locked()
1401 on_complete->next_data.scratch = CLOSURE_BARRIER_FIRST_REF_BIT; in perform_stream_op_locked()
1402 on_complete->error_data.error = GRPC_ERROR_NONE; in perform_stream_op_locked()
1412 on_complete->next_data.scratch |= CLOSURE_BARRIER_MAY_COVER_WRITE; in perform_stream_op_locked()
1425 s->send_initial_metadata_finished = add_closure_barrier(on_complete); in perform_stream_op_locked()
1497 on_complete->next_data.scratch |= CLOSURE_BARRIER_MAY_COVER_WRITE; in perform_stream_op_locked()
[all …]
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.h154 grpc_closure* on_complete() const { return op_->on_complete; } in on_complete() function
155 void set_on_complete(grpc_closure* closure) { op_->on_complete = closure; } in set_on_complete()
/external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Ddns_resolver_ares.cc65 grpc_closure* on_complete) override;
174 grpc_closure* on_complete) { in NextLocked() argument
177 next_completion_ = on_complete; in NextLocked()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc385 GRPC_CLOSURE_SCHED(op->on_complete, GRPC_ERROR_REF(error)); in complete_if_batch_end_locked()
657 GRPC_CLOSURE_SCHED(s->recv_trailing_md_op->on_complete, in op_state_machine()
793 GRPC_CLOSURE_SCHED(s->recv_trailing_md_op->on_complete, in op_state_machine()
923 grpc_closure* on_complete = op->on_complete; in perform_stream_op() local
929 if (on_complete == nullptr) { in perform_stream_op()
930 on_complete = GRPC_CLOSURE_INIT(&op->handler_private.closure, do_nothing, in perform_stream_op()
1076 GRPC_CLOSURE_SCHED(on_complete, GRPC_ERROR_REF(error)); in perform_stream_op()
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc262 calld->send_message_batch->on_complete; in finish_send_message()
263 calld->send_message_batch->on_complete = &calld->send_message_on_complete; in finish_send_message()

12