From eb08b023ca46414e6e82c64c5661c95db4a0df75 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Piotr=20Ma=C5=9Blanka?= <piotr.maslanka@henrietta.com.pl>
Date: Sun, 5 Jan 2020 16:09:35 +0100
Subject: [PATCH] v0.102
---
CHANGELOG.md | 4 +++-
coolamqp/__init__.py | 2 +-
coolamqp/uplink/handshake.py | 1 -
coolamqp/uplink/listener/socket.py | 3 ---
4 files changed, 4 insertions(+), 6 deletions(-)
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 1f1caa5..ebcaf16 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 ddd847c..db0cbd0 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 5c5d3e3..4bf0473 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 6a86421..bb95f52 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()
--
GitLab