update_fix

agentcelery.py

@@ -37,7 +37,7 @@ def send_command(vm, command, *args, **kwargs):
         reactor.ended_tasks[vm][uuid] = None
         reactor.ended_tasks[vm][uuid] = None
 
 
     for conn in reactor.connections[vm]:
     for conn in reactor.connections[vm]:
-        if command == 'append' and 'vio-cloud' not in conn.transport.addr:
+        if command == 'append' and b'vio-cloud' not in conn.transport.addr:
             continue
             continue
         logger.info('%s(%s, %s)', command, vm,
         logger.info('%s(%s, %s)', command, vm,
                     ', '.join(map(lambda x: str(x)[:100], kwargs.values())))
                     ', '.join(map(lambda x: str(x)[:100], kwargs.values())))

protocol.py

@@ -78,7 +78,7 @@ def inotify_handler(self, file, mask):
 
 
 class SerialLineReceiver(SerialLineReceiverBase):
 class SerialLineReceiver(SerialLineReceiverBase):
     def send_to_graphite(self, data):
     def send_to_graphite(self, data):
-        logger.info("Send_TO_Graphite")
+        logger.info("Send_TO_Graphite from %s", self.factory.vm)
         client = GraphiteClientFactory()
         client = GraphiteClientFactory()
         client.protocol.data = data
         client.protocol.data = data
         client.protocol.name = self.factory.vm
         client.protocol.name = self.factory.vm
@@ -105,7 +105,7 @@ class SerialLineReceiver(SerialLineReceiverBase):
             self.send_response(response='pong', args=args)
             self.send_response(response='pong', args=args)
 
 
     def handle_response(self, response, args):
     def handle_response(self, response, args):
-        logger.info('handle_response: %s %s', response, args)
+        logger.info('handle_response: %s', response)
         vm = self.factory.vm
         vm = self.factory.vm
         if response == 'status':
         if response == 'status':
             self.send_to_graphite(args)
             self.send_to_graphite(args)