We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d137c0a commit 3055d63Copy full SHA for 3055d63
qasync/_windows.py
@@ -140,15 +140,13 @@ def _poll(self, timeout=None):
140
if ms >= UINT32_MAX:
141
raise ValueError("timeout too big")
142
143
- with QtCore.QMutexLocker(self._lock):
144
- while True:
145
- # self._logger.debug('Polling IOCP with timeout {} ms in thread {}...'.format(
146
- # ms, threading.get_ident()))
147
- status = _overlapped.GetQueuedCompletionStatus(self._iocp, ms)
148
- if status is None:
149
- break
150
- ms = 0
+ while True:
+ status = _overlapped.GetQueuedCompletionStatus(self._iocp, ms)
+ if status is None:
+ break
+ ms = 0
151
+ with QtCore.QMutexLocker(self._lock):
152
err, transferred, key, address = status
153
try:
154
f, ov, obj, callback = self._cache.pop(address)
0 commit comments