Fix events exception raising when ensuring server. Closes #3515.
[leap_pycommon.git] / src / leap / common / events / server.py
index daccc61..41aede3 100644 (file)
@@ -69,7 +69,7 @@ def ensure_server(port=SERVER_PORT):
     :rtype: EventsServerDaemon or None
 
     :raise PortAlreadyTaken: Raised if C{port} is already taken by something
-        that is not an events server.
+                             that is not an events server.
     """
     try:
         # check if port is available
@@ -77,12 +77,13 @@ def ensure_server(port=SERVER_PORT):
         s.connect(('localhost', port))
         s.close()
         # port is taken, check if there's a server running there
-        response = ping(port)
+        response = ping(port=port, timeout=1000)
         if response is not None and response.status == proto.EventResponse.OK:
             logger.info('A server is already running on port %d.', port)
-            return None
+            return
         # port is taken, and not by an events server
-        logger.info('Port %d is taken by something not an events server.', port)
+        logger.warning(
+            'Port %d is taken by something not an events server.', port)
         raise PortAlreadyTaken(port)
     except socket.error:
         # port is available, run a server
@@ -97,18 +98,21 @@ def ping(port=SERVER_PORT, reqcbk=None, timeout=1000):
     :param port: the port in which server should be listening
     :type port: int
     :param reqcbk: a callback to be called when a response from server is
-        received
-    :type reqcbk: function
-        callback(leap.common.events.events_pb2.EventResponse)
+                   received
+    :type reqcbk: function(proto.PingRequest, proto.EventResponse)
     :param timeout: the timeout for synch calls
     :type timeout: int
+
+    :return: the response from server for synch calls or nothing for asynch
+             calls.
+    :rtype: leap.common.events.events_pb2.EventsResponse or None
     """
     request = proto.PingRequest()
     service = RpcService(
         proto.EventsServerService_Stub,
         port,
         'localhost')
-    logger.info("Pinging server in port %d..." % port)
+    logger.debug("Pinging server in port %d..." % port)
     return service.ping(request, callback=reqcbk, timeout=timeout)
 
 
@@ -179,14 +183,14 @@ class EventsServerService(proto.EventsServerService):
         :param done: callback to be called when done
         :type done: protobuf.socketrpc.server.Callback
         """
-        logger.info('Received signal from client: %s...', str(request)[:40])
+        logger.debug('Received signal from client: %s...', str(request)[:40])
         # send signal to all registered clients
         # TODO: verify signal auth
         if request.event in registered_clients:
             for port in registered_clients[request.event]:
 
                 def callback(req, resp):
-                    logger.info("Signal received by " + str(port))
+                    logger.debug("Signal received by " + str(port))
 
                 service = RpcService(proto.EventsClientService_Stub,
                                      port, 'localhost')
@@ -207,7 +211,7 @@ class EventsServerService(proto.EventsServerService):
         :param done: callback to be called when done
         :type done: protobuf.socketrpc.server.Callback
         """
-        logger.info("Received ping request, sending response.")
+        logger.debug("Received ping request, sending response.")
         response = proto.EventResponse()
         response.status = proto.EventResponse.OK
         done.run(response)