[Pkg-bitcoin-commits] [python-quamash] 37/269: Fix Windows implementation

[Jonas Smedegaard]

This is an automated email from the git hooks/post-receive script.

js pushed a commit to branch master
in repository python-quamash.

commit 750b0efadff516f438398ab1f70bade5e0d80282
Author: Arve Knudsen <arve.knudsen at gmail.com>
Date:   Wed Jul 2 09:17:30 2014 +0200

    Fix Windows implementation
---
 quamash/__init__.py |  3 ---
 quamash/_windows.py | 16 +++++++++++-----
 2 files changed, 11 insertions(+), 8 deletions(-)

diff --git a/quamash/__init__.py b/quamash/__init__.py
index 1b87db9..2d54ed0 100644
--- a/quamash/__init__.py
+++ b/quamash/__init__.py
@@ -15,7 +15,6 @@ import os
 import asyncio
 import time
 from functools import wraps
-import logging
 from queue import Queue
 from concurrent.futures import Future
 import threading
@@ -28,8 +27,6 @@ except ImportError:
 
 from ._common import with_logger
 
-_logger = logging.getLogger(__name__)
-
 
 @with_logger
 class _EventPoller(QtCore.QObject):
diff --git a/quamash/_windows.py b/quamash/_windows.py
index fb27705..62459ba 100644
--- a/quamash/_windows.py
+++ b/quamash/_windows.py
@@ -1,14 +1,20 @@
+import threading
 import _winapi
 import asyncio
 from asyncio import windows_events
+from asyncio import _overlapped
+import math
+
+from ._common import with_logger
 
 baseclass = asyncio.ProactorEventLoop
 
+
 @with_logger
-class IocpProactor(windows_events.IocpProactor):
+class _IocpProactor(windows_events.IocpProactor):
 	def __init__(self):
 		self.__events = []
-		super(IocpProactor, self).__init__()
+		super(_IocpProactor, self).__init__()
 
 	def select(self, timeout=None):
 		"""Override in order to handle events in a threadsafe manner."""
@@ -20,12 +26,10 @@ class IocpProactor(windows_events.IocpProactor):
 
 	def close(self):
 		self._logger.debug('Closing')
-		super(IocpProactor, self).close()
+		super(_IocpProactor, self).close()
 
 	def _poll(self, timeout=None):
 		"""Override in order to handle events in a threadsafe manner."""
-		import math
-		from asyncio import _overlapped
 		INFINITE = 0xffffffff
 
 		if timeout is None:
@@ -63,3 +67,5 @@ class IocpProactor(windows_events.IocpProactor):
 				self.__events.append((f, callback, transferred, key, ov))
 
 			ms = 0
+
+selector_cls = _IocpProactor
\ No newline at end of file

-- 
Alioth's /usr/local/bin/git-commit-notice on /srv/git.debian.org/git/pkg-bitcoin/python-quamash.git