From 6afd3e85919e55d52b747fad87540fb6ae2c8910 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 14:32:26 +0100
Subject: [PATCH] debug by CI
---
coolamqp/uplink/listener/socket.py | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/coolamqp/uplink/listener/socket.py b/coolamqp/uplink/listener/socket.py
index 7e2931e..29b7000 100644
--- a/coolamqp/uplink/listener/socket.py
+++ b/coolamqp/uplink/listener/socket.py
@@ -3,6 +3,9 @@ from __future__ import absolute_import, division, print_function
import collections
import socket
+import logging
+
+logger = logging.getLogger(__name__)
class SocketFailed(IOError):
@@ -91,6 +94,8 @@ 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')
@@ -121,6 +126,7 @@ 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