From dcf1711d74de0cf8381c7198d46b90b7d0c2208e Mon Sep 17 00:00:00 2001
From: Piotr Maslanka <piotr.maslanka@henrietta.com.pl>
Date: Sat, 14 Jan 2017 04:06:57 +0100
Subject: [PATCH] die printfs
---
coolamqp/uplink/handshake.py | 2 +-
coolamqp/uplink/listener/epoll_listener.py | 6 +++---
setup.py | 4 ++--
3 files changed, 6 insertions(+), 6 deletions(-)
diff --git a/coolamqp/uplink/handshake.py b/coolamqp/uplink/handshake.py
index 8544cdb..00f5574 100644
--- a/coolamqp/uplink/handshake.py
+++ b/coolamqp/uplink/handshake.py
@@ -22,7 +22,7 @@ CLIENT_DATA = [
# because RabbitMQ is some kind of a fascist and does not allow
# these fields to be of type short-string
(b'product', (b'CoolAMQP', 'S')),
- (b'version', (b'0.85', 'S')),
+ (b'version', (b'0.86', 'S')),
(b'copyright', (b'Copyright (C) 2016-2017 DMS Serwis', 'S')),
(b'information', (b'Licensed under the MIT License.\nSee https://github.com/smok-serwis/coolamqp for details', 'S')),
(b'capabilities', ([(capa, (True, 't')) for capa in SUPPORTED_EXTENSIONS], 'F')),
diff --git a/coolamqp/uplink/listener/epoll_listener.py b/coolamqp/uplink/listener/epoll_listener.py
index 16e8926..692b2aa 100644
--- a/coolamqp/uplink/listener/epoll_listener.py
+++ b/coolamqp/uplink/listener/epoll_listener.py
@@ -87,9 +87,9 @@ class EpollListener(object):
if event & select.EPOLLOUT:
- if sock.on_write():
- # I'm done with sending for now
- assert len(sock.data_to_send) == 0 and len(sock.priority_queue) == 0
+ sock.on_write()
+ # I'm done with sending for now
+ if len(sock.data_to_send) == 0 and len(sock.priority_queue) == 0:
self.epoll.modify(sock.fileno(), RO)
except SocketFailed:
diff --git a/setup.py b/setup.py
index b2c3afb..cc670f2 100644
--- a/setup.py
+++ b/setup.py
@@ -4,12 +4,12 @@ from setuptools import setup
setup(name=u'CoolAMQP',
- version='0.85',
+ version='0.86',
description=u'The fastest AMQP client',
author=u'DMS Serwis s.c.',
author_email=u'piotrm@smok.co',
url=u'https://github.com/smok-serwis/coolamqp',
- download_url='https://github.com/smok-serwis/coolamqp/archive/v0.85.zip',
+ download_url='https://github.com/smok-serwis/coolamqp/archive/v0.86.zip',
keywords=['amqp', 'rabbitmq', 'client', 'network', 'ha', 'high availability'],
packages=[
'coolamqp',
--
GitLab