| /external/grpc-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()
|
| /external/rust/crates/grpcio-sys/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()
|
| /external/python/cpython3/Modules/ |
| D | _winapi.c | 89 OVERLAPPED overlapped; member
110 Py_CancelIoEx(self->handle, &self->overlapped) && in overlapped_dealloc()
111 GetOverlappedResult(self->handle, &self->overlapped, &bytes, TRUE)) in overlapped_dealloc()
132 CloseHandle(self->overlapped.hEvent); in overlapped_dealloc()
138 CloseHandle(self->overlapped.hEvent); in overlapped_dealloc()
220 res = GetOverlappedResult(self->handle, &self->overlapped, &transferred, in _winapi_Overlapped_GetOverlappedResult_impl()
280 res = Py_CancelIoEx(self->handle, &self->overlapped); in _winapi_Overlapped_cancel_impl()
302 offsetof(OverlappedObject, overlapped) + offsetof(OVERLAPPED, hEvent),
360 memset(&self->overlapped, 0, sizeof(OVERLAPPED)); in new_overlapped()
363 self->overlapped.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); in new_overlapped()
[all …]
|
| D | overlapped.c | 47 OVERLAPPED overlapped; member
571 memset(&self->overlapped, 0, sizeof(OVERLAPPED)); in Overlapped_new()
574 self->overlapped.hEvent = event; in Overlapped_new()
624 if (!HasOverlappedIoCompleted(&self->overlapped) && in Overlapped_dealloc()
627 if (Py_CancelIoEx && Py_CancelIoEx(self->handle, &self->overlapped)) in Overlapped_dealloc()
631 ret = GetOverlappedResult(self->handle, &self->overlapped, in Overlapped_dealloc()
649 if (self->overlapped.hEvent != NULL) { in Overlapped_dealloc()
650 CloseHandle(self->overlapped.hEvent); in Overlapped_dealloc()
736 if (!HasOverlappedIoCompleted(&self->overlapped)) { in Overlapped_cancel()
739 ret = Py_CancelIoEx(self->handle, &self->overlapped); in Overlapped_cancel()
[all …]
|
| /external/llvm-project/lldb/source/Host/windows/ |
| D | LockFileWindows.cpp | 23 OVERLAPPED overlapped = {}; in fileLock() local
25 if (!::LockFileEx(file_handle, flags, 0, len, 0, &overlapped) && in fileLock()
30 if (!::GetOverlappedResult(file_handle, &overlapped, &bytes, TRUE)) in fileLock()
67 OVERLAPPED overlapped = {}; in DoUnlock() local
69 if (!::UnlockFileEx(m_file, 0, m_len, 0, &overlapped) && in DoUnlock()
74 if (!::GetOverlappedResult(m_file, &overlapped, &bytes, TRUE)) in DoUnlock()
|
| /external/python/cpython3/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))
|
| /external/deqp/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 …]
|
| /external/libevent/ |
| D | event_iocp.c | 59 EVUTIL_UPCAST(o, struct event_overlapped, overlapped); in handle_entry()
74 OVERLAPPED *overlapped=NULL; in loop() local
78 &overlapped, ms); in loop()
89 if (key != NOTIFICATION_KEY && overlapped) in loop()
90 handle_entry(overlapped, key, bytes, ok); in loop()
91 else if (!overlapped) in loop()
282 r = PostQueuedCompletionStatus(port->port, n, key, &o->overlapped); in event_iocp_activate_overlapped_()
|
| D | listener.c | 461 struct event_overlapped overlapped; member
515 event_overlapped_init_(&res->overlapped, accepted_socket_cb); in new_accepting_socket()
575 as->buflen/2, as->buflen/2, &pending, &as->overlapped.overlapped)) in start_accepting()
578 accepted_socket_cb(&as->overlapped, 1, 0, 1); in start_accepting()
676 EVUTIL_UPCAST(o, struct accepting_socket, overlapped); in accepted_socket_cb()
699 ok = WSAGetOverlappedResult(as->s, &o->overlapped, in accepted_socket_cb()
|
| /external/llvm-project/compiler-rt/lib/profile/ |
| D | WindowsMMap.c | 121 OVERLAPPED overlapped; in lock() local
122 ZeroMemory(&overlapped, sizeof(OVERLAPPED)); in lock()
123 overlapped.hEvent = CreateEvent(NULL, FALSE, FALSE, NULL); in lock()
124 BOOL result = LockFileEx(handle, flags, 0, MAXDWORD, MAXDWORD, &overlapped); in lock()
138 if (!GetOverlappedResult(handle, &overlapped, &dwNumBytes, TRUE)) in lock()
|
| /external/rust/crates/mio/src/sys/windows/ |
| D | named_pipe.rs | 169 let overlapped = self.inner.connect.as_ptr() as *mut _; in connect() localVariable
170 self.inner.handle.connect_overlapped(overlapped) in connect()
484 let overlapped = me.read.as_ptr() as *mut _; in schedule_read() localVariable
486 me.handle.read_overlapped(slice, overlapped) in schedule_read()
524 let overlapped = me.write.as_ptr() as *mut _; in maybe_schedule_write() localVariable
525 me.handle.write_overlapped(&buf[pos..], overlapped) in maybe_schedule_write()
591 unsafe fn cancel<T: AsRawHandle>(handle: &T, overlapped: &Overlapped) -> io::Result<()> { in cancel()
592 let ret = CancelIoEx(handle.as_raw_handle(), overlapped.as_ptr() as *mut _); in cancel()
608 let me = unsafe { overlapped2arc!(status.overlapped(), Inner, connect) }; in connect_done()
617 match me.handle.result(status.overlapped()) { in connect_done()
[all …]
|
| D | selector.rs | 505 if iocp_event.overlapped().is_null() { in feed_events()
511 let callback = (*(iocp_event.overlapped() as *mut super::Overlapped)).callback; in feed_events()
519 let sock_state = from_overlapped(iocp_event.overlapped()); in feed_events()
707 if iocp_event.overlapped().is_null() { in drop()
712 (*(iocp_event.overlapped() as *mut super::Overlapped)).callback in drop()
718 let _sock_state = from_overlapped(iocp_event.overlapped()); in drop()
|
| D | mod.rs | 10 mod overlapped; module
11 use overlapped::Overlapped;
|
| /external/libusb/libusb/os/ |
| D | windows_common.c | 298 OVERLAPPED *overlapped = &transfer_priv->overlapped; in windows_force_sync_completion() local
302 overlapped->Internal = (ULONG_PTR)STATUS_SUCCESS; in windows_force_sync_completion()
303 overlapped->InternalHigh = (ULONG_PTR)size; in windows_force_sync_completion()
418 OVERLAPPED *overlapped; in windows_iocp_thread() local
425 overlapped = NULL; in windows_iocp_thread()
426 …ueuedCompletionStatus(iocp, &num_bytes, &completion_key, &overlapped, INFINITE) && (overlapped == … in windows_iocp_thread()
431 if (overlapped == NULL) { in windows_iocp_thread()
438 transfer_priv = container_of(overlapped, struct windows_transfer_priv, overlapped); in windows_iocp_thread()
749 if (CancelIoEx(transfer_priv->handle, &transfer_priv->overlapped)) in windows_cancel_transfer()
770 …if (GetOverlappedResult(transfer_priv->handle, &transfer_priv->overlapped, &bytes_transferred, FAL… in windows_handle_transfer_completion()
|
| 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()
|
| /external/skqp/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()
|
| /external/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()
|
| /external/mdnsresponder/mDNSWindows/ |
| D | mDNSWin32.c | 144 …LLBACK TCPEndRecv( DWORD error, DWORD bytesTransferred, LPWSAOVERLAPPED overlapped, DWORD flags );
148 mDNSlocal void CALLBACK UDPEndRecv( DWORD err, DWORD bytesTransferred, LPWSAOVERLAPPED overlapped,…
337 inMDNS->p->unicastSock4.overlapped.pending = FALSE; in mDNSPlatformInit()
369 inMDNS->p->unicastSock6.overlapped.pending = FALSE; in mDNSPlatformInit()
1189 if ( !sock->overlapped.pending && ( sock->bptr == sock->eptr ) ) in mDNSPlatformReadTCP()
1344 check( !sock->overlapped.pending ); in TCPBeginRecv()
1346 ZeroMemory( &sock->overlapped.data, sizeof( sock->overlapped.data ) ); in TCPBeginRecv()
1347 sock->overlapped.data.hEvent = sock; in TCPBeginRecv()
1349 sock->overlapped.wbuf.buf = ( char* ) sock->eptr; in TCPBeginRecv()
1350 sock->overlapped.wbuf.len = ( ULONG) ( sock->ebuf - sock->eptr ); in TCPBeginRecv()
[all …]
|
| D | mDNSWin32.h | 61 Overlapped overlapped; member
80 Overlapped overlapped; member
|
| /external/python/cpython3/Lib/test/libregrtest/ |
| D | win_utils.py | 66 overlap = _winapi.ConnectNamedPipe(self.pipe, overlapped=True)
121 overlapped, _ = _winapi.ReadFile(self.pipe, BUFSIZE, True)
122 bytes_read, res = overlapped.GetOverlappedResult(False)
126 output = overlapped.getbuffer()
|
| /external/tensorflow/tensorflow/core/platform/windows/ |
| D | windows_file_system.cc | 61 OVERLAPPED overlapped = {0}; in pread() local
65 overlapped.Offset = offset_union.LowPart; in pread()
66 overlapped.OffsetHigh = offset_union.HighPart; in pread()
67 overlapped.hEvent = ::CreateEvent(NULL, TRUE, FALSE, NULL); in pread()
69 if (NULL == overlapped.hEvent) { in pread()
79 &bytes_read, &overlapped); in pread()
89 ::GetOverlappedResult(hfile, &overlapped, &bytes_read, TRUE); in pread()
98 ::CloseHandle(overlapped.hEvent); in pread()
|
| /external/wpa_supplicant_8/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()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver_windows.cc | 116 memset(&winsocket_->read_info.overlapped, 0, sizeof(OVERLAPPED)); in RegisterForOnReadableLocked()
122 &winsocket_->read_info.overlapped, nullptr)) { in RegisterForOnReadableLocked()
149 SendWriteBuf(nullptr, &winsocket_->write_info.overlapped); in RegisterForOnWriteableLocked()
213 int SendWriteBuf(LPDWORD bytes_sent_ptr, LPWSAOVERLAPPED overlapped) { in SendWriteBuf() argument
219 bytes_sent_ptr, flags, overlapped, nullptr); in SendWriteBuf()
223 GetName(), buf.len, *bytes_sent_ptr, overlapped, out); in SendWriteBuf()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver_windows.cc | 173 memset(&winsocket_->read_info.overlapped, 0, sizeof(OVERLAPPED)); in ContinueRegisterForOnReadableLocked()
179 &winsocket_->read_info.overlapped, nullptr)) { in ContinueRegisterForOnReadableLocked()
239 if (SendWriteBuf(nullptr, &winsocket_->write_info.overlapped, in ContinueRegisterForOnWriteableLocked()
312 int SendWriteBuf(LPDWORD bytes_sent_ptr, LPWSAOVERLAPPED overlapped, in SendWriteBuf() argument
319 bytes_sent_ptr, flags, overlapped, nullptr); in SendWriteBuf()
326 overlapped, out, *wsa_error_code); in SendWriteBuf()
448 &winsocket_->write_info.overlapped, in OnTcpConnectLocked()
552 &winsocket_->write_info.overlapped) == 0) { in ConnectTCP()
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_windows_utils.py | 25 h1, h2 = windows_utils.pipe(overlapped=(True, True))
62 h, _ = windows_utils.pipe(overlapped=(True, True))
|