fix for issue 391 and issue 307

pika/adapters/base_connection.py

@@ -119,6 +119,8 @@ def _adapter_connect(self):
 
     def _adapter_disconnect(self):
         """Invoked if the connection is being told to disconnect"""
+        if hasattr(self, 'heartbeat') and self.heartbeat is not None:
+            self.heartbeat.stop()
         if self.socket:
             self.socket.close()
         self.socket = None
@@ -306,6 +308,11 @@ def _handle_events(self, fd, events, error=None, write_only=False):
         if not write_only and (events & self.READ):
             self._handle_read()
 
+        if write_only and (events & self.READ) and (events & self.ERROR):
+            LOGGER.error('BAD libc:  Write-Only but Read+Error. '
+                         'Assume socket disconnected.')
+            self._handle_disconnect()
+
         if events & self.ERROR:
             LOGGER.error('Error event %r, %r', events, error)
             self._handle_error(error)