Commit 52674a2f authored by Federico Sismondi's avatar Federico Sismondi

cleaner log lines

parent 7bb9ec7e
Pipeline #2230 canceled with stage
in 0 seconds
......@@ -192,7 +192,7 @@ class AmqpMessagePublisher:
channel = None
properties = pika.BasicProperties(**message.get_properties())
logger.info("publishing to routing_key: %s, msg: %s"
logger.info("PUBLISHING to routing_key: %s, msg: %s"
% (message.routing_key,
repr(message)[:STDOUT_MAX_TEXT_LENGTH_PER_LINE],))
......
......@@ -101,7 +101,7 @@ class Sniffer:
return
if isinstance(request, MsgSniffingGetCaptureLast):
self.logger.debug('Processing request: %s' % repr(request))
self.logger.debug('HANDLING request: %s' % repr(request))
if self.last_capture_name:
capture_id = self.last_capture_name
......@@ -163,7 +163,7 @@ class Sniffer:
elif isinstance(request, MsgSniffingGetCapture):
self.logger.debug('Processing request: %s' % repr(request))
self.logger.debug('HANDLING request: %s' % repr(request))
try:
capture_id = request.capture_id
......@@ -207,7 +207,7 @@ class Sniffer:
return
elif isinstance(request, MsgSniffingStart):
self.logger.debug('Processing request: %s' % repr(request))
self.logger.debug('HANDLING request: %s' % repr(request))
try:
capture_id = request.capture_id
filename = "{0}.pcap".format(capture_id)
......
......@@ -171,7 +171,7 @@ class CoordinatorAmqpInterface(object):
channel = None
properties = pika.BasicProperties(**message.get_properties())
logger.info("publishing to routing_key: %s, msg: %s"
logger.info("PUBLISHING to routing_key: %s, msg: %s"
% (message.routing_key,
repr(message)[:70],))
try:
......@@ -215,7 +215,7 @@ class CoordinatorAmqpInterface(object):
# let's process request
if type(request) in self.request_reply_handlers:
logger.info('Processing request: %s' % type(request))
logger.info('HANDLING request: %s' % type(request))
callback = self.request_reply_handlers[type(request)]
try:
......@@ -242,7 +242,7 @@ class CoordinatorAmqpInterface(object):
# let's process request
if type(event) in self.control_events_triggers:
logger.info('Processing request: %s' % type(event))
logger.info('HANDLING request: %s' % type(event))
trigger_callback = self.control_events_triggers[type(event)]
try:
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment