| /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 | 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 …]
|
| 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 | executor.cc | 195 void GrpcExecutor::Enqueue(grpc_closure* closure, grpc_error* error, in Enqueue() argument
213 EXECUTOR_TRACE("(%s) schedule %p (created %s:%d) inline", name_, closure, in Enqueue()
214 closure->file_created, closure->line_created); in Enqueue()
216 EXECUTOR_TRACE("(%s) schedule %p inline", name_, closure); in Enqueue()
219 closure, error); in Enqueue()
239 name_, closure, is_short ? "short" : "long", closure->file_created, in Enqueue()
240 closure->line_created, ts->id); in Enqueue()
243 closure, is_short ? "short" : "long", ts->id); in Enqueue()
285 grpc_closure_list_append(&ts->elems, closure, error); in Enqueue()
321 void default_enqueue_short(grpc_closure* closure, grpc_error* error) { in default_enqueue_short() argument
[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/wayland/src/ |
| D | connection.c | 531 struct wl_closure *closure; in wl_closure_marshal() local
544 closure = malloc(sizeof *closure); in wl_closure_marshal()
545 if (closure == NULL) { in wl_closure_marshal()
550 memcpy(closure->args, args, count * sizeof *args); in wl_closure_marshal()
574 closure->args[i].n = object ? object->id : 0; in wl_closure_marshal()
585 closure->args[i].h = dup_fd; in wl_closure_marshal()
593 closure->sender_id = sender->id; in wl_closure_marshal()
594 closure->opcode = opcode; in wl_closure_marshal()
595 closure->message = message; in wl_closure_marshal()
596 closure->count = count; in wl_closure_marshal()
[all …]
|
| D | wayland-client.c | 226 decrease_closure_args_refcount(struct wl_closure *closure) in decrease_closure_args_refcount() argument
233 signature = closure->message->signature; in decrease_closure_args_refcount()
240 proxy = (struct wl_proxy *) closure->args[i].o; in decrease_closure_args_refcount()
243 closure->args[i].o = NULL; in decrease_closure_args_refcount()
259 struct wl_closure *closure; in wl_event_queue_release() local
264 closure = container_of(queue->event_list.next, in wl_event_queue_release()
266 wl_list_remove(&closure->link); in wl_event_queue_release()
268 decrease_closure_args_refcount(closure); in wl_event_queue_release()
270 proxy = closure->proxy; in wl_event_queue_release()
277 wl_closure_destroy(closure); in wl_event_queue_release()
[all …]
|
| /external/protobuf/python/google/protobuf/pyext/ |
| D | descriptor.cc | 419 static PyObject* GetName(PyBaseDescriptor* self, void *closure) { in GetName() argument
423 static PyObject* GetFullName(PyBaseDescriptor* self, void *closure) { in GetFullName() argument
427 static PyObject* GetFile(PyBaseDescriptor *self, void *closure) { in GetFile() argument
431 static PyObject* GetConcreteClass(PyBaseDescriptor* self, void *closure) { in GetConcreteClass() argument
444 static PyObject* GetFieldsByName(PyBaseDescriptor* self, void *closure) { in GetFieldsByName() argument
449 void *closure) { in GetFieldsByCamelcaseName() argument
453 static PyObject* GetFieldsByNumber(PyBaseDescriptor* self, void *closure) { in GetFieldsByNumber() argument
457 static PyObject* GetFieldsSeq(PyBaseDescriptor* self, void *closure) { in GetFieldsSeq() argument
461 static PyObject* GetNestedTypesByName(PyBaseDescriptor* self, void *closure) { in GetNestedTypesByName() argument
465 static PyObject* GetNestedTypesSeq(PyBaseDescriptor* self, void *closure) { in GetNestedTypesSeq() argument
[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/libffi/src/s390/ |
| D | ffi.c | 553 ffi_closure_helper_SYSV (ffi_closure *closure, in ffi_closure_helper_SYSV() argument
573 p_arg = avalue = alloca (closure->cif->nargs * sizeof (void *)); in ffi_closure_helper_SYSV()
579 if (closure->cif->flags == FFI390_RET_STRUCT) in ffi_closure_helper_SYSV()
584 for (ptr = closure->cif->arg_types, i = closure->cif->nargs; in ffi_closure_helper_SYSV()
692 (closure->fun) (closure->cif, rvalue, avalue, closure->user_data); in ffi_closure_helper_SYSV()
695 switch (closure->cif->rtype->type) in ffi_closure_helper_SYSV()
758 ffi_prep_closure_loc (ffi_closure *closure, in ffi_prep_closure_loc() argument
768 *(short *)&closure->tramp [0] = 0x0d10; /* basr %r1,0 */ in ffi_prep_closure_loc()
769 *(short *)&closure->tramp [2] = 0x9801; /* lm %r0,%r1,6(%r1) */ in ffi_prep_closure_loc()
770 *(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/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 …]
|
| /external/wayland/tests/ |
| D | connection-test.c | 167 struct wl_closure *closure; in marshal() local
174 closure = wl_closure_vmarshal(&sender, opcode, ap, &message); in marshal()
177 assert(closure); in marshal()
178 assert(wl_closure_send(closure, data->write_connection) == 0); in marshal()
179 wl_closure_destroy(closure); in marshal()
228 struct wl_closure *closure; in expected_fail_marshal() local
241 closure = wl_closure_vmarshal(&sender, opcode, ap, &message); in expected_fail_marshal()
244 assert(closure == NULL); in expected_fail_marshal()
252 struct wl_closure *closure; in expected_fail_marshal_send() local
259 closure = wl_closure_vmarshal(&sender, opcode, ap, &message); in expected_fail_marshal_send()
[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/python/cpython3/Modules/_ctypes/libffi_osx/x86/ |
| D | x86-ffi_darwin.c | 240 ffi_closure_SYSV_inner (closure, respp, args) in ffi_closure_SYSV_inner() argument
241 ffi_closure *closure; in ffi_closure_SYSV_inner()
249 cif = closure->cif;
260 (closure->fun) (cif, *respp, arg_area, closure->user_data);
321 ffi_prep_closure (ffi_closure* closure, in ffi_prep_closure() argument
329 FFI_INIT_TRAMPOLINE (&closure->tramp[0], \ in ffi_prep_closure()
331 (void*)closure); in ffi_prep_closure()
333 closure->cif = cif; in ffi_prep_closure()
334 closure->user_data = user_data; in ffi_prep_closure()
335 closure->fun = fun; in ffi_prep_closure()
[all …]
|
| /external/python/cpython2/Modules/_ctypes/libffi_osx/x86/ |
| D | x86-ffi_darwin.c | 240 ffi_closure_SYSV_inner (closure, respp, args) in ffi_closure_SYSV_inner() argument
241 ffi_closure *closure; in ffi_closure_SYSV_inner()
249 cif = closure->cif;
260 (closure->fun) (cif, *respp, arg_area, closure->user_data);
321 ffi_prep_closure (ffi_closure* closure, in ffi_prep_closure() argument
329 FFI_INIT_TRAMPOLINE (&closure->tramp[0], \ in ffi_prep_closure()
331 (void*)closure); in ffi_prep_closure()
333 closure->cif = cif; in ffi_prep_closure()
334 closure->user_data = user_data; in ffi_prep_closure()
335 closure->fun = fun; in ffi_prep_closure()
[all …]
|
| /external/libffi/src/xtensa/ |
| D | ffi.c | 229 ffi_prep_closure_loc (ffi_closure* closure, in ffi_prep_closure_loc() argument
236 memcpy(closure->tramp, ffi_trampoline, FFI_TRAMPOLINE_SIZE); in ffi_prep_closure_loc()
237 *(unsigned int*)(&closure->tramp[8]) = (unsigned int)ffi_closure_SYSV; in ffi_prep_closure_loc()
241 ffi_cacheflush(closure->tramp, closure->tramp + FFI_TRAMPOLINE_SIZE); in ffi_prep_closure_loc()
243 closure->cif = cif; in ffi_prep_closure_loc()
244 closure->fun = fun; in ffi_prep_closure_loc()
245 closure->user_data = user_data; in ffi_prep_closure_loc()
251 ffi_closure_SYSV_inner(ffi_closure *closure, void **values, void *rvalue) in ffi_closure_SYSV_inner() argument
258 cif = closure->cif; in ffi_closure_SYSV_inner()
271 cif = closure->cif; in ffi_closure_SYSV_inner()
[all …]
|
| /external/turbine/java/com/google/turbine/deps/ |
| D | Dependencies.java | 51 Set<ClassSymbol> closure = superTypeClosure(bound, lowered); in collectDeps() local
52 addPackageInfos(closure, bound); in collectDeps()
54 for (ClassSymbol sym : closure) { in collectDeps()
85 Set<ClassSymbol> closure = new LinkedHashSet<>(); in superTypeClosure() local
87 addSuperTypes(closure, env, sym); in superTypeClosure()
89 return closure; in superTypeClosure()
93 Set<ClassSymbol> closure, Env<ClassSymbol, TypeBoundClass> env, ClassSymbol sym) { in addSuperTypes() argument
94 if (!closure.add(sym)) { in addSuperTypes()
102 addSuperTypes(closure, env, info.superclass()); in addSuperTypes()
105 addSuperTypes(closure, env, i); in addSuperTypes()
[all …]
|
| /external/python/cpython2/Modules/_ctypes/libffi/src/xtensa/ |
| D | ffi.c | 229 ffi_prep_closure_loc (ffi_closure* closure, in ffi_prep_closure_loc() argument
236 memcpy(closure->tramp, ffi_trampoline, FFI_TRAMPOLINE_SIZE); in ffi_prep_closure_loc()
237 *(unsigned int*)(&closure->tramp[8]) = (unsigned int)ffi_closure_SYSV; in ffi_prep_closure_loc()
241 ffi_cacheflush(closure->tramp, closure->tramp + FFI_TRAMPOLINE_SIZE); in ffi_prep_closure_loc()
243 closure->cif = cif; in ffi_prep_closure_loc()
244 closure->fun = fun; in ffi_prep_closure_loc()
245 closure->user_data = user_data; in ffi_prep_closure_loc()
251 ffi_closure_SYSV_inner(ffi_closure *closure, void **values, void *rvalue) in ffi_closure_SYSV_inner() argument
258 cif = closure->cif; in ffi_closure_SYSV_inner()
271 cif = closure->cif; in ffi_closure_SYSV_inner()
[all …]
|
| /external/python/cpython2/Modules/_ctypes/libffi/src/m68k/ |
| D | ffi.c | 30 unsigned int ffi_closure_SYSV_inner (ffi_closure *closure,
309 ffi_closure_SYSV_inner (ffi_closure *closure, void *resp, void *args) in ffi_closure_SYSV_inner() argument
314 cif = closure->cif; in ffi_closure_SYSV_inner()
319 (closure->fun) (cif, resp, arg_area, closure->user_data); in ffi_closure_SYSV_inner()
325 ffi_prep_closure_loc (ffi_closure* closure, in ffi_prep_closure_loc() argument
334 *(unsigned short *)closure->tramp = 0x207c; in ffi_prep_closure_loc()
335 *(void **)(closure->tramp + 2) = codeloc; in ffi_prep_closure_loc()
336 *(unsigned short *)(closure->tramp + 6) = 0x4ef9; in ffi_prep_closure_loc()
344 *(void **)(closure->tramp + 8) = ffi_closure_struct_SYSV; in ffi_prep_closure_loc()
346 *(void **)(closure->tramp + 8) = ffi_closure_SYSV; in ffi_prep_closure_loc()
[all …]
|
| /external/libffi/src/m68k/ |
| D | ffi.c | 30 unsigned int ffi_closure_SYSV_inner (ffi_closure *closure,
309 ffi_closure_SYSV_inner (ffi_closure *closure, void *resp, void *args) in ffi_closure_SYSV_inner() argument
314 cif = closure->cif; in ffi_closure_SYSV_inner()
319 (closure->fun) (cif, resp, arg_area, closure->user_data); in ffi_closure_SYSV_inner()
325 ffi_prep_closure_loc (ffi_closure* closure, in ffi_prep_closure_loc() argument
334 *(unsigned short *)closure->tramp = 0x207c; in ffi_prep_closure_loc()
335 *(void **)(closure->tramp + 2) = codeloc; in ffi_prep_closure_loc()
336 *(unsigned short *)(closure->tramp + 6) = 0x4ef9; in ffi_prep_closure_loc()
344 *(void **)(closure->tramp + 8) = ffi_closure_struct_SYSV; in ffi_prep_closure_loc()
346 *(void **)(closure->tramp + 8) = ffi_closure_SYSV; in ffi_prep_closure_loc()
[all …]
|