openstack/deb-python-cassandra-driver
Code Issues Proposed changes

Fix asyncore re-initialization in case of a fork

Browse Source
This commit is contained in:
Alan Boudreault
2016-06-14 19:13:26 -04:00
parent 6700d3ad50
commit 0a006083e8
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
cassandra/io/asyncorereactor.py
View File

@@ -278,6 +278,8 @@ class AsyncoreConnection(Connection, asyncore.dispatcher):
@classmethod @classmethod
def handle_fork(cls): def handle_fork(cls):
global _dispatcher_map
_dispatcher_map = {}
if cls._loop: if cls._loop:
cls._loop._cleanup() cls._loop._cleanup()
cls._loop = None cls._loop = None