(self)
| 219 | super()._unregister_wait_cb(fut) |
| 220 | |
| 221 | def _unregister_wait(self): |
| 222 | if not self._registered: |
| 223 | return |
| 224 | self._registered = False |
| 225 | |
| 226 | wait_handle = self._wait_handle |
| 227 | self._wait_handle = None |
| 228 | try: |
| 229 | _overlapped.UnregisterWaitEx(wait_handle, self._event) |
| 230 | except OSError as exc: |
| 231 | if exc.winerror != _overlapped.ERROR_IO_PENDING: |
| 232 | context = { |
| 233 | 'message': 'Failed to unregister the wait handle', |
| 234 | 'exception': exc, |
| 235 | 'future': self, |
| 236 | } |
| 237 | if self._source_traceback: |
| 238 | context['source_traceback'] = self._source_traceback |
| 239 | self._loop.call_exception_handler(context) |
| 240 | return |
| 241 | # ERROR_IO_PENDING is not an error, the wait was unregistered |
| 242 | |
| 243 | self._event_fut = self._proactor._wait_cancel(self._event, |
| 244 | self._unregister_wait_cb) |
| 245 | |
| 246 | |
| 247 | class PipeServer(object): |
nothing calls this directly
no test coverage detected