Merge pull request apache#826 from datastax/python-asyncore-subclass

Jaume Marhuenda · web-flow · commit 18aa7242ff3a · 2017-09-19T09:24:05.000-04:00
Fix bug when subclassing AsyncoreConnection
diff --git a/CHANGELOG.rst b/CHANGELOG.rst
@@ -10,6 +10,7 @@ Bug Fixes
 * Both _set_final_exception/result called for the same ResponseFuture (PYTHON-630)
 * Use of DCAwareRoundRobinPolicy raises NoHostAvailable exception (PYTHON-781)
 * Not create two sessions by default in CQLEngine (PYTHON-814)
+* Bug when subclassing AyncoreConnection (PYTHON-827)
 
 3.11.0
 ======
diff --git a/cassandra/io/asyncorereactor.py b/cassandra/io/asyncorereactor.py
@@ -347,7 +347,7 @@ def __init__(self, *args, **kwargs):
             callback=partial(asyncore.dispatcher.__init__,
                              self, self._socket, _dispatcher_map)
         )
-        AsyncoreConnection._loop.add_timer(init_handler)
+        self._loop.add_timer(init_handler)
         init_handler.wait(kwargs["connect_timeout"])
 
         self._writable = True

Original file line number	Diff line number	Diff line change
`@@ -347,7 +347,7 @@ def __init__(self, args, *kwargs):`
`347`	`347`	`callback=partial(asyncore.dispatcher.__init__,`
`348`	`348`	`self, self._socket, _dispatcher_map)`
`349`	`349`	`)`
`350`		`- AsyncoreConnection._loop.add_timer(init_handler)`
	`350`	`+ self._loop.add_timer(init_handler)`
`351`	`351`	`init_handler.wait(kwargs["connect_timeout"])`
`352`	`352`
`353`	`353`	`self._writable = True`