Home
last modified time | relevance | path

Searched refs:grpc_closure (Results 1 – 25 of 209) sorted by relevance

123456789

/external/grpc-grpc/src/core/lib/iomgr/
Dclosure.h32 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 …]
Dev_posix.h48 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);
Dcombiner.cc62 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 …]
Dcall_combiner.cc62 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()
Dcall_combiner.h65 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()
Dsocket_windows.h47 grpc_closure* closure;
85 grpc_closure shutdown_closure;
105 grpc_closure* closure);
108 grpc_closure* closure);
Dresource_quota.h118 grpc_closure* optional_on_done);
126 bool destructive, grpc_closure* closure);
133 grpc_closure on_allocated;
135 grpc_closure on_done;
Dendpoint.h39 void (*read)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb);
40 void (*write)(grpc_endpoint* ep, grpc_slice_buffer* slices, grpc_closure* cb,
58 grpc_closure* cb);
79 grpc_closure* cb, void* arg);
Dtcp_server.h49 grpc_error* (*create)(grpc_closure* shutdown_complete,
61 grpc_closure* shutdown_starting);
69 grpc_error* grpc_tcp_server_create(grpc_closure* shutdown_complete,
109 grpc_closure* shutdown_starting);
Dtcp_client_cfstream.cc58 grpc_closure on_alarm;
59 grpc_closure on_open;
65 grpc_closure* closure;
88 grpc_closure* closure = connect->closure; in OnAlarm()
110 grpc_closure* closure = connect->closure; in OnOpen()
156 static void CFStreamClientConnect(grpc_closure* closure, grpc_endpoint** ep, in CFStreamClientConnect()
Dtimer.h36 grpc_closure* closure;
52 void (*init)(grpc_timer* timer, grpc_millis, grpc_closure* closure);
70 grpc_closure* closure);
Dudp_server.h54 grpc_closure* notify_on_write_closure) GRPC_ABSTRACT;
58 virtual void OnFdAboutToOrphan(grpc_closure* orphan_fd_closure,
105 void grpc_udp_server_destroy(grpc_udp_server* server, grpc_closure* on_done);
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dinternal.h202 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/grpc-grpc/src/core/lib/transport/
Dtransport.h55 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 …]
Dtransport.cc194 grpc_closure* then_schedule_closure) {
244 grpc_closure outer_on_complete;
245 grpc_closure* inner_on_complete;
255 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_complete) {
267 grpc_closure outer_on_complete;
268 grpc_closure* inner_on_complete;
275 grpc_closure* c = op->inner_on_complete;
281 grpc_closure* on_complete) {
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_closure.cc59 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/grpc-grpc/src/cpp/ext/filters/census/
Dserver_filter.h53 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_;
Dclient_filter.h53 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/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_wrapper_fallback.cc31 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,
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc43 grpc_closure on_complete_for_send;
44 grpc_closure* original_on_complete_for_send;
47 grpc_closure recv_initial_metadata_ready;
48 grpc_closure* original_recv_initial_metadata_ready;
88 grpc_closure* ignored) { in destroy_call_elem()
/external/grpc-grpc/src/core/lib/security/security_connector/
Dsecurity_connector.h58 grpc_closure* on_peer_checked);
93 grpc_closure* on_peer_checked);
122 grpc_closure* on_call_host_checked,
125 grpc_closure* on_call_host_checked,
141 grpc_auth_context* auth_context, grpc_closure* on_call_host_checked,
148 grpc_channel_security_connector* sc, grpc_closure* on_call_host_checked,
/external/grpc-grpc/src/core/lib/http/
Dhttpcli.h87 grpc_closure* on_complete,
109 grpc_millis deadline, grpc_closure* on_complete,
115 grpc_closure* on_complete,
121 grpc_closure* on_complete,
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.h39 grpc_closure timer_callback;
42 grpc_closure recv_trailing_metadata_ready;
45 grpc_closure* original_recv_trailing_metadata_ready;
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dsubchannel.h95 grpc_closure* closure);
96 void Ping(grpc_closure* on_initiate, grpc_closure* on_ack);
143 grpc_connectivity_state* state, grpc_closure* notify);
169 grpc_subchannel_call* subchannel_call, grpc_closure* closure);
Dlb_policy.h75 grpc_closure* on_complete;
131 grpc_closure* closure) GRPC_ABSTRACT;
167 void SetReresolutionClosureLocked(grpc_closure* request_reresolution) { in SetReresolutionClosureLocked()
210 grpc_closure* request_reresolution_;

123456789