Home
last modified time | relevance | path

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

12

/third_party/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()
/third_party/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()
/third_party/node/test/pummel/
Dtest-net-pingpong-delay.js27 function pingPongTest(host, on_complete) { argument
102 if (on_complete) on_complete();
Dtest-net-pingpong.js29 function pingPongTest(host, on_complete) { argument
106 if (on_complete) on_complete();
/third_party/cef/libcef_dll/ctocpp/
Dcompletion_callback_ctocpp.cc24 if (CEF_MEMBER_MISSING(_struct, on_complete)) in OnComplete()
30 _struct->on_complete(_struct); in OnComplete()
Ddelete_cookies_callback_ctocpp.cc25 if (CEF_MEMBER_MISSING(_struct, on_complete)) in OnComplete()
31 _struct->on_complete(_struct, num_deleted); in OnComplete()
Dset_cookie_callback_ctocpp.cc25 if (CEF_MEMBER_MISSING(_struct, on_complete)) in OnComplete()
31 _struct->on_complete(_struct, success); in OnComplete()
/third_party/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()
Dclient_channel.h58 grpc_connectivity_state* state, grpc_closure* on_complete,
Dclient_channel.cc194 grpc_closure* on_complete, in AddExternalConnectivityWatcher() argument
196 new ExternalConnectivityWatcher(this, pollent, state, on_complete, in AddExternalConnectivityWatcher()
200 void RemoveExternalConnectivityWatcher(grpc_closure* on_complete, in RemoveExternalConnectivityWatcher() argument
203 this, on_complete, cancel); in RemoveExternalConnectivityWatcher()
229 grpc_closure* on_complete,
236 grpc_closure* on_complete,
589 grpc_closure on_complete; member
1562 grpc_connectivity_state* state, grpc_closure* on_complete, in ExternalConnectivityWatcher() argument
1568 on_complete_(on_complete), in ExternalConnectivityWatcher()
1576 GPR_ASSERT(chand->external_watchers_[on_complete] == nullptr); in ExternalConnectivityWatcher()
[all …]
/third_party/cef/include/capi/
Dcef_cookie_capi.h173 void(CEF_CALLBACK* on_complete)(struct _cef_set_cookie_callback_t* self,
191 void(CEF_CALLBACK* on_complete)(struct _cef_delete_cookies_callback_t* self,
Dcef_callback_capi.h81 void(CEF_CALLBACK* on_complete)(struct _cef_completion_callback_t* self);
/third_party/grpc/src/core/lib/http/
Dhttpcli.h113 grpc_closure* on_complete,
119 grpc_closure* on_complete,
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc346 op.on_complete = done.get(); in BM_StreamCreateSendInitialMetadataDestroy()
382 op.on_complete = c.get(); in BM_TransportEmptyOp()
397 op.on_complete = stream_cancel_closure.get(); in BM_TransportEmptyOp()
455 op.on_complete = c.get(); in BM_TransportStreamSend()
464 op.on_complete = c.get(); in BM_TransportStreamSend()
481 op.on_complete = stream_cancel_closure.get(); in BM_TransportStreamSend()
597 op.on_complete = do_nothing.get(); in BM_TransportStreamRecv()
641 op.on_complete = c.get(); in BM_TransportStreamRecv()
667 op.on_complete = stream_cancel_closure.get(); in BM_TransportStreamRecv()
/third_party/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()
/third_party/cef/libcef_dll/cpptoc/
Dcompletion_callback_cpptoc.cc41 GetStruct()->on_complete = completion_callback_on_complete; in CefCompletionCallbackCppToC()
Ddelete_cookies_callback_cpptoc.cc42 GetStruct()->on_complete = delete_cookies_callback_on_complete; in CefDeleteCookiesCallbackCppToC()
Dset_cookie_callback_cpptoc.cc42 GetStruct()->on_complete = set_cookie_callback_on_complete; in CefSetCookieCallbackCppToC()
/third_party/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()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1348 grpc_transport_stream_op_batch_string(op).c_str(), op->on_complete); in perform_stream_op_locked()
1359 grpc_closure* on_complete = op->on_complete; in perform_stream_op_locked() local
1361 if (on_complete != nullptr) { in perform_stream_op_locked()
1364 on_complete->next_data.scratch = CLOSURE_BARRIER_FIRST_REF_BIT; in perform_stream_op_locked()
1365 on_complete->error_data.error = GRPC_ERROR_NONE; in perform_stream_op_locked()
1379 on_complete->next_data.scratch |= CLOSURE_BARRIER_MAY_COVER_WRITE; in perform_stream_op_locked()
1397 s->send_initial_metadata_finished = add_closure_barrier(on_complete); in perform_stream_op_locked()
1450 on_complete->next_data.scratch |= CLOSURE_BARRIER_MAY_COVER_WRITE; in perform_stream_op_locked()
1451 s->fetching_send_message_finished = add_closure_barrier(op->on_complete); in perform_stream_op_locked()
1493 on_complete->next_data.scratch |= CLOSURE_BARRIER_MAY_COVER_WRITE; in perform_stream_op_locked()
[all …]
/third_party/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc392 grpc_core::ExecCtx::Run(DEBUG_LOCATION, op->on_complete, in complete_if_batch_end_locked()
669 s->recv_trailing_md_op->on_complete, in op_state_machine_locked()
812 s->recv_trailing_md_op->on_complete, in op_state_machine_locked()
966 grpc_closure* on_complete = op->on_complete; in perform_stream_op() local
972 if (on_complete == nullptr) { in perform_stream_op()
973 on_complete = GRPC_CLOSURE_INIT(&op->handler_private.closure, do_nothing, in perform_stream_op()
1122 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_complete, GRPC_ERROR_REF(error)); in perform_stream_op()
/third_party/grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc1357 if (stream_op->on_complete) { in execute_stream_op()
1358 grpc_core::ExecCtx::Run(DEBUG_LOCATION, stream_op->on_complete, in execute_stream_op()
1362 if (stream_op->on_complete) { in execute_stream_op()
1366 DEBUG_LOCATION, stream_op->on_complete, in execute_stream_op()
1374 if (stream_op->on_complete) { in execute_stream_op()
1375 grpc_core::ExecCtx::Run(DEBUG_LOCATION, stream_op->on_complete, in execute_stream_op()
1461 grpc_core::ExecCtx::Run(DEBUG_LOCATION, op->on_complete, in perform_stream_op()

12