| /third_party/grpc/src/core/lib/iomgr/ |
| D | iocp_windows.cc | 62 LPOVERLAPPED overlapped; in grpc_iocp_work() local
67 GetQueuedCompletionStatus(g_iocp, &bytes, &completion_key, &overlapped, in grpc_iocp_work()
70 if (success == 0 && overlapped == NULL) { in grpc_iocp_work()
73 GPR_ASSERT(completion_key && overlapped); in grpc_iocp_work()
74 if (overlapped == &g_iocp_custom_overlap) { in grpc_iocp_work()
85 if (overlapped == &socket->write_info.overlapped) { in grpc_iocp_work()
87 } else if (overlapped == &socket->read_info.overlapped) { in grpc_iocp_work()
96 success = WSAGetOverlappedResult(socket->socket, &info->overlapped, &bytes, in grpc_iocp_work()
101 GPR_ASSERT(overlapped == &info->overlapped); in grpc_iocp_work()
|
| /third_party/libuv/src/win/ |
| D | winsock.c | 271 DWORD buffer_count, DWORD* bytes, DWORD* flags, WSAOVERLAPPED *overlapped, in uv__wsarecv_workaround() argument
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() argument
370 IO_STATUS_BLOCK* iosb = (IO_STATUS_BLOCK*) &overlapped->Internal; in uv__wsarecvfrom_workaround()
374 if (overlapped == NULL || addr == NULL || addr_len == NULL || in uv__wsarecvfrom_workaround()
395 if (!((intptr_t) overlapped->hEvent & 1)) { in uv__wsarecvfrom_workaround()
[all …]
|
| D | req-inl.h | 32 (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()
|
| D | tcp.c | 361 req->u.io.overlapped.InternalHigh, in post_completion()
363 &req->u.io.overlapped)) { in post_completion()
380 req->u.io.overlapped.InternalHigh, in post_write_completion()
382 &req->u.io.overlapped)) { in post_write_completion()
424 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_accept()
427 req->u.io.overlapped.hEvent = (HANDLE) ((ULONG_PTR) req->event_handle | 1); in uv__tcp_queue_accept()
437 &req->u.io.overlapped); in uv__tcp_queue_accept()
482 memset(&req->u.io.overlapped, 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_read()
506 memset(&(req->u.io.overlapped), 0, sizeof(req->u.io.overlapped)); in uv__tcp_queue_read()
509 req->u.io.overlapped.hEvent = (HANDLE) ((ULONG_PTR) req->event_handle | 1); in uv__tcp_queue_read()
[all …]
|
| D | fs-event.c | 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()
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()
|
| /third_party/python/Modules/ |
| D | _winapi.c | 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),
367 memset(&self->overlapped, 0, sizeof(OVERLAPPED)); in new_overlapped()
370 self->overlapped.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); in new_overlapped()
[all …]
|
| D | overlapped.c | 77 OVERLAPPED overlapped; member
639 memset(&self->overlapped, 0, sizeof(OVERLAPPED)); in _overlapped_Overlapped_impl()
642 self->overlapped.hEvent = event; in _overlapped_Overlapped_impl()
692 if (!HasOverlappedIoCompleted(&self->overlapped) && in Overlapped_dealloc()
695 if (Py_CancelIoEx && Py_CancelIoEx(self->handle, &self->overlapped)) in Overlapped_dealloc()
699 ret = GetOverlappedResult(self->handle, &self->overlapped, in Overlapped_dealloc()
717 if (self->overlapped.hEvent != NULL) { in Overlapped_dealloc()
718 CloseHandle(self->overlapped.hEvent); in Overlapped_dealloc()
809 if (!HasOverlappedIoCompleted(&self->overlapped)) { in _overlapped_Overlapped_cancel_impl()
812 ret = Py_CancelIoEx(self->handle, &self->overlapped); in _overlapped_Overlapped_cancel_impl()
[all …]
|
| /third_party/boost/boost/interprocess/detail/ |
| D | os_file_functions.hpp | 222 static winapi::interprocess_overlapped overlapped; in acquire_file_lock() local
227 (hnd, winapi::lockfile_exclusive_lock, 0, len, len, &overlapped); in acquire_file_lock()
233 winapi::interprocess_overlapped overlapped; in try_acquire_file_lock() local
234 std::memset(&overlapped, 0, sizeof(overlapped)); in try_acquire_file_lock()
237 0, len, len, &overlapped)){ in try_acquire_file_lock()
248 winapi::interprocess_overlapped overlapped; in release_file_lock() local
249 std::memset(&overlapped, 0, sizeof(overlapped)); in release_file_lock()
250 return winapi::unlock_file_ex(hnd, 0, len, len, &overlapped); in release_file_lock()
256 winapi::interprocess_overlapped overlapped; in acquire_file_lock_sharable() local
257 std::memset(&overlapped, 0, sizeof(overlapped)); in acquire_file_lock_sharable()
[all …]
|
| /third_party/python/Lib/asyncio/ |
| D | windows_utils.py | 32 def pipe(*, duplex=False, overlapped=(True, True), bufsize=BUFSIZE): argument
49 if overlapped[0]:
52 if overlapped[1]:
67 ov = _winapi.ConnectNamedPipe(h1, overlapped=True)
136 stdin_rh, stdin_wh = pipe(overlapped=(False, True), duplex=True)
141 stdout_rh, stdout_wh = pipe(overlapped=(True, False))
146 stderr_rh, stderr_wh = pipe(overlapped=(True, False))
|
| /third_party/vk-gl-cts/execserver/ |
| D | xsWin32TestProcess.cpp | 133 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.hEvent = ioEvent.getHandle(); in run()
240 overlapped.Offset = (DWORD)(offset & 0xffffffffu); in run()
241 overlapped.OffsetHigh = (DWORD)(offset >> 32); in run()
[all …]
|
| /third_party/gn/src/base/files/ |
| D | file_win.cc | 61 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/libusb/libusb/os/ |
| D | windows_common.c | 300 OVERLAPPED *overlapped = &transfer_priv->overlapped; in windows_force_sync_completion() local
304 overlapped->Internal = (ULONG_PTR)STATUS_SUCCESS; in windows_force_sync_completion()
305 overlapped->InternalHigh = (ULONG_PTR)size; in windows_force_sync_completion()
307 …dCompletionStatus(priv->completion_port, (DWORD)size, (ULONG_PTR)transfer->dev_handle, overlapped)) in windows_force_sync_completion()
421 OVERLAPPED *overlapped; in windows_iocp_thread() local
431 overlapped = NULL; in windows_iocp_thread()
432 …ueuedCompletionStatus(iocp, &num_bytes, &completion_key, &overlapped, INFINITE) && (overlapped == … in windows_iocp_thread()
437 if (overlapped == NULL) { in windows_iocp_thread()
452 if (overlapped == &transfer_priv->overlapped) { in windows_iocp_thread()
463 overlapped, dev_handle, dev_handle->dev->bus_number, dev_handle->dev->device_address); in windows_iocp_thread()
[all …]
|
| D | windows_usbdk.c | 529 OVERLAPPED *overlapped = get_transfer_priv_overlapped(itransfer); in usbdk_do_control_transfer() local
539 transResult = usbdk_helper.ReadPipe(priv->redirector_handle, &transfer_priv->request, overlapped); in usbdk_do_control_transfer()
541 …transResult = usbdk_helper.WritePipe(priv->redirector_handle, &transfer_priv->request, overlapped); in usbdk_do_control_transfer()
562 OVERLAPPED *overlapped = get_transfer_priv_overlapped(itransfer); in usbdk_do_bulk_transfer() local
581 transferRes = usbdk_helper.ReadPipe(priv->redirector_handle, &transfer_priv->request, overlapped); in usbdk_do_bulk_transfer()
583 …transferRes = usbdk_helper.WritePipe(priv->redirector_handle, &transfer_priv->request, overlapped); in usbdk_do_bulk_transfer()
604 OVERLAPPED *overlapped = get_transfer_priv_overlapped(itransfer); in usbdk_do_iso_transfer() local
633 transferRes = usbdk_helper.ReadPipe(priv->redirector_handle, &transfer_priv->request, overlapped); in usbdk_do_iso_transfer()
635 …transferRes = usbdk_helper.WritePipe(priv->redirector_handle, &transfer_priv->request, overlapped); in usbdk_do_iso_transfer()
|
| /third_party/boost/boost/interprocess/sync/windows/ |
| D | named_sync.hpp | 83 winapi::interprocess_overlapped overlapped; in close() local
85 (m_file_hnd, winapi::lockfile_exclusive_lock, 0, sizeof_file_info, 0, &overlapped)){ in close()
131 winapi::interprocess_overlapped overlapped; in open_or_create() local
133 (m_file_hnd, winapi::lockfile_exclusive_lock, 0, sizeof_file_info, 0, &overlapped)){ in open_or_create()
176 if(!winapi::unlock_file_ex(m_file_hnd, 0, sizeof_file_info, 0, &overlapped)){ in open_or_create()
|
| /third_party/flutter/skia/src/ports/ |
| D | SkOSFile_win.cpp | 138 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/skia/src/ports/ |
| D | SkOSFile_win.cpp | 138 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/boost/libs/asio/example/cpp03/windows/ |
| D | transmit_file.cpp | 37 overlapped_ptr overlapped(socket.get_executor().context(), handler); in transmit_file() local
41 file.native_handle(), 0, 0, overlapped.get(), 0, 0); in transmit_file()
52 overlapped.complete(ec, 0); in transmit_file()
58 overlapped.release(); in transmit_file()
|
| /third_party/boost/doc/html/boost_asio/example/cpp03/windows/ |
| D | transmit_file.cpp | 37 overlapped_ptr overlapped(socket.get_executor().context(), handler); in transmit_file() local
41 file.native_handle(), 0, 0, overlapped.get(), 0, 0); in transmit_file()
52 overlapped.complete(ec, 0); in transmit_file()
58 overlapped.release(); in transmit_file()
|
| /third_party/libuv/test/ |
| D | runner-win.c | 246 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/python/Lib/test/libregrtest/ |
| D | win_utils.py | 66 overlap = _winapi.ConnectNamedPipe(self.pipe, overlapped=True)
123 overlapped, _ = _winapi.ReadFile(self.pipe, BUFSIZE, True)
124 bytes_read, res = overlapped.GetOverlappedResult(False)
128 output = overlapped.getbuffer()
|
| /third_party/boost/libs/asio/include/boost/asio/detail/impl/ |
| D | win_iocp_handle_service.ipp | 316 overlapped_wrapper overlapped(ec);
323 overlapped.Offset = offset & 0xFFFFFFFF;
324 overlapped.OffsetHigh = (offset >> 32) & 0xFFFFFFFF;
326 static_cast<DWORD>(buffer.size()), 0, &overlapped);
341 &overlapped, &bytes_transferred, TRUE);
408 overlapped_wrapper overlapped(ec);
415 overlapped.Offset = offset & 0xFFFFFFFF;
416 overlapped.OffsetHigh = (offset >> 32) & 0xFFFFFFFF;
418 static_cast<DWORD>(buffer.size()), 0, &overlapped);
440 &overlapped, &bytes_transferred, TRUE);
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | win_iocp_handle_service.ipp | 316 overlapped_wrapper overlapped(ec);
323 overlapped.Offset = offset & 0xFFFFFFFF;
324 overlapped.OffsetHigh = (offset >> 32) & 0xFFFFFFFF;
326 static_cast<DWORD>(buffer.size()), 0, &overlapped);
341 &overlapped, &bytes_transferred, TRUE);
408 overlapped_wrapper overlapped(ec);
415 overlapped.Offset = offset & 0xFFFFFFFF;
416 overlapped.OffsetHigh = (offset >> 32) & 0xFFFFFFFF;
418 static_cast<DWORD>(buffer.size()), 0, &overlapped);
440 &overlapped, &bytes_transferred, TRUE);
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/l2_packet/ |
| D | l2_packet_ndis.c | 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/ |
| D | l2_packet_ndis.c | 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/gstreamer/gstplugins_bad/sys/winks/ |
| D | gstksvideodevice.c | 64 OVERLAPPED overlapped; member
260 if (!GetOverlappedResult (priv->pin_handle, &req->overlapped, &n, FALSE)) { in gst_ks_video_device_clear_buffers()
262 GetOverlappedResult (priv->pin_handle, &req->overlapped, &n, FALSE); in gst_ks_video_device_clear_buffers()
319 req.overlapped.hEvent = CreateEvent (NULL, TRUE, FALSE, NULL); in gst_ks_video_device_prepare_buffers()
322 g_array_append_val (priv->request_events, req.overlapped.hEvent); in gst_ks_video_device_prepare_buffers()
961 event = req->overlapped.hEvent; in gst_ks_video_device_request_frame()
962 memset (&req->overlapped, 0, sizeof (OVERLAPPED)); in gst_ks_video_device_request_frame()
963 req->overlapped.hEvent = event; in gst_ks_video_device_request_frame()
983 params, params->header.Size, &bytes_returned, &req->overlapped); in gst_ks_video_device_request_frame()
1062 if (WaitForSingleObject (req->overlapped.hEvent, 0) != WAIT_OBJECT_0) in gst_ks_video_device_read_frame()
[all …]
|