| /external/libusb/libusb/os/ |
| D | poll_windows.c | 112 || (poll_fd[_index].handle == 0) || (poll_fd[_index].overlapped == NULL) ) { in cancel_io()
121 return (*pCancelIoEx)(poll_fd[_index].handle, poll_fd[_index].overlapped); in cancel_io()
143 || (poll_fd[_index].handle == 0) || (poll_fd[_index].overlapped == NULL) ) { in cancel_io()
199 OVERLAPPED *overlapped = (OVERLAPPED*) calloc(1, sizeof(OVERLAPPED)); in create_overlapped() local
200 if (overlapped == NULL) { in create_overlapped()
203 overlapped->hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); in create_overlapped()
204 if(overlapped->hEvent == NULL) { in create_overlapped()
205 free (overlapped); in create_overlapped()
208 return overlapped; in create_overlapped()
211 static void free_overlapped(OVERLAPPED *overlapped) in free_overlapped() argument
[all …]
|
| D | windows_usbdk.c | 574 …nsResult = usbdk_helper.ReadPipe(priv->redirector_handle, &transfer_priv->request, wfd.overlapped); in usbdk_do_control_transfer()
576 …sResult = usbdk_helper.WritePipe(priv->redirector_handle, &transfer_priv->request, wfd.overlapped); in usbdk_do_control_transfer()
580 wfd.overlapped->Internal = STATUS_COMPLETED_SYNCHRONOUSLY; in usbdk_do_control_transfer()
581 wfd.overlapped->InternalHigh = (DWORD)Length; in usbdk_do_control_transfer()
634 …nsferRes = usbdk_helper.ReadPipe(priv->redirector_handle, &transfer_priv->request, wfd.overlapped); in usbdk_do_bulk_transfer()
636 …sferRes = usbdk_helper.WritePipe(priv->redirector_handle, &transfer_priv->request, wfd.overlapped); in usbdk_do_bulk_transfer()
640 wfd.overlapped->Internal = STATUS_COMPLETED_SYNCHRONOUSLY; in usbdk_do_bulk_transfer()
703 …nsferRes = usbdk_helper.ReadPipe(priv->redirector_handle, &transfer_priv->request, wfd.overlapped); in usbdk_do_iso_transfer()
705 …sferRes = usbdk_helper.WritePipe(priv->redirector_handle, &transfer_priv->request, wfd.overlapped); in usbdk_do_iso_transfer()
709 wfd.overlapped->Internal = STATUS_COMPLETED_SYNCHRONOUSLY; in usbdk_do_iso_transfer()
[all …]
|
| D | poll_windows.h | 86 OVERLAPPED* overlapped; // what will report our I/O status member
106 struct winfd overlapped_to_winfd(OVERLAPPED* overlapped);
|
| D | wince_usb.c | 558 if (!UkwCancelTransfer(priv->dev, transfer_priv->pollable_fd.overlapped, UKW_TF_NO_WAIT)) in wince_cancel_transfer()
605 …sueControlTransfer(priv->dev, flags, setup, buf, bufLen, &transfer->actual_length, wfd.overlapped); in wince_submit_control_or_bulk_transfer()
608 transfer->length, &transfer->actual_length, wfd.overlapped); in wince_submit_control_or_bulk_transfer()
792 if (found && HasOverlappedIoCompleted(transfer_priv->pollable_fd.overlapped)) { in wince_handle_events()
793 io_result = (DWORD)transfer_priv->pollable_fd.overlapped->Internal; in wince_handle_events()
794 io_size = (DWORD)transfer_priv->pollable_fd.overlapped->InternalHigh; in wince_handle_events()
|
| D | windows_winusb.c | 2029 if (HasOverlappedIoCompletedSync(pollable_fd->overlapped)) { in windows_get_overlapped_result()
2031 *io_size = (DWORD)pollable_fd->overlapped->InternalHigh; in windows_get_overlapped_result()
2033 else if (GetOverlappedResult(pollable_fd->handle, pollable_fd->overlapped, io_size, false)) { in windows_get_overlapped_result()
2746 wfd.overlapped->Internal = STATUS_COMPLETED_SYNCHRONOUSLY; in winusbx_submit_control_transfer()
2747 wfd.overlapped->InternalHigh = 0; in winusbx_submit_control_transfer()
2749 …er(wfd.handle, *setup, transfer->buffer + LIBUSB_CONTROL_SETUP_SIZE, size, NULL, wfd.overlapped)) { in winusbx_submit_control_transfer()
2756 wfd.overlapped->Internal = STATUS_COMPLETED_SYNCHRONOUSLY; in winusbx_submit_control_transfer()
2757 wfd.overlapped->InternalHigh = (DWORD)size; in winusbx_submit_control_transfer()
2827 …ReadPipe(wfd.handle, transfer->endpoint, transfer->buffer, transfer->length, NULL, wfd.overlapped); in winusbx_submit_bulk_transfer()
2830 …ritePipe(wfd.handle, transfer->endpoint, transfer->buffer, transfer->length, NULL, wfd.overlapped); in winusbx_submit_bulk_transfer()
[all …]
|
| /external/python/cpython3/Modules/ |
| D | _winapi.c | 91 OVERLAPPED overlapped; member
112 Py_CancelIoEx(self->handle, &self->overlapped) && in overlapped_dealloc()
113 GetOverlappedResult(self->handle, &self->overlapped, &bytes, TRUE)) in overlapped_dealloc()
134 CloseHandle(self->overlapped.hEvent); in overlapped_dealloc()
140 CloseHandle(self->overlapped.hEvent); in overlapped_dealloc()
211 res = GetOverlappedResult(self->handle, &self->overlapped, &transferred, in _winapi_Overlapped_GetOverlappedResult_impl()
271 res = Py_CancelIoEx(self->handle, &self->overlapped); in _winapi_Overlapped_cancel_impl()
293 offsetof(OverlappedObject, overlapped) + offsetof(OVERLAPPED, hEvent),
351 memset(&self->overlapped, 0, sizeof(OVERLAPPED)); in new_overlapped()
354 self->overlapped.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); in new_overlapped()
[all …]
|
| D | overlapped.c | 46 OVERLAPPED overlapped; member
554 memset(&self->overlapped, 0, sizeof(OVERLAPPED)); in Overlapped_new()
557 self->overlapped.hEvent = event; in Overlapped_new()
569 if (!HasOverlappedIoCompleted(&self->overlapped) && in Overlapped_dealloc()
572 if (Py_CancelIoEx && Py_CancelIoEx(self->handle, &self->overlapped)) in Overlapped_dealloc()
576 ret = GetOverlappedResult(self->handle, &self->overlapped, in Overlapped_dealloc()
594 if (self->overlapped.hEvent != NULL) in Overlapped_dealloc()
595 CloseHandle(self->overlapped.hEvent); in Overlapped_dealloc()
625 if (!HasOverlappedIoCompleted(&self->overlapped)) { in Overlapped_cancel()
628 ret = Py_CancelIoEx(self->handle, &self->overlapped); in Overlapped_cancel()
[all …]
|
| /external/libmojo/mojo/edk/test/ |
| D | test_utils_win.cc | 21 OVERLAPPED overlapped = {0}; in BlockingWrite() local
25 &bytes_written_dword, &overlapped)) { in BlockingWrite()
27 !GetOverlappedResult(handle.handle, &overlapped, &bytes_written_dword, in BlockingWrite()
41 OVERLAPPED overlapped = {0}; in BlockingRead() local
45 &bytes_read_dword, &overlapped)) { in BlockingRead()
47 !GetOverlappedResult(handle.handle, &overlapped, &bytes_read_dword, in BlockingRead()
61 OVERLAPPED overlapped = {0}; in NonBlockingRead() local
65 &bytes_read_dword, &overlapped)) { in NonBlockingRead()
71 if (!GetOverlappedResult(handle.handle, &overlapped, &bytes_read_dword, in NonBlockingRead()
|
| /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/python/cpython3/Lib/asyncio/ |
| D | windows_utils.py | 83 def pipe(*, duplex=False, overlapped=(True, True), bufsize=BUFSIZE): argument
99 if overlapped[0]:
102 if overlapped[1]:
117 ov = _winapi.ConnectNamedPipe(h1, overlapped=True)
187 stdin_rh, stdin_wh = pipe(overlapped=(False, True), duplex=True)
192 stdout_rh, stdout_wh = pipe(overlapped=(True, False))
197 stderr_rh, stderr_wh = pipe(overlapped=(True, False))
|
| /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 | 452 struct event_overlapped overlapped; member
506 event_overlapped_init_(&res->overlapped, accepted_socket_cb); in new_accepting_socket()
566 as->buflen/2, as->buflen/2, &pending, &as->overlapped.overlapped)) in start_accepting()
569 accepted_socket_cb(&as->overlapped, 1, 0, 1); in start_accepting()
667 EVUTIL_UPCAST(o, struct accepting_socket, overlapped); in accepted_socket_cb()
690 ok = WSAGetOverlappedResult(as->s, &o->overlapped, in accepted_socket_cb()
|
| D | buffer_iocp.c | 226 &ol->overlapped, NULL)) { in evbuffer_launch_write_()
292 &ol->overlapped, NULL)) { in evbuffer_launch_read_()
|
| D | iocp-internal.h | 52 OVERLAPPED overlapped; member
|
| /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/skia/src/ports/ |
| D | SkOSFile_win.cpp | 136 OVERLAPPED overlapped; in sk_qread() local
137 memset(&overlapped, 0, sizeof(overlapped)); in sk_qread()
140 overlapped.Offset = winOffset.LowPart; in sk_qread()
141 overlapped.OffsetHigh = winOffset.HighPart; in sk_qread()
148 if (ReadFile(fileHandle, buffer, static_cast<DWORD>(count), &bytesRead, &overlapped)) { in sk_qread()
|
| /external/skqp/src/ports/ |
| D | SkOSFile_win.cpp | 135 OVERLAPPED overlapped; in sk_qread() local
136 memset(&overlapped, 0, sizeof(overlapped)); in sk_qread()
139 overlapped.Offset = winOffset.LowPart; in sk_qread()
140 overlapped.OffsetHigh = winOffset.HighPart; in sk_qread()
147 if (ReadFile(fileHandle, buffer, static_cast<DWORD>(count), &bytesRead, &overlapped)) { in sk_qread()
|
| /external/tensorflow/tensorflow/core/platform/windows/ |
| D | windows_file_system.cc | 56 OVERLAPPED overlapped = {0}; in pread() local
60 overlapped.Offset = offset_union.LowPart; in pread()
61 overlapped.OffsetHigh = offset_union.HighPart; in pread()
62 overlapped.hEvent = ::CreateEvent(NULL, TRUE, FALSE, NULL); in pread()
64 if (NULL == overlapped.hEvent) { in pread()
74 &bytes_read, &overlapped); in pread()
84 ::GetOverlappedResult(hfile, &overlapped, &bytes_read, TRUE); in pread()
93 ::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/python/cpython3/Lib/multiprocessing/ |
| D | connection.py | 280 ov, err = _winapi.WriteFile(self._handle, buf, overlapped=True)
302 overlapped=True)
340 ov, err = _winapi.ReadFile(self._handle, left, overlapped=True)
551 overlapped = _winapi.ConnectNamedPipe(h1, overlapped=True)
552 _, err = overlapped.GetOverlappedResult(True)
654 ov = _winapi.ConnectNamedPipe(handle, overlapped=True)
|
| /external/libmojo/mojo/edk/system/ |
| D | channel_win.cc | 158 &connect_context_.overlapped); in StartOnIOThread()
291 &read_context_.overlapped); in ReadMore()
308 &write_context_.overlapped); in WriteNoLock()
|
| /external/lzma/CPP/Windows/ |
| D | FileIO.h | 75 LPVOID outBuffer, DWORD outSize, LPDWORD bytesReturned, LPOVERLAPPED overlapped = NULL) const
78 outBuffer, outSize, bytesReturned, overlapped));
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_windows_utils.py | 75 h1, h2 = windows_utils.pipe(overlapped=(True, True))
112 h, _ = windows_utils.pipe(overlapped=(True, True))
|
| /external/webrtc/webrtc/test/channel_transport/ |
| D | udp_socket2_manager_win.h | 39 WSAOVERLAPPED overlapped; member
|