| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | closure.h | 32 struct grpc_closure;
33 typedef struct grpc_closure grpc_closure; typedef
38 grpc_closure* head;
39 grpc_closure* tail;
56 void (*run)(grpc_closure* closure, grpc_error* error);
57 void (*sched)(grpc_closure* closure, grpc_error* error);
67 struct grpc_closure { struct
71 grpc_closure* next; argument
105 inline grpc_closure* grpc_closure_init(const char* file, int line, argument
106 grpc_closure* closure,
[all …]
|
| D | ev_posix.h | 48 void (*fd_orphan)(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
51 void (*fd_notify_on_read)(grpc_fd* fd, grpc_closure* closure);
52 void (*fd_notify_on_write)(grpc_fd* fd, grpc_closure* closure);
53 void (*fd_notify_on_error)(grpc_fd* fd, grpc_closure* closure);
60 void (*pollset_shutdown)(grpc_pollset* pollset, grpc_closure* closure);
121 void grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
143 void grpc_fd_notify_on_read(grpc_fd* fd, grpc_closure* closure);
146 void grpc_fd_notify_on_write(grpc_fd* fd, grpc_closure* closure);
150 void grpc_fd_notify_on_error(grpc_fd* fd, grpc_closure* closure);
|
| D | combiner.cc | 62 grpc_closure offload;
66 static void combiner_run(grpc_closure* closure, grpc_error* error);
67 static void combiner_exec(grpc_closure* closure, grpc_error* error);
68 static void combiner_finally_exec(grpc_closure* closure, grpc_error* error);
158 static void combiner_exec(grpc_closure* cl, grpc_error* error) { in combiner_exec()
255 grpc_closure* cl = reinterpret_cast<grpc_closure*>(n); in grpc_combiner_continue_exec_ctx()
263 grpc_closure* c = lock->final_list.head; in grpc_combiner_continue_exec_ctx()
271 grpc_closure* next = c->next_data.next; in grpc_combiner_continue_exec_ctx()
325 static void combiner_finally_exec(grpc_closure* closure, grpc_error* error) { in combiner_finally_exec()
347 static void combiner_run(grpc_closure* closure, grpc_error* error) { in combiner_run()
[all …]
|
| D | call_combiner.cc | 62 grpc_closure* closure, in grpc_call_combiner_start()
121 grpc_closure* closure = reinterpret_cast<grpc_closure*>( in grpc_call_combiner_stop()
144 grpc_closure* closure) { in grpc_call_combiner_set_notify_on_cancel()
172 closure = (grpc_closure*)original_state; in grpc_call_combiner_set_notify_on_cancel()
200 grpc_closure* notify_on_cancel = (grpc_closure*)original_state; in grpc_call_combiner_cancel()
|
| D | call_combiner.h | 65 grpc_closure* closure, grpc_error* error,
77 grpc_closure* closure, grpc_error* error,
110 grpc_closure* closure);
131 void Add(grpc_closure* closure, grpc_error* error, const char* reason) { in Add()
179 grpc_closure* closure;
183 CallCombinerClosure(grpc_closure* closure, grpc_error* error, in CallCombinerClosure()
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | internal.h | 202 grpc_closure* closure;
216 bool Next(size_t max_size_hint, grpc_closure* on_complete) override;
265 grpc_closure closure;
267 grpc_closure* on_complete;
269 grpc_closure destroy_action_;
289 grpc_closure* notify_on_receive_settings;
314 grpc_closure write_action_begin_locked;
315 grpc_closure write_action;
316 grpc_closure write_action_end_locked;
318 grpc_closure read_action_locked;
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | closure.h | 36 struct grpc_closure;
37 typedef struct grpc_closure grpc_closure; typedef
42 grpc_closure* head;
43 grpc_closure* tail;
56 struct grpc_closure { struct
60 grpc_closure* next; argument
92 inline grpc_closure* grpc_closure_init(const char* file, int line, argument
93 grpc_closure* closure,
96 inline grpc_closure* grpc_closure_init(grpc_closure* closure,
127 grpc_closure wrapper;
[all …]
|
| D | ev_posix.h | 53 void (*fd_orphan)(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
56 void (*fd_notify_on_read)(grpc_fd* fd, grpc_closure* closure);
57 void (*fd_notify_on_write)(grpc_fd* fd, grpc_closure* closure);
58 void (*fd_notify_on_error)(grpc_fd* fd, grpc_closure* closure);
65 void (*pollset_shutdown)(grpc_pollset* pollset, grpc_closure* closure);
90 bool (*add_closure_to_background_poller)(grpc_closure* closure,
135 void grpc_fd_orphan(grpc_fd* fd, grpc_closure* on_done, int* release_fd,
157 void grpc_fd_notify_on_read(grpc_fd* fd, grpc_closure* closure);
160 void grpc_fd_notify_on_write(grpc_fd* fd, grpc_closure* closure);
164 void grpc_fd_notify_on_error(grpc_fd* fd, grpc_closure* closure);
[all …]
|
| D | call_combiner.h | 61 void Start(grpc_closure* closure, grpc_error_handle error, const char* file,
71 void Start(grpc_closure* closure, grpc_error_handle error,
98 void SetNotifyOnCancel(grpc_closure* closure);
104 void ScheduleClosure(grpc_closure* closure, grpc_error_handle error);
132 grpc_closure tsan_closure_;
133 grpc_closure* original_closure_;
150 void Add(grpc_closure* closure, grpc_error_handle error, const char* reason) { in Add()
199 grpc_closure* closure;
203 CallCombinerClosure(grpc_closure* closure, grpc_error_handle error, in CallCombinerClosure()
|
| D | combiner.cc | 48 static void combiner_exec(grpc_core::Combiner* lock, grpc_closure* closure,
51 grpc_closure* closure,
129 static void combiner_exec(grpc_core::Combiner* lock, grpc_closure* cl, in combiner_exec()
233 grpc_closure* cl = reinterpret_cast<grpc_closure*>(n); in grpc_combiner_continue_exec_ctx()
241 grpc_closure* c = lock->final_list.head; in grpc_combiner_continue_exec_ctx()
249 grpc_closure* next = c->next_data.next; in grpc_combiner_continue_exec_ctx()
304 grpc_closure* closure, in combiner_finally_exec()
328 grpc_closure* cl = static_cast<grpc_closure*>(closure); in enqueue_finally()
335 void Combiner::Run(grpc_closure* closure, grpc_error_handle error) { in Run()
339 void Combiner::FinallyRun(grpc_closure* closure, grpc_error_handle error) { in FinallyRun()
|
| D | call_combiner.cc | 94 void CallCombiner::ScheduleClosure(grpc_closure* closure, in ScheduleClosure()
114 void CallCombiner::Start(grpc_closure* closure, grpc_error_handle error, in Start()
169 grpc_closure* closure = in Stop()
170 reinterpret_cast<grpc_closure*>(queue_.PopAndCheckEnd(&empty)); in Stop()
192 void CallCombiner::SetNotifyOnCancel(grpc_closure* closure) { in SetNotifyOnCancel()
220 closure = reinterpret_cast<grpc_closure*>(original_state); in SetNotifyOnCancel()
247 grpc_closure* notify_on_cancel = in Cancel()
248 reinterpret_cast<grpc_closure*>(original_state); in Cancel()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | internal.h | 205 grpc_closure* closure;
219 bool Next(size_t max_size_hint, grpc_closure* on_complete) override;
272 grpc_closure closure;
274 grpc_closure* on_complete;
276 grpc_closure destroy_action_;
303 grpc_closure* notify_on_receive_settings = nullptr;
304 grpc_closure* notify_on_close = nullptr;
323 grpc_closure write_action_begin_locked;
324 grpc_closure write_action;
325 grpc_closure write_action_end_locked;
[all …]
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.h | 55 grpc_closure destroy;
116 grpc_closure closure;
134 grpc_closure* on_complete;
201 grpc_closure* recv_initial_metadata_ready;
220 grpc_closure* recv_message_ready;
227 grpc_closure* recv_trailing_metadata_ready;
253 grpc_closure* on_consumed;
255 grpc_closure* on_connectivity_state_change;
281 grpc_closure* on_initiate;
283 grpc_closure* on_ack;
[all …]
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_closure.cc | 59 grpc_closure c; in BM_ClosureInitAgainstExecCtx()
71 grpc_closure c; in BM_ClosureInitAgainstCombiner()
85 grpc_closure c; in BM_ClosureRunOnExecCtx()
113 grpc_closure c; in BM_ClosureInitAndRun()
126 grpc_closure c; in BM_ClosureSchedOnExecCtx()
140 grpc_closure c1; in BM_ClosureSched2OnExecCtx()
141 grpc_closure c2; in BM_ClosureSched2OnExecCtx()
157 grpc_closure c1; in BM_ClosureSched3OnExecCtx()
158 grpc_closure c2; in BM_ClosureSched3OnExecCtx()
159 grpc_closure c3; in BM_ClosureSched3OnExecCtx()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | transport.h | 58 grpc_closure destroy;
154 grpc_closure closure;
183 grpc_closure* on_complete = nullptr;
280 grpc_closure* recv_initial_metadata_ready = nullptr;
299 grpc_closure* recv_message_ready = nullptr;
306 grpc_closure* recv_trailing_metadata_ready = nullptr;
332 grpc_closure* on_consumed = nullptr;
363 grpc_closure* on_initiate = nullptr;
365 grpc_closure* on_ack = nullptr;
411 grpc_closure* then_schedule_closure);
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/ |
| D | client_filter.h | 53 memset(&on_done_recv_trailing_metadata_, 0, sizeof(grpc_closure)); in CensusClientCallData()
54 memset(&on_done_recv_message_, 0, sizeof(grpc_closure)); in CensusClientCallData()
61 grpc_closure* then_call_closure) override;
85 grpc_closure* initial_on_done_recv_trailing_metadata_;
86 grpc_closure on_done_recv_trailing_metadata_;
88 grpc_closure* initial_on_done_recv_message_;
89 grpc_closure on_done_recv_message_;
|
| D | server_filter.h | 53 memset(&on_done_recv_initial_metadata_, 0, sizeof(grpc_closure)); in CensusServerCallData()
54 memset(&on_done_recv_message_, 0, sizeof(grpc_closure)); in CensusServerCallData()
61 grpc_closure* then_call_closure) override;
85 grpc_closure* initial_on_done_recv_initial_metadata_;
86 grpc_closure on_done_recv_initial_metadata_;
88 grpc_closure* initial_on_done_recv_message_;
89 grpc_closure on_done_recv_message_;
|
| /external/grpc-grpc/src/cpp/ext/filters/census/ |
| D | server_filter.h | 53 memset(&on_done_recv_initial_metadata_, 0, sizeof(grpc_closure)); in CensusServerCallData()
54 memset(&on_done_recv_message_, 0, sizeof(grpc_closure)); in CensusServerCallData()
61 grpc_closure* then_call_closure) override;
84 grpc_closure* initial_on_done_recv_initial_metadata_;
85 grpc_closure on_done_recv_initial_metadata_;
87 grpc_closure* initial_on_done_recv_message_;
88 grpc_closure on_done_recv_message_;
|
| D | client_filter.h | 53 memset(&on_done_recv_trailing_metadata_, 0, sizeof(grpc_closure)); in CensusClientCallData()
54 memset(&on_done_recv_message_, 0, sizeof(grpc_closure)); in CensusClientCallData()
61 grpc_closure* then_call_closure) override;
83 grpc_closure* initial_on_done_recv_trailing_metadata_;
84 grpc_closure on_done_recv_trailing_metadata_;
86 grpc_closure* initial_on_done_recv_message_;
87 grpc_closure on_done_recv_message_;
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.h | 104 grpc_closure* on_complete, in AddExternalConnectivityWatcher()
105 grpc_closure* watcher_timer_init) { in AddExternalConnectivityWatcher()
112 void CancelExternalConnectivityWatcher(grpc_closure* on_complete) { in CancelExternalConnectivityWatcher()
137 grpc_closure* on_call_destruction_complete);
154 grpc_closure* on_complete,
155 grpc_closure* watcher_timer_init);
161 grpc_closure* on_complete,
181 grpc_closure* on_complete_;
182 grpc_closure* watcher_timer_init_;
364 std::map<grpc_closure*, RefCountedPtr<ExternalConnectivityWatcher>>
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/security/security_connector/insecure/ |
| D | insecure_security_connector.h | 49 grpc_closure* on_call_host_checked,
52 void cancel_check_call_host(grpc_closure* on_call_host_checked,
61 grpc_closure* on_peer_checked) override;
63 void cancel_check_peer(grpc_closure* /*on_peer_checked*/, in cancel_check_peer() argument
84 grpc_closure* on_peer_checked) override;
86 void cancel_check_peer(grpc_closure* /*on_peer_checked*/, in cancel_check_peer() argument
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/client/ |
| D | chttp2_connector.h | 35 void Connect(const Args& args, Result* result, grpc_closure* notify) override;
59 grpc_closure* notify_ = nullptr;
65 grpc_closure connected_;
66 grpc_closure on_receive_settings_;
68 grpc_closure on_timeout_;
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_decompress_filter.cc | 111 grpc_closure on_recv_initial_metadata_ready_;
112 grpc_closure* original_recv_initial_metadata_ready_ = nullptr;
118 grpc_closure on_recv_message_ready_;
119 grpc_closure* original_recv_message_ready_ = nullptr;
120 grpc_closure on_recv_message_next_done_;
131 grpc_closure on_recv_trailing_metadata_ready_;
132 grpc_closure* original_recv_trailing_metadata_ready_ = nullptr;
163 grpc_closure* closure = calld->original_recv_initial_metadata_ready_; in OnRecvInitialMetadataReady()
289 grpc_closure* closure = original_recv_message_ready_; in ContinueRecvMessageReadyCallback()
318 grpc_closure* closure = calld->original_recv_trailing_metadata_ready_; in OnRecvTrailingMetadataReady()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.h | 109 grpc_closure on_complete_;
123 grpc_closure recv_initial_metadata_ready_;
127 grpc_closure recv_message_ready_;
134 grpc_closure recv_trailing_metadata_ready_;
140 grpc_closure after_call_stack_destruction_;
170 grpc_closure retry_timer_callback_ ABSL_GUARDED_BY(mu_);
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_wrapper_fallback.cc | 31 grpc_pollset_set* interested_parties, grpc_closure* on_done, in grpc_dns_lookup_ares_locked_impl()
39 grpc_pollset_set* interested_parties, grpc_closure* on_done,
52 grpc_closure* on_done, in grpc_resolve_address_ares_impl()
57 grpc_pollset_set* interested_parties, grpc_closure* on_done,
|