diff --git a/coolamqp/uplink/connection/connection.py b/coolamqp/uplink/connection/connection.py index cb9384f111b21410d7cbe7594d0132172abca127..84e5be3c75c43b43b98faddc176ee6f52c262409 100644 --- a/coolamqp/uplink/connection/connection.py +++ b/coolamqp/uplink/connection/connection.py @@ -253,7 +253,7 @@ class Connection(object): #todo why is that necessary? it doesnt pass travis CI if there's no this block self.listener_socket.oneshot(delay, callback) except AttributeError: - print(dir(self)) + pass #print(dir(self)) def unwatch_all(self, channel_id): """ diff --git a/coolamqp/uplink/listener/epoll_listener.py b/coolamqp/uplink/listener/epoll_listener.py index 727076bc1e9acc3770b7c972326ec1c8de5c02ff..16e8926b1056b905cb40196b8289d83c0b1354df 100644 --- a/coolamqp/uplink/listener/epoll_listener.py +++ b/coolamqp/uplink/listener/epoll_listener.py @@ -90,7 +90,7 @@ class EpollListener(object): if sock.on_write(): # I'm done with sending for now assert len(sock.data_to_send) == 0 and len(sock.priority_queue) == 0 - self.epoll.modify(sock.fileno(), RW) + self.epoll.modify(sock.fileno(), RO) except SocketFailed: self.epoll.unregister(fd) diff --git a/tests/run.py b/tests/run.py index 0d79aa59f2228a5e0f0042b743ee0db1ea7b1290..4c1a8591e9b2f3021d8189ff2dd3d7e1fecc30e7 100644 --- a/tests/run.py +++ b/tests/run.py @@ -25,7 +25,6 @@ if __name__ == '__main__': except AMQPError: print(':)') - while True: - time.sleep(30) + time.sleep(30) amqp.shutdown(True)