| /external/rust/crates/grpcio-sys/grpc/third_party/upb/upb/json/ |
| D | printer.c | 236 static bool putkey(void *closure, const void *handler_data) { in putkey() argument
237 upb_json_printer *p = closure; in putkey()
250 static bool put##type(void *closure, const void *handler_data, type val) { \
251 upb_json_printer *p = closure; \
259 static bool scalar_##type(void *closure, const void *handler_data, \
261 CHK(putkey(closure, handler_data)); \
262 CHK(put##type(closure, handler_data, val)); \
265 static bool repeated_##type(void *closure, const void *handler_data, \
267 upb_json_printer *p = closure; \
269 CHK(put##type(closure, handler_data, val)); \
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | call_combiner.h | 56 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ argument
57 (call_combiner)->Start((closure), (error), __FILE__, __LINE__, (reason))
61 void Start(grpc_closure* closure, grpc_error* error, const char* file,
66 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ argument
67 (call_combiner)->Start((closure), (error), (reason))
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);
153 void Add(grpc_closure* closure, grpc_error* error, const char* reason) { in Add() argument
154 closures_.emplace_back(closure, error, reason); in Add()
[all …]
|
| D | closure.h | 93 grpc_closure* closure, argument
96 inline grpc_closure* grpc_closure_init(grpc_closure* closure,
99 closure->cb = cb;
100 closure->cb_arg = cb_arg;
101 closure->error_data.error = GRPC_ERROR_NONE;
103 closure->scheduled = false;
104 closure->file_initiated = nullptr;
105 closure->line_initiated = 0;
106 closure->run = false;
107 closure->file_created = file;
[all …]
|
| D | exec_ctx.cc | 30 static void exec_ctx_run(grpc_closure* closure, grpc_error* error) { in exec_ctx_run() argument
32 closure->scheduled = false; in exec_ctx_run()
35 closure, closure->file_created, closure->line_created, in exec_ctx_run()
36 closure->run ? "run" : "scheduled", closure->file_initiated, in exec_ctx_run()
37 closure->line_initiated); in exec_ctx_run()
40 closure->cb(closure->cb_arg, error); in exec_ctx_run()
43 gpr_log(GPR_DEBUG, "closure %p finished", closure); in exec_ctx_run()
49 static void exec_ctx_sched(grpc_closure* closure, grpc_error* error) { in exec_ctx_sched() argument
50 grpc_closure_list_append(grpc_core::ExecCtx::Get()->closure_list(), closure, in exec_ctx_sched()
172 void ExecCtx::Run(const DebugLocation& location, grpc_closure* closure, in Run() argument
[all …]
|
| D | call_combiner.cc | 94 void CallCombiner::ScheduleClosure(grpc_closure* closure, grpc_error* error) { in ScheduleClosure() argument
96 original_closure_ = closure; in ScheduleClosure()
99 ExecCtx::Run(DEBUG_LOCATION, closure, error); in ScheduleClosure()
113 void CallCombiner::Start(grpc_closure* closure, grpc_error* error, in Start() argument
120 this, closure DEBUG_FMT_ARGS, reason, grpc_error_string(error)); in Start()
136 ScheduleClosure(closure, error); in Start()
142 closure->error_data.error = error; in Start()
144 reinterpret_cast<MultiProducerSingleConsumerQueue::Node*>(closure)); in Start()
167 grpc_closure* closure = in Stop() local
169 if (closure == nullptr) { in Stop()
[all …]
|
| D | socket_windows.cc | 103 winsocket->write_info.closure == NULL && in check_destroyable()
104 winsocket->read_info.closure == NULL; in check_destroyable()
120 static void socket_notify_on_iocp(grpc_winsocket* socket, grpc_closure* closure, in socket_notify_on_iocp() argument
122 GPR_ASSERT(info->closure == NULL); in socket_notify_on_iocp()
126 grpc_core::ExecCtx::Run(DEBUG_LOCATION, closure, GRPC_ERROR_NONE); in socket_notify_on_iocp()
128 info->closure = closure; in socket_notify_on_iocp()
134 grpc_closure* closure) { in grpc_socket_notify_on_write() argument
135 socket_notify_on_iocp(socket, closure, &socket->write_info); in grpc_socket_notify_on_write()
138 void grpc_socket_notify_on_read(grpc_winsocket* socket, grpc_closure* closure) { in grpc_socket_notify_on_read() argument
139 socket_notify_on_iocp(socket, closure, &socket->read_info); in grpc_socket_notify_on_read()
[all …]
|
| D | executor.cc | 60 void default_enqueue_short(grpc_closure* closure, grpc_error* error) { in default_enqueue_short() argument
62 closure, error, true /* is_short */); in default_enqueue_short()
65 void default_enqueue_long(grpc_closure* closure, grpc_error* error) { in default_enqueue_long() argument
67 closure, error, false /* is_short */); in default_enqueue_long()
70 void resolver_enqueue_short(grpc_closure* closure, grpc_error* error) { in resolver_enqueue_short() argument
72 closure, error, true /* is_short */); in resolver_enqueue_short()
75 void resolver_enqueue_long(grpc_closure* closure, grpc_error* error) { in resolver_enqueue_long() argument
77 closure, error, false /* is_short */); in resolver_enqueue_long()
80 using EnqueueFunc = void (*)(grpc_closure* closure, grpc_error* error);
254 void Executor::Enqueue(grpc_closure* closure, grpc_error* error, in Enqueue() argument
[all …]
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | call_combiner.h | 58 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ argument
59 grpc_call_combiner_start((call_combiner), (closure), (error), __FILE__, \
65 grpc_closure* closure, grpc_error* error,
71 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ argument
72 grpc_call_combiner_start((call_combiner), (closure), (error), (reason))
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() argument
132 closures_.emplace_back(closure, error, reason); in Add()
148 auto& closure = closures_[i]; in RunClosures() local
[all …]
|
| D | closure.h | 56 void (*run)(grpc_closure* closure, grpc_error* error);
57 void (*sched)(grpc_closure* closure, grpc_error* error);
106 grpc_closure* closure, argument
110 inline grpc_closure* grpc_closure_init(grpc_closure* closure,
114 closure->cb = cb;
115 closure->cb_arg = cb_arg;
116 closure->scheduler = scheduler;
118 closure->scheduled = false;
119 closure->file_initiated = nullptr;
120 closure->line_initiated = 0;
[all …]
|
| D | call_combiner.cc | 62 grpc_closure* closure, in grpc_call_combiner_start() argument
70 call_combiner, closure DEBUG_FMT_ARGS, reason, in grpc_call_combiner_start()
88 GRPC_CLOSURE_SCHED(closure, error); in grpc_call_combiner_start()
94 closure->error_data.error = error; in grpc_call_combiner_start()
96 reinterpret_cast<gpr_mpscq_node*>(closure)); in grpc_call_combiner_start()
121 grpc_closure* closure = reinterpret_cast<grpc_closure*>( in grpc_call_combiner_stop() local
123 if (closure == nullptr) { in grpc_call_combiner_stop()
133 closure, grpc_error_string(closure->error_data.error)); in grpc_call_combiner_stop()
135 GRPC_CLOSURE_SCHED(closure, closure->error_data.error); in grpc_call_combiner_stop()
144 grpc_closure* closure) { in grpc_call_combiner_set_notify_on_cancel() argument
[all …]
|
| D | socket_windows.cc | 102 winsocket->write_info.closure == NULL && in check_destroyable()
103 winsocket->read_info.closure == NULL; in check_destroyable()
119 static void socket_notify_on_iocp(grpc_winsocket* socket, grpc_closure* closure, in socket_notify_on_iocp() argument
121 GPR_ASSERT(info->closure == NULL); in socket_notify_on_iocp()
125 GRPC_CLOSURE_SCHED(closure, GRPC_ERROR_NONE); in socket_notify_on_iocp()
127 info->closure = closure; in socket_notify_on_iocp()
133 grpc_closure* closure) { in grpc_socket_notify_on_write() argument
134 socket_notify_on_iocp(socket, closure, &socket->write_info); in grpc_socket_notify_on_write()
137 void grpc_socket_notify_on_read(grpc_winsocket* socket, grpc_closure* closure) { in grpc_socket_notify_on_read() argument
138 socket_notify_on_iocp(socket, closure, &socket->read_info); in grpc_socket_notify_on_read()
[all …]
|
| D | exec_ctx.cc | 30 static void exec_ctx_run(grpc_closure* closure, grpc_error* error) { in exec_ctx_run() argument
32 closure->scheduled = false; in exec_ctx_run()
35 closure, closure->file_created, closure->line_created, in exec_ctx_run()
36 closure->run ? "run" : "scheduled", closure->file_initiated, in exec_ctx_run()
37 closure->line_initiated); in exec_ctx_run()
40 closure->cb(closure->cb_arg, error); in exec_ctx_run()
43 gpr_log(GPR_DEBUG, "closure %p finished", closure); in exec_ctx_run()
49 static void exec_ctx_sched(grpc_closure* closure, grpc_error* error) { in exec_ctx_sched() argument
50 grpc_closure_list_append(grpc_core::ExecCtx::Get()->closure_list(), closure, in exec_ctx_sched()
|
| D | combiner.cc | 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);
154 #define COMBINER_FROM_CLOSURE_SCHEDULER(closure, scheduler_name) \ argument
155 ((grpc_combiner*)(((char*)((closure)->scheduler)) - \
323 static void enqueue_finally(void* closure, grpc_error* error);
325 static void combiner_finally_exec(grpc_closure* closure, grpc_error* error) { in combiner_finally_exec() argument
329 COMBINER_FROM_CLOSURE_SCHEDULER(closure, finally_scheduler); in combiner_finally_exec()
331 GPR_INFO, "C:%p grpc_combiner_execute_finally c=%p; ac=%p", lock, closure, in combiner_finally_exec()
335 GRPC_CLOSURE_SCHED(GRPC_CLOSURE_CREATE(enqueue_finally, closure, in combiner_finally_exec()
[all …]
|
| /external/wayland/src/ |
| D | connection.c | 542 wl_closure_clear_fds(struct wl_closure *closure) in wl_closure_clear_fds() argument
544 const char *signature = closure->message->signature; in wl_closure_clear_fds()
548 for (i = 0; i < closure->count; i++) { in wl_closure_clear_fds()
551 closure->args[i].h = -1; in wl_closure_clear_fds()
559 struct wl_closure *closure; in wl_closure_init() local
571 closure = malloc(sizeof *closure + size + in wl_closure_init()
574 closure = malloc(sizeof *closure); in wl_closure_init()
577 if (!closure) { in wl_closure_init()
583 memcpy(closure->args, args, count * sizeof *args); in wl_closure_init()
585 closure->message = message; in wl_closure_init()
[all …]
|
| /external/protobuf/src/google/protobuf/stubs/ |
| D | common_unittest.cc | 204 Closure* closure = NewCallback(&SetA123Function); in TEST_F() local
206 closure->Run(); in TEST_F()
211 Closure* closure = NewCallback(current_instance_, in TEST_F() local
214 closure->Run(); in TEST_F()
219 Closure* closure = NewCallback(&SetAFunction, 456); in TEST_F() local
221 closure->Run(); in TEST_F()
226 Closure* closure = NewCallback(current_instance_, in TEST_F() local
229 closure->Run(); in TEST_F()
234 Closure* closure = NewCallback(&SetCFunction, string("test")); in TEST_F() local
236 closure->Run(); in TEST_F()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/third_party/upb/upb/ |
| D | sink.h | 40 void *closure; member
52 return func(s.closure, hd, val); \
66 s->closure = c; in PUTVAL()
79 return handler(s.closure, hd, buf, n, handle); in upb_sink_putstring()
91 return handler(s.closure, hd, buf, n); in upb_sink_putunknown()
103 return startmsg(s.closure, hd); in upb_sink_startmsg()
115 return endmsg(s.closure, hd, status); in upb_sink_endmsg()
123 sub->closure = s.closure; in upb_sink_startseq()
129 sub->closure = startseq(s.closure, hd); in upb_sink_startseq()
130 return sub->closure ? true : false; in upb_sink_startseq()
[all …]
|
| /external/protobuf/python/google/protobuf/pyext/ |
| D | descriptor.cc | 471 static PyObject* GetName(PyBaseDescriptor* self, void *closure) { in GetName() argument
475 static PyObject* GetFullName(PyBaseDescriptor* self, void *closure) { in GetFullName() argument
479 static PyObject* GetFile(PyBaseDescriptor *self, void *closure) { in GetFile() argument
483 static PyObject* GetConcreteClass(PyBaseDescriptor* self, void *closure) { in GetConcreteClass() argument
497 static PyObject* GetFieldsByName(PyBaseDescriptor* self, void *closure) { in GetFieldsByName() argument
502 void *closure) { in GetFieldsByCamelcaseName() argument
506 static PyObject* GetFieldsByNumber(PyBaseDescriptor* self, void *closure) { in GetFieldsByNumber() argument
510 static PyObject* GetFieldsSeq(PyBaseDescriptor* self, void *closure) { in GetFieldsSeq() argument
514 static PyObject* GetNestedTypesByName(PyBaseDescriptor* self, void *closure) { in GetNestedTypesByName() argument
518 static PyObject* GetNestedTypesSeq(PyBaseDescriptor* self, void *closure) { in GetNestedTypesSeq() argument
[all …]
|
| /external/turbine/java/com/google/turbine/deps/ |
| D | Dependencies.java | 59 Set<ClassSymbol> closure = superTypeClosure(bound, lowered); in collectDeps() local
60 addPackageInfos(closure, bound); in collectDeps()
62 for (ClassSymbol sym : closure) { in collectDeps()
93 Set<ClassSymbol> closure = new LinkedHashSet<>(lowered.symbols()); in superTypeClosure() local
96 addAnnotations(closure, info.annotations()); in superTypeClosure()
98 addAnnotations(closure, method.annotations()); in superTypeClosure()
101 addAnnotations(closure, field.annotations()); in superTypeClosure()
103 addSuperTypes(closure, env, info); in superTypeClosure()
105 return closure; in superTypeClosure()
109 Set<ClassSymbol> closure, ImmutableList<AnnoInfo> annotations) { in addAnnotations() argument
[all …]
|
| /external/webrtc/rtc_base/task_utils/ |
| D | to_queued_task.h | 27 explicit ClosureTask(Closure&& closure) in ClosureTask() argument
28 : closure_(std::forward<Closure>(closure)) {} in ClosureTask()
43 Closure&& closure) in SafetyClosureTask() argument
44 : closure_(std::forward<Closure>(closure)), in SafetyClosureTask()
64 ClosureTaskWithCleanup(Closure&& closure, Cleanup&& cleanup) in ClosureTaskWithCleanup() argument
65 : ClosureTask<Closure>(std::forward<Closure>(closure)), in ClosureTaskWithCleanup()
78 std::unique_ptr<QueuedTask> ToQueuedTask(Closure&& closure) { in ToQueuedTask() argument
80 std::forward<Closure>(closure)); in ToQueuedTask()
86 Closure&& closure) { in ToQueuedTask() argument
88 std::move(safety), std::forward<Closure>(closure)); in ToQueuedTask()
[all …]
|
| /external/libffi/src/powerpc/ |
| D | ffi.c | 78 void *closure) in ffi_call_int() argument
105 ffi_call_LINUX64 (&ecif, fn, ecif.rvalue, cif->flags, closure, in ffi_call_int()
108 ffi_call_SYSV (&ecif, fn, ecif.rvalue, cif->flags, closure, -cif->bytes); in ffi_call_int()
143 void *closure) in ffi_call_go() argument
145 ffi_call_int (cif, fn, rvalue, avalue, closure); in ffi_call_go()
149 ffi_prep_closure_loc (ffi_closure *closure, in ffi_prep_closure_loc() argument
156 return ffi_prep_closure_loc_linux64 (closure, cif, fun, user_data, codeloc); in ffi_prep_closure_loc()
158 return ffi_prep_closure_loc_sysv (closure, cif, fun, user_data, codeloc); in ffi_prep_closure_loc()
163 ffi_prep_go_closure (ffi_go_closure *closure, in ffi_prep_go_closure() argument
168 closure->tramp = ffi_go_closure_linux64; in ffi_prep_go_closure()
[all …]
|
| /external/python/cpython2/Modules/_ctypes/libffi/src/s390/ |
| D | ffi.c | 546 ffi_closure_helper_SYSV (ffi_closure *closure, in ffi_closure_helper_SYSV() argument
566 p_arg = avalue = alloca (closure->cif->nargs * sizeof (void *)); in ffi_closure_helper_SYSV()
572 if (closure->cif->flags == FFI390_RET_STRUCT) in ffi_closure_helper_SYSV()
577 for (ptr = closure->cif->arg_types, i = closure->cif->nargs; in ffi_closure_helper_SYSV()
682 (closure->fun) (closure->cif, rvalue, avalue, closure->user_data); in ffi_closure_helper_SYSV()
685 switch (closure->cif->rtype->type) in ffi_closure_helper_SYSV()
747 ffi_prep_closure_loc (ffi_closure *closure, in ffi_prep_closure_loc() argument
757 *(short *)&closure->tramp [0] = 0x0d10; /* basr %r1,0 */ in ffi_prep_closure_loc()
758 *(short *)&closure->tramp [2] = 0x9801; /* lm %r0,%r1,6(%r1) */ in ffi_prep_closure_loc()
759 *(short *)&closure->tramp [4] = 0x1006; in ffi_prep_closure_loc()
[all …]
|
| /external/grpc-grpc/test/core/transport/ |
| D | byte_stream_test.cc | 58 grpc_closure closure; in TEST() local
59 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
63 ASSERT_TRUE(stream.Next(~(size_t)0, &closure)); in TEST()
90 grpc_closure closure; in TEST() local
91 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
94 ASSERT_TRUE(stream.Next(~(size_t)0, &closure)); in TEST()
105 ASSERT_TRUE(stream.Next(~(size_t)0, &closure)); in TEST()
135 grpc_closure closure; in TEST() local
136 GRPC_CLOSURE_INIT(&closure, NotCalledClosure, nullptr, in TEST()
141 ASSERT_TRUE(stream.Next(~(size_t)0, &closure)); in TEST()
[all …]
|
| /external/harfbuzz_ng/util/ |
| D | helper-cairo.cc | 47 void *closure, in _cairo_eps_surface_create_for_stream() argument
53 surface = cairo_ps_surface_create_for_stream (write_func, closure, width, height); in _cairo_eps_surface_create_for_stream()
182 void *closure; member
188 finalize_ansi (finalize_closure_t *closure) in finalize_ansi() argument
191 status = helper_cairo_surface_write_to_ansi_stream (closure->surface, in finalize_ansi()
192 closure->write_func, in finalize_ansi()
193 closure->closure); in finalize_ansi()
201 void *closure, in _cairo_ansi_surface_create_for_stream() argument
231 ansi_closure->closure = closure; in _cairo_ansi_surface_create_for_stream()
237 g_free ((void *) closure); in _cairo_ansi_surface_create_for_stream()
[all …]
|
| /external/mesa3d/src/compiler/glsl/ |
| D | string_to_uint_map.h | 49 void (*callback)(const char *key, unsigned value, void *closure);
50 void *closure; member
86 void iterate(void (*func)(const char *, unsigned, void *), void *closure) in iterate()
96 wrapper->closure = closure; in iterate()
154 static void delete_key(const void *key, void *data, void *closure) in delete_key()
157 (void) closure; in delete_key()
162 static void subtract_one_wrapper(const void *key, void *data, void *closure) in subtract_one_wrapper()
165 (struct string_map_iterate_wrapper_closure *) closure; in subtract_one_wrapper()
170 wrapper->callback((const char *) key, value, wrapper->closure); in subtract_one_wrapper()
|
| /external/kernel-headers/original/uapi/linux/ |
| D | firewire-cdev.h | 62 __u64 closure; member
86 __u64 closure; member
117 __u64 closure; member
139 __u64 closure; member
198 __u64 closure; member
264 __u64 closure; member
303 __u64 closure; member
330 __u64 closure; member
354 __u64 closure; member
515 __u64 closure; member
[all …]
|