| /third_party/gstreamer/gstplugins_bad/gst-libs/gst/vulkan/ |
| D | gstvkhandle.c | 53 gst_vulkan_handle_free (GstVulkanHandle * handle) in gst_vulkan_handle_free() argument
55 GST_TRACE ("Freeing %p", handle); in gst_vulkan_handle_free()
57 if (handle->notify) in gst_vulkan_handle_free()
58 handle->notify (handle, handle->user_data); in gst_vulkan_handle_free()
60 gst_clear_object (&handle->device); in gst_vulkan_handle_free()
62 g_free (handle); in gst_vulkan_handle_free()
66 gst_vulkan_handle_init (GstVulkanHandle * handle, GstVulkanDevice * device, in gst_vulkan_handle_init() argument
70 handle->device = gst_object_ref (device); in gst_vulkan_handle_init()
71 handle->type = type; in gst_vulkan_handle_init()
72 handle->handle = handle_val; in gst_vulkan_handle_init()
[all …]
|
| /third_party/libuv/src/win/ |
| D | poll.c | 77 static void uv__fast_poll_submit_poll_req(uv_loop_t* loop, uv_poll_t* handle) { in uv__fast_poll_submit_poll_req() argument
83 if (handle->submitted_events_1 == 0) { in uv__fast_poll_submit_poll_req()
84 req = &handle->poll_req_1; in uv__fast_poll_submit_poll_req()
85 afd_poll_info = &handle->afd_poll_info_1; in uv__fast_poll_submit_poll_req()
86 handle->submitted_events_1 = handle->events; in uv__fast_poll_submit_poll_req()
87 handle->mask_events_1 = 0; in uv__fast_poll_submit_poll_req()
88 handle->mask_events_2 = handle->events; in uv__fast_poll_submit_poll_req()
89 } else if (handle->submitted_events_2 == 0) { in uv__fast_poll_submit_poll_req()
90 req = &handle->poll_req_2; in uv__fast_poll_submit_poll_req()
91 afd_poll_info = &handle->afd_poll_info_2; in uv__fast_poll_submit_poll_req()
[all …]
|
| D | handle-inl.h | 32 #define DECREASE_ACTIVE_COUNT(loop, handle) \ argument
34 if (--(handle)->activecnt == 0 && \
35 !((handle)->flags & UV_HANDLE_CLOSING)) { \
36 uv__handle_stop((handle)); \
38 assert((handle)->activecnt >= 0); \
42 #define INCREASE_ACTIVE_COUNT(loop, handle) \ argument
44 if ((handle)->activecnt++ == 0) { \
45 uv__handle_start((handle)); \
47 assert((handle)->activecnt > 0); \
51 #define DECREASE_PENDING_REQ_COUNT(handle) \ argument
[all …]
|
| D | tcp.c | 48 static int uv__tcp_nodelay(uv_tcp_t* handle, SOCKET socket, int enable) { in uv__tcp_nodelay() argument
60 static int uv__tcp_keepalive(uv_tcp_t* handle, SOCKET socket, int enable, unsigned int delay) { in uv__tcp_keepalive() argument
82 uv_tcp_t* handle, in uv__tcp_set_socket() argument
90 if (handle->socket != INVALID_SOCKET) in uv__tcp_set_socket()
109 handle->flags |= UV_HANDLE_EMULATE_IOCP; in uv__tcp_set_socket()
121 if (!(handle->flags & UV_HANDLE_EMULATE_IOCP) && !non_ifs_lsp) { in uv__tcp_set_socket()
126 handle->flags |= UV_HANDLE_SYNC_BYPASS_IOCP; in uv__tcp_set_socket()
129 if (handle->flags & UV_HANDLE_TCP_NODELAY) { in uv__tcp_set_socket()
130 err = uv__tcp_nodelay(handle, socket, 1); in uv__tcp_set_socket()
136 if (handle->flags & UV_HANDLE_TCP_KEEPALIVE) { in uv__tcp_set_socket()
[all …]
|
| D | udp.c | 39 int uv_udp_getpeername(const uv_udp_t* handle, in uv_udp_getpeername() argument
43 return uv__getsockpeername((const uv_handle_t*) handle, in uv_udp_getpeername()
51 int uv_udp_getsockname(const uv_udp_t* handle, in uv_udp_getsockname() argument
55 return uv__getsockpeername((const uv_handle_t*) handle, in uv_udp_getsockname()
63 static int uv__udp_set_socket(uv_loop_t* loop, uv_udp_t* handle, SOCKET socket, in uv__udp_set_socket() argument
69 if (handle->socket != INVALID_SOCKET) in uv__udp_set_socket()
108 handle->flags |= UV_HANDLE_SYNC_BYPASS_IOCP; in uv__udp_set_socket()
109 handle->func_wsarecv = uv__wsarecv_workaround; in uv__udp_set_socket()
110 handle->func_wsarecvfrom = uv__wsarecvfrom_workaround; in uv__udp_set_socket()
116 handle->socket = socket; in uv__udp_set_socket()
[all …]
|
| D | signal.c | 37 int uv__signal_start(uv_signal_t* handle,
82 uv_signal_t* handle; in RB_GENERATE_STATIC() local
92 for (handle = RB_NFIND(uv_signal_tree_s, &uv__signal_tree, &lookup); in RB_GENERATE_STATIC()
93 handle != NULL && handle->signum == signum; in RB_GENERATE_STATIC()
94 handle = RB_NEXT(uv_signal_tree_s, &uv__signal_tree, handle)) { in RB_GENERATE_STATIC()
96 (volatile LONG*) &handle->pending_signum, signum); in RB_GENERATE_STATIC()
98 if (handle->flags & UV_SIGNAL_ONE_SHOT_DISPATCHED) in RB_GENERATE_STATIC()
102 POST_COMPLETION_FOR_REQ(handle->loop, &handle->signal_req); in RB_GENERATE_STATIC()
106 if (handle->flags & UV_SIGNAL_ONE_SHOT) in RB_GENERATE_STATIC()
107 handle->flags |= UV_SIGNAL_ONE_SHOT_DISPATCHED; in RB_GENERATE_STATIC()
[all …]
|
| D | fs-event.c | 37 uv_fs_event_t* handle) { in uv__fs_event_queue_readdirchanges() argument
38 assert(handle->dir_handle != INVALID_HANDLE_VALUE); in uv__fs_event_queue_readdirchanges()
39 assert(!handle->req_pending); in uv__fs_event_queue_readdirchanges()
41 memset(&(handle->req.u.io.overlapped), 0, in uv__fs_event_queue_readdirchanges()
42 sizeof(handle->req.u.io.overlapped)); in uv__fs_event_queue_readdirchanges()
43 if (!ReadDirectoryChangesW(handle->dir_handle, in uv__fs_event_queue_readdirchanges()
44 handle->buffer, in uv__fs_event_queue_readdirchanges()
46 (handle->flags & UV_FS_EVENT_RECURSIVE) ? TRUE : FALSE, in uv__fs_event_queue_readdirchanges()
56 &handle->req.u.io.overlapped, in uv__fs_event_queue_readdirchanges()
59 SET_REQ_ERROR(&handle->req, GetLastError()); in uv__fs_event_queue_readdirchanges()
[all …]
|
| D | tty.c | 74 static int uv__cancel_read_console(uv_tty_t* handle);
164 static void uv__determine_vterm_state(HANDLE handle);
193 HANDLE handle; in uv_tty_init() local
199 handle = (HANDLE) uv__get_osfhandle(fd); in uv_tty_init()
200 if (handle == INVALID_HANDLE_VALUE) in uv_tty_init()
211 handle, in uv_tty_init()
213 &handle, in uv_tty_init()
221 readable = GetNumberOfConsoleInputEvents(handle, &NumberOfEvents); in uv_tty_init()
224 if (!GetConsoleScreenBufferInfo(handle, &screen_buffer_info)) { in uv_tty_init()
229 if (!GetConsoleCursorInfo(handle, &cursor_info)) { in uv_tty_init()
[all …]
|
| D | pipe.c | 98 static void eof_timer_close_cb(uv_handle_t* handle);
106 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { in uv_pipe_init() argument
107 uv__stream_init(loop, (uv_stream_t*)handle, UV_NAMED_PIPE); in uv_pipe_init()
109 handle->reqs_pending = 0; in uv_pipe_init()
110 handle->handle = INVALID_HANDLE_VALUE; in uv_pipe_init()
111 handle->name = NULL; in uv_pipe_init()
112 handle->pipe.conn.ipc_remote_pid = 0; in uv_pipe_init()
113 handle->pipe.conn.ipc_data_frame.payload_remaining = 0; in uv_pipe_init()
114 QUEUE_INIT(&handle->pipe.conn.ipc_xfer_queue); in uv_pipe_init()
115 handle->pipe.conn.ipc_xfer_queue_length = 0; in uv_pipe_init()
[all …]
|
| D | handle.c | 32 HANDLE handle; in uv_guess_handle() local
39 handle = uv__get_osfhandle(file); in uv_guess_handle()
41 switch (GetFileType(handle)) { in uv_guess_handle()
43 if (GetConsoleMode(handle, &mode)) { in uv_guess_handle()
61 int uv_is_active(const uv_handle_t* handle) { in uv_is_active() argument
62 return (handle->flags & UV_HANDLE_ACTIVE) && in uv_is_active()
63 !(handle->flags & UV_HANDLE_CLOSING); in uv_is_active()
67 void uv_close(uv_handle_t* handle, uv_close_cb cb) { in uv_close() argument
68 uv_loop_t* loop = handle->loop; in uv_close()
70 if (handle->flags & UV_HANDLE_CLOSING) { in uv_close()
[all …]
|
| D | async.c | 31 void uv__async_endgame(uv_loop_t* loop, uv_async_t* handle) { in uv__async_endgame() argument
32 if (handle->flags & UV_HANDLE_CLOSING && in uv__async_endgame()
33 !handle->async_sent) { in uv__async_endgame()
34 assert(!(handle->flags & UV_HANDLE_CLOSED)); in uv__async_endgame()
35 uv__handle_close(handle); in uv__async_endgame()
40 int uv_async_init(uv_loop_t* loop, uv_async_t* handle, uv_async_cb async_cb) { in uv_async_init() argument
43 uv__handle_init(loop, (uv_handle_t*) handle, UV_ASYNC); in uv_async_init()
44 handle->async_sent = 0; in uv_async_init()
45 handle->async_cb = async_cb; in uv_async_init()
47 req = &handle->async_req; in uv_async_init()
[all …]
|
| D | loop-watcher.c | 29 void uv__loop_watcher_endgame(uv_loop_t* loop, uv_handle_t* handle) { in uv__loop_watcher_endgame() argument
30 if (handle->flags & UV_HANDLE_CLOSING) { in uv__loop_watcher_endgame()
31 assert(!(handle->flags & UV_HANDLE_CLOSED)); in uv__loop_watcher_endgame()
32 handle->flags |= UV_HANDLE_CLOSED; in uv__loop_watcher_endgame()
33 uv__handle_close(handle); in uv__loop_watcher_endgame()
39 int uv_##name##_init(uv_loop_t* loop, uv_##name##_t* handle) { \
40 uv__handle_init(loop, (uv_handle_t*) handle, UV_##NAME); \
46 int uv_##name##_start(uv_##name##_t* handle, uv_##name##_cb cb) { \
47 uv_loop_t* loop = handle->loop; \
50 assert(handle->type == UV_##NAME); \
[all …]
|
| D | stream.c | 68 int uv__read_start(uv_stream_t* handle, in uv__read_start() argument
74 switch (handle->type) { in uv__read_start()
76 err = uv__tcp_read_start((uv_tcp_t*)handle, alloc_cb, read_cb); in uv__read_start()
79 err = uv__pipe_read_start((uv_pipe_t*)handle, alloc_cb, read_cb); in uv__read_start()
82 err = uv__tty_read_start((uv_tty_t*) handle, alloc_cb, read_cb); in uv__read_start()
92 int uv_read_stop(uv_stream_t* handle) { in uv_read_stop() argument
95 if (!(handle->flags & UV_HANDLE_READING)) in uv_read_stop()
99 if (handle->type == UV_TTY) { in uv_read_stop()
100 err = uv__tty_read_stop((uv_tty_t*) handle); in uv_read_stop()
101 } else if (handle->type == UV_NAMED_PIPE) { in uv_read_stop()
[all …]
|
| /third_party/NuttX/drivers/usbdev/gadget/fconfig/src/ |
| D | usb_handle.c | 80 struct usb_handle *handle = NULL; in handle_find_by_name() local
90 list_for_each_entry(handle, &g_hanle_list, entry) in handle_find_by_name()
92 if (strcmp(handle->name, devName) == 0) in handle_find_by_name()
100 return found ? handle : NULL; in handle_find_by_name()
105 struct usb_handle *handle = NULL; in handle_find_by_fd() local
115 list_for_each_entry(handle, &g_hanle_list, entry) in handle_find_by_fd()
117 if (handle->fd == fd) in handle_find_by_fd()
125 return found ? handle : NULL; in handle_find_by_fd()
130 struct usb_handle *handle = NULL; in register_handle() local
136 handle = handle_find_by_name(devName); in register_handle()
[all …]
|
| /third_party/libuv/src/ |
| D | timer.c | 58 int uv_timer_init(uv_loop_t* loop, uv_timer_t* handle) { in uv_timer_init() argument
59 uv__handle_init(loop, (uv_handle_t*)handle, UV_TIMER); in uv_timer_init()
60 handle->timer_cb = NULL; in uv_timer_init()
61 handle->timeout = 0; in uv_timer_init()
62 handle->repeat = 0; in uv_timer_init()
67 int uv_timer_start(uv_timer_t* handle, in uv_timer_start() argument
73 if (uv__is_closing(handle) || cb == NULL) in uv_timer_start()
76 if (uv__is_active(handle)) in uv_timer_start()
77 uv_timer_stop(handle); in uv_timer_start()
79 clamped_timeout = handle->loop->time + timeout; in uv_timer_start()
[all …]
|
| /third_party/musl/libc-test/src/functionalext/ldso_randomization/ |
| D | ldso_randomization_test.c | 49 void *handle = dlopen(LIB_NAME, RTLD_NOW); in dlopen_randomization_0100() local
50 EXPECT_PTRNE(__FUNCTION__, handle, 0); in dlopen_randomization_0100()
51 if (handle) { in dlopen_randomization_0100()
52 EXPECT_EQ(__FUNCTION__, dlclose(handle), 0); in dlopen_randomization_0100()
63 void *handle = dlopen(NULL, RTLD_NOW); in dlopen_randomization_0200() local
64 EXPECT_PTRNE(__FUNCTION__, handle, 0); in dlopen_randomization_0200()
65 if (!handle) { in dlopen_randomization_0200()
68 int *i = dlsym(handle, "g_test"); in dlopen_randomization_0200()
71 dlclose(handle); in dlopen_randomization_0200()
75 TEST_FUNC test = (TEST_FUNC)dlsym(handle, "test_f"); in dlopen_randomization_0200()
[all …]
|
| /third_party/e2fsprogs/lib/ext2fs/ |
| D | extent.c | 127 static void dump_path(const char *tag, struct ext2_extent_handle *handle, in dump_path() argument
131 printf("%s: level=%d\n", tag, handle->level); in dump_path()
136 tag, (ppp - handle->path), ppp->buf, ppp->entries, in dump_path()
148 } while (ppp >= handle->path); in dump_path()
159 #define dump_path(tag, handle, path) do { } while (0) argument
194 void ext2fs_extent_free(ext2_extent_handle_t handle) in ext2fs_extent_free() argument
198 if (!handle) in ext2fs_extent_free()
201 if (handle->path) { in ext2fs_extent_free()
202 for (i = 1; i < handle->max_paths; i++) { in ext2fs_extent_free()
203 if (handle->path[i].buf) in ext2fs_extent_free()
[all …]
|
| /third_party/musl/src/network/ |
| D | ns_parse.c | 50 int ns_initparse(const unsigned char *msg, int msglen, ns_msg *handle) in ns_initparse() argument
54 handle->_msg = msg; in ns_initparse()
55 handle->_eom = msg + msglen; in ns_initparse()
57 NS_GET16(handle->_id, msg); in ns_initparse()
58 NS_GET16(handle->_flags, msg); in ns_initparse()
59 for (i = 0; i < ns_s_max; i++) NS_GET16(handle->_counts[i], msg); in ns_initparse()
61 if (handle->_counts[i]) { in ns_initparse()
62 handle->_sections[i] = msg; in ns_initparse()
63 r = ns_skiprr(msg, handle->_eom, i, handle->_counts[i]); in ns_initparse()
67 handle->_sections[i] = NULL; in ns_initparse()
[all …]
|
| /third_party/boost/libs/iostreams/test/ |
| D | deprecated_file_descriptor_test.cpp | 26 boost_ios::detail::file_handle handle = ios_test::open_file_handle(test1.name()); in file_handle_test_impl() local
28 FileDescriptor device1(handle); in file_handle_test_impl()
29 BOOST_CHECK(device1.handle() == handle); in file_handle_test_impl()
31 BOOST_CHECK_HANDLE_OPEN(handle); in file_handle_test_impl()
32 ios_test::close_file_handle(handle); in file_handle_test_impl()
36 boost_ios::detail::file_handle handle = ios_test::open_file_handle(test1.name()); in file_handle_test_impl() local
38 FileDescriptor device1(handle, false); in file_handle_test_impl()
39 BOOST_CHECK(device1.handle() == handle); in file_handle_test_impl()
41 BOOST_CHECK_HANDLE_OPEN(handle); in file_handle_test_impl()
42 ios_test::close_file_handle(handle); in file_handle_test_impl()
[all …]
|
| /third_party/flutter/engine/flutter/vulkan/ |
| D | vulkan_proc_table.cc | 73 const VulkanHandle<VkInstance>& handle) { in SetupInstanceProcAddresses() argument
74 ACQUIRE_PROC(CreateDevice, handle); in SetupInstanceProcAddresses()
75 ACQUIRE_PROC(DestroyDevice, handle); in SetupInstanceProcAddresses()
76 ACQUIRE_PROC(DestroyInstance, handle); in SetupInstanceProcAddresses()
77 ACQUIRE_PROC(EnumerateDeviceLayerProperties, handle); in SetupInstanceProcAddresses()
78 ACQUIRE_PROC(EnumeratePhysicalDevices, handle); in SetupInstanceProcAddresses()
79 ACQUIRE_PROC(GetDeviceProcAddr, handle); in SetupInstanceProcAddresses()
80 ACQUIRE_PROC(GetPhysicalDeviceFeatures, handle); in SetupInstanceProcAddresses()
81 ACQUIRE_PROC(GetPhysicalDeviceQueueFamilyProperties, handle); in SetupInstanceProcAddresses()
83 ACQUIRE_PROC(GetPhysicalDeviceSurfaceCapabilitiesKHR, handle); in SetupInstanceProcAddresses()
[all …]
|
| /third_party/libuv/src/unix/ |
| D | udp.c | 49 static void uv__udp_run_completed(uv_udp_t* handle);
51 static void uv__udp_recvmsg(uv_udp_t* handle);
52 static void uv__udp_sendmsg(uv_udp_t* handle);
53 static int uv__udp_maybe_deferred_bind(uv_udp_t* handle,
61 static int uv__udp_recvmmsg(uv_udp_t* handle, uv_buf_t* buf);
62 static void uv__udp_sendmmsg(uv_udp_t* handle);
88 void uv__udp_close(uv_udp_t* handle) { in uv__udp_close() argument
89 uv__io_close(handle->loop, &handle->io_watcher); in uv__udp_close()
90 uv__handle_stop(handle); in uv__udp_close()
92 if (handle->io_watcher.fd != -1) { in uv__udp_close()
[all …]
|
| D | pipe.c | 33 int uv_pipe_init(uv_loop_t* loop, uv_pipe_t* handle, int ipc) { in uv_pipe_init() argument
34 uv__stream_init(loop, (uv_stream_t*)handle, UV_NAMED_PIPE); in uv_pipe_init()
35 handle->shutdown_req = NULL; in uv_pipe_init()
36 handle->connect_req = NULL; in uv_pipe_init()
37 handle->pipe_fname = NULL; in uv_pipe_init()
38 handle->ipc = ipc; in uv_pipe_init()
43 int uv_pipe_bind(uv_pipe_t* handle, const char* name) { in uv_pipe_bind() argument
52 if (uv__stream_fd(handle) >= 0) in uv_pipe_bind()
83 handle->flags |= UV_HANDLE_BOUND; in uv_pipe_bind()
84 handle->pipe_fname = pipe_fname; /* Is a strdup'ed copy. */ in uv_pipe_bind()
[all …]
|
| /third_party/skia/third_party/externals/angle2/src/compiler/translator/ |
| D | ShaderLang.cpp | 57 TCompiler *GetCompilerFromHandle(ShHandle handle) in GetCompilerFromHandle() argument
59 if (!handle) in GetCompilerFromHandle()
64 TShHandleBase *base = static_cast<TShHandleBase *>(handle); in GetCompilerFromHandle()
69 const std::vector<VarT> *GetShaderVariables(const ShHandle handle) in GetShaderVariables() argument
71 TCompiler *compiler = GetCompilerFromHandle(handle); in GetShaderVariables()
81 TranslatorHLSL *GetTranslatorHLSLFromHandle(ShHandle handle) in GetTranslatorHLSLFromHandle() argument
83 if (!handle) in GetTranslatorHLSLFromHandle()
85 TShHandleBase *base = static_cast<TShHandleBase *>(handle); in GetTranslatorHLSLFromHandle()
375 void Destruct(ShHandle handle) in Destruct() argument
377 if (handle == 0) in Destruct()
[all …]
|
| /third_party/skia/third_party/externals/brotli/java/org/brotli/wrapper/dec/ |
| D | decoder_jni.cc | 47 DecoderHandle* handle = nullptr; in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate() local
53 handle = new (std::nothrow) DecoderHandle(); in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate()
54 ok = !!handle; in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate()
57 handle->input_offset = 0; in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate()
58 handle->input_length = 0; in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate()
59 handle->input_start = nullptr; in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate()
64 handle->input_start = new (std::nothrow) uint8_t[input_size]; in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate()
65 ok = !!handle->input_start; in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate()
70 handle->state = BrotliDecoderCreateInstance(nullptr, nullptr, nullptr); in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate()
71 ok = !!handle->state; in Java_org_brotli_wrapper_dec_DecoderJNI_nativeCreate()
[all …]
|
| /third_party/skia/third_party/externals/brotli/java/org/brotli/wrapper/enc/ |
| D | encoder_jni.cc | 47 EncoderHandle* handle = nullptr; in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate() local
52 handle = new (std::nothrow) EncoderHandle(); in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate()
53 ok = !!handle; in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate()
56 handle->input_offset = 0; in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate()
57 handle->input_last = 0; in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate()
58 handle->input_start = nullptr; in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate()
63 handle->input_start = new (std::nothrow) uint8_t[input_size]; in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate()
64 ok = !!handle->input_start; in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate()
69 handle->state = BrotliEncoderCreateInstance(nullptr, nullptr, nullptr); in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate()
70 ok = !!handle->state; in Java_org_brotli_wrapper_enc_EncoderJNI_nativeCreate()
[all …]
|