Skip to content

Commit a1e35bd

Browse files
authored
Merge pull request #292 from sylwiaszunejko/debug_driver_hanging
Add setting `connected_event` flag in libevreactor
2 parents 410289a + 7982b71 commit a1e35bd

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

cassandra/io/libevreactor.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -294,6 +294,7 @@ def close(self):
294294
if not self.is_defunct:
295295
self.error_all_requests(
296296
ConnectionShutdown("Connection to %s was closed" % self.endpoint))
297+
self.connected_event.set()
297298

298299
def handle_write(self, watcher, revents, errno=None):
299300
if revents & libev.EV_ERROR:

0 commit comments

Comments
 (0)