/third_party/grpc/src/core/lib/channel/ |
D | connected_channel.cc | 50 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/ |
D | transport.cc | 204 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;
|
D | byte_stream.h | 53 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;
|
D | transport.h | 183 grpc_closure* on_complete = nullptr; member 455 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_complete); 460 grpc_closure* on_complete);
|
D | byte_stream.cc | 113 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/ |
D | test-net-pingpong-delay.js | 27 function pingPongTest(host, on_complete) { argument 102 if (on_complete) on_complete();
|
D | test-net-pingpong.js | 29 function pingPongTest(host, on_complete) { argument 106 if (on_complete) on_complete();
|
/third_party/cef/libcef_dll/ctocpp/ |
D | completion_callback_ctocpp.cc | 24 if (CEF_MEMBER_MISSING(_struct, on_complete)) in OnComplete() 30 _struct->on_complete(_struct); in OnComplete()
|
D | delete_cookies_callback_ctocpp.cc | 25 if (CEF_MEMBER_MISSING(_struct, on_complete)) in OnComplete() 31 _struct->on_complete(_struct, num_deleted); in OnComplete()
|
D | set_cookie_callback_ctocpp.cc | 25 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/ |
D | channel_connectivity.cc | 68 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()
|
D | client_channel.h | 58 grpc_connectivity_state* state, grpc_closure* on_complete,
|
D | client_channel.cc | 194 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/ |
D | cef_cookie_capi.h | 173 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,
|
D | cef_callback_capi.h | 81 void(CEF_CALLBACK* on_complete)(struct _cef_completion_callback_t* self);
|
/third_party/grpc/src/core/lib/http/ |
D | httpcli.h | 113 grpc_closure* on_complete, 119 grpc_closure* on_complete,
|
/third_party/grpc/test/cpp/microbenchmarks/ |
D | bm_chttp2_transport.cc | 346 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/ |
D | client_load_reporting_filter.cc | 121 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/ |
D | completion_callback_cpptoc.cc | 41 GetStruct()->on_complete = completion_callback_on_complete; in CefCompletionCallbackCppToC()
|
D | delete_cookies_callback_cpptoc.cc | 42 GetStruct()->on_complete = delete_cookies_callback_on_complete; in CefDeleteCookiesCallbackCppToC()
|
D | set_cookie_callback_cpptoc.cc | 42 GetStruct()->on_complete = set_cookie_callback_on_complete; in CefSetCookieCallbackCppToC()
|
/third_party/grpc/src/cpp/common/ |
D | channel_filter.h | 154 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/ |
D | chttp2_transport.cc | 1348 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/ |
D | inproc_transport.cc | 392 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/ |
D | cronet_transport.cc | 1357 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()
|