Home
last modified time | relevance | path

Searched refs:overlapped (Results 1 - 25 of 45) sorted by relevance

12

/third_party/libuv/src/win/
H A Dwinsock.c266 * bit has been set, and supports only overlapped operation. It also requires
271 DWORD buffer_count, DWORD* bytes, DWORD* flags, WSAOVERLAPPED *overlapped, in uv__wsarecv_workaround()
275 IO_STATUS_BLOCK* iosb = (IO_STATUS_BLOCK*) &overlapped->Internal; in uv__wsarecv_workaround()
279 if (overlapped == NULL || completion_routine != NULL) { in uv__wsarecv_workaround()
297 if (!((intptr_t) overlapped->hEvent & 1)) { in uv__wsarecv_workaround()
298 apc_context = (void*) overlapped; in uv__wsarecv_workaround()
307 overlapped->hEvent, in uv__wsarecv_workaround()
366 int* addr_len, WSAOVERLAPPED *overlapped, in uv__wsarecvfrom_workaround()
370 IO_STATUS_BLOCK* iosb = (IO_STATUS_BLOCK*) &overlapped->Internal; in uv__wsarecvfrom_workaround()
374 if (overlapped in uv__wsarecvfrom_workaround()
270 uv__wsarecv_workaround(SOCKET socket, WSABUF* buffers, DWORD buffer_count, DWORD* bytes, DWORD* flags, WSAOVERLAPPED *overlapped, LPWSAOVERLAPPED_COMPLETION_ROUTINE completion_routine) uv__wsarecv_workaround() argument
364 uv__wsarecvfrom_workaround(SOCKET socket, WSABUF* buffers, DWORD buffer_count, DWORD* bytes, DWORD* flags, struct sockaddr* addr, int* addr_len, WSAOVERLAPPED *overlapped, LPWSAOVERLAPPED_COMPLETION_ROUTINE completion_routine) uv__wsarecvfrom_workaround() argument
461 uv__msafd_poll(SOCKET socket, AFD_POLL_INFO* info_in, AFD_POLL_INFO* info_out, OVERLAPPED* overlapped) uv__msafd_poll() argument
[all...]
H A Dreq-inl.h32 (req)->u.io.overlapped.Internal = (ULONG_PTR) (status)
44 ((NTSTATUS) (req)->u.io.overlapped.Internal)
80 &((req)->u.io.overlapped))) { \
85 INLINE static uv_req_t* uv__overlapped_to_req(OVERLAPPED* overlapped) { in uv__overlapped_to_req() argument
86 return CONTAINING_RECORD(overlapped, uv_req_t, u.io.overlapped); in uv__overlapped_to_req()
H A Dtcp.c354 req->u.io.overlapped.InternalHigh, in post_completion()
356 &req->u.io.overlapped)) { in post_completion()
373 req->u.io.overlapped.InternalHigh, in post_write_completion()
375 &req->u.io.overlapped)) { in post_write_completion()
416 /* Prepare the overlapped structure. */ in uv__tcp_queue_accept()
417 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_accept()
420 req->u.io.overlapped.hEvent = (HANDLE) ((ULONG_PTR) req->event_handle | 1); in uv__tcp_queue_accept()
430 &req->u.io.overlapped); in uv__tcp_queue_accept()
475 memset(&req->u.io.overlapped, in uv__tcp_queue_read()
[all...]
H A Dfs-event.c41 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()
56 &handle->req.u.io.overlapped, in uv__fs_event_queue_readdirchanges()
295 memset(&(handle->req.u.io.overlapped), 0, in uv_fs_event_start()
296 sizeof(handle->req.u.io.overlapped)); in uv_fs_event_start()
311 &handle->req.u.io.overlapped, in uv_fs_event_start()
443 if (req->u.io.overlapped.InternalHigh > 0) { in uv__process_fs_event_req()
H A Dudp.c272 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__udp_queue_recv()
285 &req->u.io.overlapped, in uv__udp_queue_recv()
291 req->u.io.overlapped.InternalHigh = bytes; in uv__udp_queue_recv()
361 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__send()
370 &req->u.io.overlapped, in uv__send()
436 req->u.io.overlapped.InternalHigh, in uv__process_udp_recv_req()
H A Dpoll.c125 memset(&req->u.io.overlapped, 0, sizeof req->u.io.overlapped); in uv__fast_poll_submit_poll_req()
130 &req->u.io.overlapped); in uv__fast_poll_submit_poll_req()
331 req->u.io.overlapped.InternalHigh = (DWORD) reported_events; in uv__slow_poll_thread_proc()
393 int events = req->u.io.overlapped.InternalHigh & handle->events & ~mask_events; in uv__slow_poll_process_poll_req()
H A Dcore.c432 OVERLAPPED* overlapped; in uv__poll_wine() local
466 &overlapped, in uv__poll_wine()
470 if (overlapped && timeout == 0) in uv__poll_wine()
483 if (overlapped) { in uv__poll_wine()
487 req = uv__overlapped_to_req(overlapped); in uv__poll_wine()
/third_party/node/deps/uv/src/win/
H A Dwinsock.c266 * bit has been set, and supports only overlapped operation. It also requires
271 DWORD buffer_count, DWORD* bytes, DWORD* flags, WSAOVERLAPPED *overlapped, in uv__wsarecv_workaround()
275 IO_STATUS_BLOCK* iosb = (IO_STATUS_BLOCK*) &overlapped->Internal; in uv__wsarecv_workaround()
279 if (overlapped == NULL || completion_routine != NULL) { in uv__wsarecv_workaround()
297 if (!((intptr_t) overlapped->hEvent & 1)) { in uv__wsarecv_workaround()
298 apc_context = (void*) overlapped; in uv__wsarecv_workaround()
307 overlapped->hEvent, in uv__wsarecv_workaround()
366 int* addr_len, WSAOVERLAPPED *overlapped, in uv__wsarecvfrom_workaround()
370 IO_STATUS_BLOCK* iosb = (IO_STATUS_BLOCK*) &overlapped->Internal; in uv__wsarecvfrom_workaround()
374 if (overlapped in uv__wsarecvfrom_workaround()
270 uv__wsarecv_workaround(SOCKET socket, WSABUF* buffers, DWORD buffer_count, DWORD* bytes, DWORD* flags, WSAOVERLAPPED *overlapped, LPWSAOVERLAPPED_COMPLETION_ROUTINE completion_routine) uv__wsarecv_workaround() argument
364 uv__wsarecvfrom_workaround(SOCKET socket, WSABUF* buffers, DWORD buffer_count, DWORD* bytes, DWORD* flags, struct sockaddr* addr, int* addr_len, WSAOVERLAPPED *overlapped, LPWSAOVERLAPPED_COMPLETION_ROUTINE completion_routine) uv__wsarecvfrom_workaround() argument
461 uv__msafd_poll(SOCKET socket, AFD_POLL_INFO* info_in, AFD_POLL_INFO* info_out, OVERLAPPED* overlapped) uv__msafd_poll() argument
[all...]
H A Dreq-inl.h32 (req)->u.io.overlapped.Internal = (ULONG_PTR) (status)
44 ((NTSTATUS) (req)->u.io.overlapped.Internal)
80 &((req)->u.io.overlapped))) { \
85 INLINE static uv_req_t* uv__overlapped_to_req(OVERLAPPED* overlapped) { in uv__overlapped_to_req() argument
86 return CONTAINING_RECORD(overlapped, uv_req_t, u.io.overlapped); in uv__overlapped_to_req()
H A Dtcp.c364 req->u.io.overlapped.InternalHigh, in post_completion()
366 &req->u.io.overlapped)) { in post_completion()
383 req->u.io.overlapped.InternalHigh, in post_write_completion()
385 &req->u.io.overlapped)) { in post_write_completion()
426 /* Prepare the overlapped structure. */ in uv__tcp_queue_accept()
427 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_accept()
430 req->u.io.overlapped.hEvent = (HANDLE) ((ULONG_PTR) req->event_handle | 1); in uv__tcp_queue_accept()
440 &req->u.io.overlapped); in uv__tcp_queue_accept()
485 memset(&req->u.io.overlapped, in uv__tcp_queue_read()
[all...]
H A Dfs-event.c41 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()
56 &handle->req.u.io.overlapped, in uv__fs_event_queue_readdirchanges()
308 memset(&(handle->req.u.io.overlapped), 0, in uv_fs_event_start()
309 sizeof(handle->req.u.io.overlapped)); in uv_fs_event_start()
324 &handle->req.u.io.overlapped, in uv_fs_event_start()
453 if (req->u.io.overlapped.InternalHigh > 0) { in uv__process_fs_event_req()
H A Dudp.c277 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__udp_queue_recv()
306 &req->u.io.overlapped, in uv__udp_queue_recv()
312 req->u.io.overlapped.InternalHigh = bytes; in uv__udp_queue_recv()
338 &req->u.io.overlapped, in uv__udp_queue_recv()
344 req->u.io.overlapped.InternalHigh = bytes; in uv__udp_queue_recv()
417 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__send()
426 &req->u.io.overlapped, in uv__send()
492 req->u.io.overlapped in uv__process_udp_recv_req()
[all...]
H A Dpipe.c506 /* Non-overlapped pipe. */ in uv__set_pipe_handle()
918 r = CancelIoEx(handle->handle, &handle->read_req.u.io.overlapped); in uv__pipe_interrupt_read()
1026 /* Prepare the overlapped structure. */ in uv__pipe_queue_accept()
1027 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__pipe_queue_accept()
1029 if (!ConnectNamedPipe(req->pipeHandle, &req->u.io.overlapped) && in uv__pipe_queue_accept()
1257 req->u.io.overlapped.InternalHigh, in post_completion_read_wait()
1259 &req->u.io.overlapped)) { in post_completion_read_wait()
1276 req->u.io.overlapped.InternalHigh, in post_completion_write_wait()
1278 &req->u.io.overlapped)) { in post_completion_write_wait()
[all...]
H A Dpoll.c123 memset(&req->u.io.overlapped, 0, sizeof req->u.io.overlapped); in uv__fast_poll_submit_poll_req()
128 &req->u.io.overlapped); in uv__fast_poll_submit_poll_req()
329 req->u.io.overlapped.InternalHigh = (DWORD) reported_events; in uv__slow_poll_thread_proc()
391 int events = req->u.io.overlapped.InternalHigh & handle->events & ~mask_events; in uv__slow_poll_process_poll_req()
/third_party/python/Modules/
H A Doverlapped.c2 * Support for overlapped IO
71 OVERLAPPED overlapped; member
618 * for overlapped I/O
653 memset(&self->overlapped, 0, sizeof(OVERLAPPED)); in _overlapped_Overlapped_impl()
656 self->overlapped.hEvent = event; in _overlapped_Overlapped_impl()
662 buffers while overlapped are still running, to prevent a crash. */
716 if (!HasOverlappedIoCompleted(&self->overlapped) && in Overlapped_dealloc()
720 if (CancelIoEx(self->handle, &self->overlapped)) in Overlapped_dealloc()
723 ret = GetOverlappedResult(self->handle, &self->overlapped, in Overlapped_dealloc()
741 if (self->overlapped in Overlapped_dealloc()
[all...]
H A D_winapi.c97 * for overlapped I/O
102 OVERLAPPED overlapped; member
138 Py_CancelIoEx(self->handle, &self->overlapped) && in overlapped_dealloc()
139 GetOverlappedResult(self->handle, &self->overlapped, &bytes, TRUE)) in overlapped_dealloc()
160 CloseHandle(self->overlapped.hEvent); in overlapped_dealloc()
166 CloseHandle(self->overlapped.hEvent); in overlapped_dealloc()
251 res = GetOverlappedResult(self->handle, &self->overlapped, &transferred, in _winapi_Overlapped_GetOverlappedResult_impl()
311 res = Py_CancelIoEx(self->handle, &self->overlapped); in _winapi_Overlapped_cancel_impl()
333 offsetof(OverlappedObject, overlapped) + offsetof(OVERLAPPED, hEvent),
334 READONLY, "overlapped even
417 OverlappedObject *overlapped = NULL; _winapi_ConnectNamedPipe_impl() local
1624 OverlappedObject *overlapped = NULL; _winapi_ReadFile_impl() local
1910 OverlappedObject *overlapped = NULL; _winapi_WriteFile_impl() local
[all...]
/third_party/python/Lib/asyncio/
H A Dwindows_utils.py32 def pipe(*, duplex=False, overlapped=(True, True), bufsize=BUFSIZE):
33 """Like os.pipe() but with overlapped support and using handles not fds."""
49 if overlapped[0]:
52 if overlapped[1]:
67 ov = _winapi.ConnectNamedPipe(h1, overlapped=True)
82 """Wrapper for an overlapped pipe handle which is vaguely file-object like.
122 # Replacement for subprocess.Popen using overlapped pipe handles
126 """Replacement for subprocess.Popen using overlapped pipe handles.
136 stdin_rh, stdin_wh = pipe(overlapped=(False, True), duplex=True)
141 stdout_rh, stdout_wh = pipe(overlapped
[all...]
/third_party/vk-gl-cts/execserver/
H A DxsWin32TestProcess.cpp133 OVERLAPPED overlapped; in run() local
136 deMemset(&overlapped, 0, sizeof(overlapped)); in run()
137 overlapped.hEvent = ioEvent.getHandle(); in run()
145 if (!WriteFile(m_dst, &m_caseList[curPos], (DWORD)numToWrite, NULL, &overlapped)) in run()
159 if (!GetOverlappedResult(m_dst, &overlapped, &numBytesWritten, FALSE)) in run()
228 OVERLAPPED overlapped; in run() local
232 deMemset(&overlapped, 0, sizeof(overlapped)); in run()
233 overlapped in run()
[all...]
/third_party/gn/src/base/files/
H A Dfile_win.cc61 OVERLAPPED overlapped = {}; in Read() local
62 overlapped.Offset = offset_li.LowPart; in Read()
63 overlapped.OffsetHigh = offset_li.HighPart; in Read()
66 if (::ReadFile(file_.Get(), data, size, &bytes_read, &overlapped)) in Read()
104 OVERLAPPED overlapped = {}; in Write() local
105 overlapped.Offset = offset_li.LowPart; in Write()
106 overlapped.OffsetHigh = offset_li.HighPart; in Write()
109 if (::WriteFile(file_.Get(), data, size, &bytes_written, &overlapped)) in Write()
/third_party/libuv/test/
H A Drunner-win.c246 OVERLAPPED overlapped; in process_read_last_line() local
259 memset(&overlapped, 0, sizeof overlapped); in process_read_last_line()
261 overlapped.Offset = size - buffer_len - 1; in process_read_last_line()
263 if (!ReadFile(p->stdio_out, buffer, buffer_len - 1, &read, &overlapped)) in process_read_last_line()
/third_party/skia/src/ports/
H A DSkOSFile_win.cpp138 OVERLAPPED overlapped; in sk_qread() local
139 memset(&overlapped, 0, sizeof(overlapped)); in sk_qread()
142 overlapped.Offset = winOffset.LowPart; in sk_qread()
143 overlapped.OffsetHigh = winOffset.HighPart; in sk_qread()
150 if (ReadFile(fileHandle, buffer, static_cast<DWORD>(count), &bytesRead, &overlapped)) { in sk_qread()
/third_party/node/deps/cares/src/lib/
H A Dares_event_win32.c70 * - OVERLAPPED overlapped; -- Used by AFD POLL
135 * NtDeviceIoControlFile((HANDLE)peer_socket, NULL, NULL, &overlapped,
178 OVERLAPPED overlapped; member
359 memset(&ed->overlapped, 0, sizeof(ed->overlapped)); in ares_evsys_win32_afd_enqueue()
360 iosb_ptr = (IO_STATUS_BLOCK *)&ed->overlapped.Internal; in ares_evsys_win32_afd_enqueue()
364 (HANDLE)ed->peer_socket, NULL, NULL, &ed->overlapped, iosb_ptr, in ares_evsys_win32_afd_enqueue()
388 iosb_ptr = (IO_STATUS_BLOCK *)&ed->overlapped.Internal; in ares_evsys_win32_afd_cancel()
/third_party/wpa_supplicant/wpa_supplicant-2.9/src/l2_packet/
H A Dl2_packet_ndis.c13 * WinXP version of the code uses overlapped I/O and a single threaded design
98 OVERLAPPED overlapped; in l2_packet_send() local
108 os_memset(&overlapped, 0, sizeof(overlapped)); in l2_packet_send()
109 o = &overlapped; in l2_packet_send()
137 driver_ndis_get_ndisuio_handle(), &overlapped, in l2_packet_send()
/third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/l2_packet/
H A Dl2_packet_ndis.c13 * WinXP version of the code uses overlapped I/O and a single threaded design
98 OVERLAPPED overlapped; in l2_packet_send() local
108 os_memset(&overlapped, 0, sizeof(overlapped)); in l2_packet_send()
109 o = &overlapped; in l2_packet_send()
137 driver_ndis_get_ndisuio_handle(), &overlapped, in l2_packet_send()
/third_party/curl/lib/
H A Dasyn-thread.c152 OVERLAPPED overlapped; member
298 query_complete(DWORD err, DWORD bytes, LPWSAOVERLAPPED overlapped) in query_complete() argument
310 CONTAINING_RECORD(overlapped, struct thread_sync_data, w8.overlapped); in query_complete()
659 NULL, &td->tsd.w8.overlapped, in init_resolve_thread()
662 query_complete(err, 0, &td->tsd.w8.overlapped); in init_resolve_thread()

Completed in 24 milliseconds

12