Commit 71a28a91 authored by Antoine Pitrou's avatar Antoine Pitrou

Rebind locally the globals which can be looked up at shutdown

(to avoid the warnings seen on a buildbot)
parent 37009207
...@@ -290,8 +290,8 @@ if win32: ...@@ -290,8 +290,8 @@ if win32:
""" """
_buffered = b'' _buffered = b''
def _close(self): def _close(self, _CloseHandle=win32.CloseHandle):
win32.CloseHandle(self._handle) _CloseHandle(self._handle)
def _send_bytes(self, buf): def _send_bytes(self, buf):
overlapped = win32.WriteFile(self._handle, buf, overlapped=True) overlapped = win32.WriteFile(self._handle, buf, overlapped=True)
...@@ -376,13 +376,13 @@ class Connection(_ConnectionBase): ...@@ -376,13 +376,13 @@ class Connection(_ConnectionBase):
""" """
if win32: if win32:
def _close(self): def _close(self, _close=win32.closesocket):
win32.closesocket(self._handle) _close(self._handle)
_write = win32.send _write = win32.send
_read = win32.recv _read = win32.recv
else: else:
def _close(self): def _close(self, _close=os.close):
os.close(self._handle) _close(self._handle)
_write = os.write _write = os.write
_read = os.read _read = os.read
......
...@@ -188,7 +188,11 @@ class Finalize(object): ...@@ -188,7 +188,11 @@ class Finalize(object):
_finalizer_registry[self._key] = self _finalizer_registry[self._key] = self
def __call__(self, wr=None): def __call__(self, wr=None,
# Need to bind these locally because the globals can have
# been cleared at shutdown
_finalizer_registry=_finalizer_registry,
sub_debug=sub_debug):
''' '''
Run the callback unless it has already been called or cancelled Run the callback unless it has already been called or cancelled
''' '''
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment