Rooba
/
cpython
mirror of https://github.com/python/cpython.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

asyncio/windows_events.py: use more revelant names to overlapped callbacks 

For example: "finish_recv", not just "finish".
This commit is contained in:
Victor Stinner 2014-02-26 17:35:30 +01:00
parent 984689821d
commit c89c8a7be9
2 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
Lib/asyncio/selector_events.py
View File

@ -702,8 +702,7 @@ def _write_ready(self):
if self._buffer:
try:
n = self._sock.send(self._buffer)
except (BlockingIOError, InterruptedError,
ssl.SSLWantWriteError):
except (BlockingIOError, InterruptedError, ssl.SSLWantWriteError):
n = 0
except ssl.SSLWantReadError:
n = 0

20
Lib/asyncio/windows_events.py
View File

@ -213,7 +213,7 @@ def recv(self, conn, nbytes, flags=0):
else:
ov.ReadFile(conn.fileno(), nbytes)
def finish(trans, key, ov):
def finish_recv(trans, key, ov):
try:
return ov.getresult()
except OSError as exc:
@ -222,7 +222,7 @@ def finish(trans, key, ov):
else:
raise
return self._register(ov, conn, finish)
return self._register(ov, conn, finish_recv)
def send(self, conn, buf, flags=0):
self._register_with_iocp(conn)
@ -232,7 +232,7 @@ def send(self, conn, buf, flags=0):
else:
ov.WriteFile(conn.fileno(), buf)
def finish(trans, key, ov):
def finish_send(trans, key, ov):
try:
return ov.getresult()
except OSError as exc:
@ -241,7 +241,7 @@ def finish(trans, key, ov):
else:
raise
return self._register(ov, conn, finish)
return self._register(ov, conn, finish_send)
def accept(self, listener):
self._register_with_iocp(listener)
@ -300,17 +300,17 @@ def accept_pipe(self, pipe):
ov = _overlapped.Overlapped(NULL)
ov.ConnectNamedPipe(pipe.fileno())
def finish(trans, key, ov):
def finish_accept_pipe(trans, key, ov):
ov.getresult()
return pipe
return self._register(ov, pipe, finish)
return self._register(ov, pipe, finish_accept_pipe)
def connect_pipe(self, address):
ov = _overlapped.Overlapped(NULL)
ov.WaitNamedPipeAndConnect(address, self._iocp, ov.address)
def finish(err, handle, ov):
def finish_connect_pipe(err, handle, ov):
# err, handle were arguments passed to PostQueuedCompletionStatus()
# in a function run in a thread pool.
if err == _overlapped.ERROR_SEM_TIMEOUT:
@ -323,7 +323,7 @@ def finish(err, handle, ov):
else:
return windows_utils.PipeHandle(handle)
return self._register(ov, None, finish, wait_for_post=True)
return self._register(ov, None, finish_connect_pipe, wait_for_post=True)
def wait_for_handle(self, handle, timeout=None):
if timeout is None:
@ -339,7 +339,7 @@ def wait_for_handle(self, handle, timeout=None):
handle, self._iocp, ov.address, ms)
f = _WaitHandleFuture(wh, loop=self._loop)
def finish(trans, key, ov):
def finish_wait_for_handle(trans, key, ov):
if not f.cancelled():
try:
_overlapped.UnregisterWait(wh)
@ -355,7 +355,7 @@ def finish(trans, key, ov):
return (_winapi.WaitForSingleObject(handle, 0) ==
_winapi.WAIT_OBJECT_0)
self._cache[ov.address] = (f, ov, None, finish)
self._cache[ov.address] = (f, ov, None, finish_wait_for_handle)
return f
def _register_with_iocp(self, obj):