| /third_party/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* error, const char* file,
71 void Start(grpc_closure* closure, grpc_error* error, const char* reason);
101 void SetNotifyOnCancel(grpc_closure* closure);
107 void ScheduleClosure(grpc_closure* closure, grpc_error* error);
135 grpc_closure tsan_closure_;
136 grpc_closure* original_closure_;
153 void Add(grpc_closure* closure, grpc_error* error, const char* reason) { in Add()
201 grpc_closure* closure;
205 CallCombinerClosure(grpc_closure* closure, grpc_error* error, in CallCombinerClosure()
|
| D | combiner.cc | 48 static void combiner_exec(grpc_core::Combiner* lock, grpc_closure* closure,
51 grpc_closure* closure, grpc_error* error);
128 static void combiner_exec(grpc_core::Combiner* lock, grpc_closure* cl, in combiner_exec()
235 grpc_closure* cl = reinterpret_cast<grpc_closure*>(n); in grpc_combiner_continue_exec_ctx()
243 grpc_closure* c = lock->final_list.head; in grpc_combiner_continue_exec_ctx()
251 grpc_closure* next = c->next_data.next; in grpc_combiner_continue_exec_ctx()
306 grpc_closure* closure, grpc_error* error) { in combiner_finally_exec()
329 grpc_closure* cl = static_cast<grpc_closure*>(closure); in enqueue_finally()
336 void Combiner::Run(grpc_closure* closure, grpc_error* error) { in Run()
340 void Combiner::FinallyRun(grpc_closure* closure, grpc_error* error) { in FinallyRun()
|
| D | call_combiner.cc | 94 void CallCombiner::ScheduleClosure(grpc_closure* closure, grpc_error* error) { in ScheduleClosure()
113 void CallCombiner::Start(grpc_closure* closure, grpc_error* error, in Start()
167 grpc_closure* closure = in Stop()
168 reinterpret_cast<grpc_closure*>(queue_.PopAndCheckEnd(&empty)); in Stop()
189 void CallCombiner::SetNotifyOnCancel(grpc_closure* closure) { in SetNotifyOnCancel()
217 closure = reinterpret_cast<grpc_closure*>(original_state); in SetNotifyOnCancel()
244 grpc_closure* notify_on_cancel = in Cancel()
245 reinterpret_cast<grpc_closure*>(original_state); in Cancel()
|
| D | socket_windows.h | 51 grpc_closure* closure;
89 grpc_closure shutdown_closure;
109 grpc_closure* closure);
112 grpc_closure* closure);
|
| D | exec_ctx.cc | 30 static void exec_ctx_run(grpc_closure* closure, grpc_error* error) { in exec_ctx_run()
49 static void exec_ctx_sched(grpc_closure* closure, grpc_error* error) { in exec_ctx_sched()
147 grpc_closure* c = closure_list_.head; in Flush()
150 grpc_closure* next = c->next_data.next; in Flush()
172 void ExecCtx::Run(const DebugLocation& location, grpc_closure* closure, in Run()
200 grpc_closure* c = list->head; in RunList()
202 grpc_closure* next = c->next_data.next; in RunList()
|
| D | resource_quota.h | 134 grpc_closure* optional_on_done)
143 bool destructive, grpc_closure* closure);
150 grpc_closure on_allocated;
152 grpc_closure on_done;
|
| D | endpoint.h | 40 void (*read)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb,
42 void (*write)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb,
62 grpc_closure* cb, bool urgent);
85 grpc_closure* cb, void* arg);
|
| /third_party/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;
322 grpc_closure write_action_begin_locked;
323 grpc_closure write_action;
324 grpc_closure write_action_end_locked;
326 grpc_closure read_action_locked;
[all …]
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_closure.cc | 58 grpc_closure c; in BM_ClosureInitAgainstExecCtx()
70 grpc_closure c; in BM_ClosureInitAgainstCombiner()
84 grpc_closure c; in BM_ClosureRun()
112 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 …]
|
| /third_party/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 …]
|
| D | transport.cc | 164 grpc_closure* then_schedule_closure) {
214 grpc_closure outer_on_complete;
215 grpc_closure* inner_on_complete = nullptr;
229 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_complete) {
239 grpc_closure outer_on_complete;
240 grpc_closure* inner_on_complete;
246 grpc_closure* c = op->inner_on_complete;
252 grpc_closure* on_complete) {
|
| /third_party/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;
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_;
|
| 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_;
|
| /third_party/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_;
|
| /third_party/grpc/src/core/lib/surface/ |
| D | server.h | 87 virtual void SetOnDestroyDone(grpc_closure* on_destroy_done) = 0;
226 grpc_closure finish_destroy_channel_closure_;
266 grpc_closure* /*ignored*/);
297 grpc_closure kill_zombie_closure_;
301 grpc_closure recv_initial_metadata_batch_complete_;
305 grpc_closure recv_initial_metadata_ready_;
306 grpc_closure* original_recv_initial_metadata_ready_;
310 grpc_closure recv_trailing_metadata_ready_;
311 grpc_closure* original_recv_trailing_metadata_ready_;
314 grpc_closure publish_;
[all …]
|
| /third_party/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_;
169 grpc_closure retry_timer_callback_;
|
| /third_party/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 …]
|
| /third_party/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()
41 grpc_pollset_set* interested_parties, grpc_closure* on_done,
60 grpc_closure* on_done, in grpc_resolve_address_ares_impl()
65 grpc_pollset_set* interested_parties, grpc_closure* on_done,
|
| /third_party/grpc/src/core/lib/http/ |
| D | httpcli.h | 86 grpc_closure* on_done, grpc_httpcli_response* response);
107 grpc_millis deadline, grpc_closure* on_done,
113 grpc_closure* on_complete,
119 grpc_closure* on_complete,
|
| /third_party/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;
79 grpc_closure* on_peer_checked) override;
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 46 grpc_closure on_complete_for_send;
47 grpc_closure* original_on_complete_for_send;
50 grpc_closure recv_initial_metadata_ready;
51 grpc_closure* original_recv_initial_metadata_ready;
85 grpc_closure* /*ignored*/) { in clr_destroy_call_elem() argument
|
| /third_party/grpc/src/core/lib/channel/ |
| D | handshaker.h | 83 grpc_closure* on_handshake_done,
154 grpc_closure call_next_handshaker_;
159 grpc_closure on_timeout_;
161 grpc_closure on_handshake_done_;
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | subchannel.h | 83 void Ping(grpc_closure* on_initiate, grpc_closure* on_ack);
124 void SetAfterCallStackDestroy(grpc_closure* closure);
156 grpc_closure* after_call_stack_destroy_ = nullptr;
158 grpc_closure recv_trailing_metadata_ready_;
159 grpc_closure* original_recv_trailing_metadata_ = nullptr;
398 grpc_closure on_connecting_finished_;
420 grpc_closure on_retry_alarm_;
|