Lines Matching refs:_winapi
30 import _winapi
31 from _winapi import WAIT_OBJECT_0, WAIT_ABANDONED_0, WAIT_TIMEOUT, INFINITE
35 _winapi = None
265 if _winapi:
275 def _close(self, _CloseHandle=_winapi.CloseHandle):
279 ov, err = _winapi.WriteFile(self._handle, buf, overlapped=True)
281 if err == _winapi.ERROR_IO_PENDING:
282 waitres = _winapi.WaitForMultipleObjects(
300 ov, err = _winapi.ReadFile(self._handle, bsize,
303 if err == _winapi.ERROR_IO_PENDING:
304 waitres = _winapi.WaitForMultipleObjects(
316 elif err == _winapi.ERROR_MORE_DATA:
319 if e.winerror == _winapi.ERROR_BROKEN_PIPE:
327 _winapi.PeekNamedPipe(self._handle)[0] != 0):
335 left = _winapi.PeekNamedPipe(self._handle)[1]
339 ov, err = _winapi.ReadFile(self._handle, left, overlapped=True)
353 if _winapi:
540 openmode = _winapi.PIPE_ACCESS_DUPLEX
541 access = _winapi.GENERIC_READ | _winapi.GENERIC_WRITE
544 openmode = _winapi.PIPE_ACCESS_INBOUND
545 access = _winapi.GENERIC_WRITE
548 h1 = _winapi.CreateNamedPipe(
549 address, openmode | _winapi.FILE_FLAG_OVERLAPPED |
550 _winapi.FILE_FLAG_FIRST_PIPE_INSTANCE,
551 _winapi.PIPE_TYPE_MESSAGE | _winapi.PIPE_READMODE_MESSAGE |
552 _winapi.PIPE_WAIT,
553 1, obsize, ibsize, _winapi.NMPWAIT_WAIT_FOREVER,
555 _winapi.NULL
557 h2 = _winapi.CreateFile(
558 address, access, 0, _winapi.NULL, _winapi.OPEN_EXISTING,
559 _winapi.FILE_FLAG_OVERLAPPED, _winapi.NULL
561 _winapi.SetNamedPipeHandleState(
562 h2, _winapi.PIPE_READMODE_MESSAGE, None, None
565 overlapped = _winapi.ConnectNamedPipe(h1, overlapped=True)
654 flags = _winapi.PIPE_ACCESS_DUPLEX | _winapi.FILE_FLAG_OVERLAPPED
656 flags |= _winapi.FILE_FLAG_FIRST_PIPE_INSTANCE
657 return _winapi.CreateNamedPipe(
659 _winapi.PIPE_TYPE_MESSAGE | _winapi.PIPE_READMODE_MESSAGE |
660 _winapi.PIPE_WAIT,
661 _winapi.PIPE_UNLIMITED_INSTANCES, BUFSIZE, BUFSIZE,
662 _winapi.NMPWAIT_WAIT_FOREVER, _winapi.NULL
669 ov = _winapi.ConnectNamedPipe(handle, overlapped=True)
671 if e.winerror != _winapi.ERROR_NO_DATA:
677 res = _winapi.WaitForMultipleObjects(
681 _winapi.CloseHandle(handle)
692 _winapi.CloseHandle(handle)
701 _winapi.WaitNamedPipe(address, 1000)
702 h = _winapi.CreateFile(
703 address, _winapi.GENERIC_READ | _winapi.GENERIC_WRITE,
704 0, _winapi.NULL, _winapi.OPEN_EXISTING,
705 _winapi.FILE_FLAG_OVERLAPPED, _winapi.NULL
708 if e.winerror not in (_winapi.ERROR_SEM_TIMEOUT,
709 _winapi.ERROR_PIPE_BUSY) or _check_timeout(t):
716 _winapi.SetNamedPipeHandleState(
717 h, _winapi.PIPE_READMODE_MESSAGE, None, None
810 res = _winapi.WaitForMultipleObjects(L, False, timeout)
824 _ready_errors = {_winapi.ERROR_BROKEN_PIPE, _winapi.ERROR_NETNAME_DELETED}
854 ov, err = _winapi.ReadFile(fileno(), 0, True)
859 if err == _winapi.ERROR_IO_PENDING:
892 if err != _winapi.ERROR_OPERATION_ABORTED:
956 access = ((_winapi.FILE_GENERIC_READ if conn.readable else 0) |
957 (_winapi.FILE_GENERIC_WRITE if conn.writable else 0))