| /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/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()
|
| D | tcp_windows.cc | 254 memset(&tcp->socket->read_info.overlapped, 0, sizeof(OVERLAPPED)); in win_read()
256 &info->overlapped, NULL); in win_read()
354 memset(&socket->write_info.overlapped, 0, sizeof(OVERLAPPED)); in win_write()
356 &bytes_sent, 0, &socket->write_info.overlapped, NULL); in win_write()
|
| D | tcp_client_windows.cc | 102 WSAGetOverlappedResult(socket->socket, &socket->write_info.overlapped, in on_connect()
186 0, NULL, &info->overlapped); in tcp_connect()
|
| /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()
209 res = GetOverlappedResult(self->handle, &self->overlapped, &transferred, in _winapi_Overlapped_GetOverlappedResult_impl()
269 res = Py_CancelIoEx(self->handle, &self->overlapped); in _winapi_Overlapped_cancel_impl()
291 offsetof(OverlappedObject, overlapped) + offsetof(OVERLAPPED, hEvent),
349 memset(&self->overlapped, 0, sizeof(OVERLAPPED)); in new_overlapped()
352 self->overlapped.hEvent = CreateEvent(NULL, TRUE, FALSE, NULL); in new_overlapped()
[all …]
|
| D | overlapped.c | 46 OVERLAPPED overlapped; member
557 memset(&self->overlapped, 0, sizeof(OVERLAPPED)); in Overlapped_new()
560 self->overlapped.hEvent = event; in Overlapped_new()
594 if (!HasOverlappedIoCompleted(&self->overlapped) && in Overlapped_dealloc()
597 if (Py_CancelIoEx && Py_CancelIoEx(self->handle, &self->overlapped)) in Overlapped_dealloc()
601 ret = GetOverlappedResult(self->handle, &self->overlapped, in Overlapped_dealloc()
619 if (self->overlapped.hEvent != NULL) { in Overlapped_dealloc()
620 CloseHandle(self->overlapped.hEvent); in Overlapped_dealloc()
642 if (!HasOverlappedIoCompleted(&self->overlapped)) { in Overlapped_cancel()
645 ret = Py_CancelIoEx(self->handle, &self->overlapped); in Overlapped_cancel()
[all …]
|
| /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)
137 stdin_rh, stdin_wh = pipe(overlapped=(False, True), duplex=True)
142 stdout_rh, stdout_wh = pipe(overlapped=(True, False))
147 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 | 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()
|
| /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/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/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/tensorflow/tensorflow/core/platform/windows/ |
| D | windows_file_system.cc | 58 OVERLAPPED overlapped = {0}; in pread() local
62 overlapped.Offset = offset_union.LowPart; in pread()
63 overlapped.OffsetHigh = offset_union.HighPart; in pread()
64 overlapped.hEvent = ::CreateEvent(NULL, TRUE, FALSE, NULL); in pread()
66 if (NULL == overlapped.hEvent) { in pread()
76 &bytes_read, &overlapped); in pread()
86 ::GetOverlappedResult(hfile, &overlapped, &bytes_read, TRUE); in pread()
95 ::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/libchrome/mojo/core/ |
| D | channel_win.cc | 144 BOOL ok = ::ConnectNamedPipe(handle_.Get(), &connect_context_.overlapped); in StartOnIOThread()
292 NULL, &read_context_.overlapped); in ReadMore()
307 &write_context_.overlapped); in WriteNoLock()
|
| /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)
556 overlapped = _winapi.ConnectNamedPipe(h1, overlapped=True)
557 _, err = overlapped.GetOverlappedResult(True)
659 ov = _winapi.ConnectNamedPipe(handle, overlapped=True)
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_windows_utils.py | 20 h1, h2 = windows_utils.pipe(overlapped=(True, True))
57 h, _ = windows_utils.pipe(overlapped=(True, True))
|
| /external/lzma/CPP/Windows/ |
| D | FileIO.h | 79 LPVOID outBuffer, DWORD outSize, LPDWORD bytesReturned, LPOVERLAPPED overlapped = NULL) const
82 outBuffer, outSize, bytesReturned, overlapped));
|