diff --git a/CHANGELOG.md b/CHANGELOG.md index 1f1caa543aeadfd0b259f0e67ddb8a9b18ed89dd..ebcaf1646e5ac1a682322f8400cade83234d7eae 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,6 +1,8 @@ # v0.102: -* _TBA_ +* due to noticed behaviour on some Linuxes that changing epoll from another thread + than is being waited on does not seem to alter the behaviour, EpollListener + will now check manually if threads have anything to send # v0.101: diff --git a/coolamqp/__init__.py b/coolamqp/__init__.py index ddd847c4a973b97754c20a30c77efca1a199eb7c..db0cbd068e0504976dc1bd7e7a498acd5aa65d72 100644 --- a/coolamqp/__init__.py +++ b/coolamqp/__init__.py @@ -1,2 +1,2 @@ # coding=UTF-8 -__version__ = '0.102a1' +__version__ = '0.102' diff --git a/coolamqp/uplink/handshake.py b/coolamqp/uplink/handshake.py index 5c5d3e3447dbff44615936d8904950964e75fb26..4bf04737de6c06e7bbecb5edd51ea80c3c340e16 100644 --- a/coolamqp/uplink/handshake.py +++ b/coolamqp/uplink/handshake.py @@ -116,7 +116,6 @@ class Handshaker(object): def on_connection_tune(self, payload # type: coolamqp.framing.base.AMQPPayload ): - logger.debug('Responding with ConnectionTuneOk') self.connection.frame_max = payload.frame_max self.connection.heartbeat = min(payload.heartbeat, self.heartbeat) self.connection.free_channels.extend(six.moves.xrange(1, ( diff --git a/coolamqp/uplink/listener/socket.py b/coolamqp/uplink/listener/socket.py index 6a864215c5d75cfa060db2e47bf571d6c2e8e0e9..bb95f5284935cee1e843fa650e0215f44b09464a 100644 --- a/coolamqp/uplink/listener/socket.py +++ b/coolamqp/uplink/listener/socket.py @@ -94,8 +94,6 @@ class BaseSocket(object): except (IOError, socket.error) as e: raise SocketFailed(repr(e)) - logger.debug('Received %s', repr(data)) - if len(data) == 0: raise SocketFailed('connection gracefully closed') @@ -129,7 +127,6 @@ class BaseSocket(object): try: sent = self.sock.send(self.data_to_send[0]) - logger.debug('Sent %s', repr(self.data_to_send[0])) except (IOError, socket.error): raise SocketFailed()