From 4257aa859c0d447eb281edd310c6bde73146b613 Mon Sep 17 00:00:00 2001 From: Tyler Hobbs Date: Tue, 5 Nov 2013 13:29:57 -0600 Subject: [PATCH] Don't ignored libev conns closed by server This bug was introduced by 31f684bb91f3e0a41238c869a7c8fc11ebf21515 --- cassandra/io/libevreactor.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/cassandra/io/libevreactor.py b/cassandra/io/libevreactor.py index 45265089..6b7376e3 100644 --- a/cassandra/io/libevreactor.py +++ b/cassandra/io/libevreactor.py @@ -259,6 +259,9 @@ class LibevConnection(Connection): else: self._total_reqd_bytes = body_len + 8 break + else: + log.debug("Connection %s closed by server", self) + self.close() def handle_pushed(self, response): log.debug("Message pushed from server: %r", response)