| /external/grpc-grpc/src/core/lib/transport/ |
| D | byte_stream.cc | 57 grpc_closure* on_complete) { in Next()
115 grpc_closure* on_complete) { in Next()
|
| D | transport.cc | 255 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_complete) {
281 grpc_closure* on_complete) {
|
| D | transport.h | 134 grpc_closure* on_complete; member
|
| /external/grpc-grpc/test/core/client_channel/resolvers/ |
| D | dns_resolver_connectivity_test.cc | 120 grpc_closure* on_complete; member
132 grpc_closure* on_complete, in call_resolver_next_after_locking()
|
| /external/cronet/base/tracing/ |
| D | perfetto_task_runner_unittest.cc | 36 base::OnceClosure on_complete) in TaskDestination()
112 void SetTaskExpectations(base::OnceClosure on_complete, in SetTaskExpectations()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.h | 104 grpc_closure* on_complete, in AddExternalConnectivityWatcher()
112 void CancelExternalConnectivityWatcher(grpc_closure* on_complete) { in CancelExternalConnectivityWatcher()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | transport.cc | 229 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_complete) {
253 grpc_closure* on_complete) {
|
| D | byte_stream.cc | 113 grpc_closure* on_complete) { in Next()
|
| D | transport.h | 183 grpc_closure* on_complete = nullptr; member
|
| /external/pigweed/pw_watch/py/pw_watch/ |
| D | debounce.py | 42 def on_complete(self, cancelled: bool = False) -> None: member in DebouncedFunction
|
| D | watch.py | 440 def on_complete(self, cancelled: bool = False) -> None: member in PigweedBuildWatcher
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | lb_policy.h | 75 grpc_closure* on_complete; member
|
| D | channel_connectivity.cc | 67 grpc_closure on_complete; member
|
| D | client_channel.cc | 840 grpc_closure on_complete; member
2090 static void on_complete(void* arg, grpc_error* error) { in on_complete() function
3319 grpc_closure* on_complete; member
3327 channel_data* chand, grpc_closure* on_complete) { in lookup_external_connectivity_watcher()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/sockaddr/ |
| D | sockaddr_resolver.cc | 84 grpc_closure* on_complete) { in NextLocked()
|
| /external/webrtc/test/peer_scenario/ |
| D | peer_scenario_client.cc | 145 std::function<void(RTCError)> on_complete) in LambdaSetLocalDescriptionObserver()
159 std::function<void(RTCError)> on_complete) in LambdaSetRemoteDescriptionObserver()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/native/ |
| D | dns_resolver.cc | 146 grpc_closure* on_complete) { in NextLocked()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/fake/ |
| D | fake_resolver.cc | 98 grpc_closure* on_complete) { in NextLocked()
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 51 callback_state on_complete[6]; // Max number of pending batches. member
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 50 callback_state on_complete[6]; // Max number of pending batches. member
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | dns_resolver_ares.cc | 174 grpc_closure* on_complete) { in NextLocked()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/common/ |
| D | channel_filter.h | 154 grpc_closure* on_complete() const { return op_->on_complete; } in on_complete() function
|
| /external/grpc-grpc/src/cpp/common/ |
| D | channel_filter.h | 154 grpc_closure* on_complete() const { return op_->on_complete; } in on_complete() function
|
| /external/cronet/net/url_request/ |
| D | url_request_test_util.h | 111 void set_on_complete(base::OnceClosure on_complete) { in set_on_complete()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 1398 grpc_closure* on_complete = op->on_complete; in perform_stream_op_locked() local
3033 grpc_closure* on_complete) { in Next()
|