Skip to content
Snippets Groups Projects
Commit eb08b023 authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

v0.102

parent 589e91a4
No related branches found
No related tags found
No related merge requests found
# 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:
......
# coding=UTF-8
__version__ = '0.102a1'
__version__ = '0.102'
......@@ -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, (
......
......@@ -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()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment