From b16426c7d7e77dac89cf86730df4e3ccea96fac4 Mon Sep 17 00:00:00 2001 From: Kali Kaneko Date: Thu, 11 Apr 2013 19:36:28 +0900 Subject: fix deprecation warnings; add debug info --- changes/bug_fix-deprecation-warning | 1 + src/leap/common/events/component.py | 5 ++++- src/leap/common/events/daemon.py | 2 +- src/leap/common/events/server.py | 8 +++----- 4 files changed, 9 insertions(+), 7 deletions(-) create mode 100644 changes/bug_fix-deprecation-warning diff --git a/changes/bug_fix-deprecation-warning b/changes/bug_fix-deprecation-warning new file mode 100644 index 0000000..ac58117 --- /dev/null +++ b/changes/bug_fix-deprecation-warning @@ -0,0 +1 @@ + o Fix deprecation warnings diff --git a/src/leap/common/events/component.py b/src/leap/common/events/component.py index 4fcd6e7..bec1898 100644 --- a/src/leap/common/events/component.py +++ b/src/leap/common/events/component.py @@ -66,10 +66,13 @@ def ensure_component_daemon(): @return: the daemon instance @rtype: EventsComponentDaemon """ - daemon = EventsComponentDaemon.ensure(0) import time + daemon = EventsComponentDaemon.ensure(0) + logger.debug('ensure component daemon') + # Because we use a random port we want to wait until a port is assigned to # local component daemon. + while not (EventsComponentDaemon.get_instance() and EventsComponentDaemon.get_instance().get_port()): time.sleep(0.1) diff --git a/src/leap/common/events/daemon.py b/src/leap/common/events/daemon.py index 09f3c2f..d2c7b9b 100644 --- a/src/leap/common/events/daemon.py +++ b/src/leap/common/events/daemon.py @@ -99,7 +99,7 @@ class EventsSingletonDaemon(threading.Thread): % len(args)) if cls.__instance is None: cls.__instance = object.__new__( - EventsSingletonDaemon, *args, **kwargs) + EventsSingletonDaemon) cls.__initialize(cls.__instance, args[0], args[1]) return cls.__instance diff --git a/src/leap/common/events/server.py b/src/leap/common/events/server.py index e2365cb..16c6513 100644 --- a/src/leap/common/events/server.py +++ b/src/leap/common/events/server.py @@ -14,7 +14,6 @@ # # You should have received a copy of the GNU General Public License # along with this program. If not, see . - """ A server for the events mechanism. @@ -25,10 +24,7 @@ A server can receive different kinds of requests from components: 2. Signal request: redistribute the signal to registered components. """ - - import logging -import sets import socket @@ -95,9 +91,11 @@ class EventsServerService(proto.EventsServerService): logger.info("Received registration request: %s" % str(request)) # add component port to signal list if request.event not in registered_components: - registered_components[request.event] = sets.Set() + registered_components[request.event] = set([]) registered_components[request.event].add(request.port) # send response back to component + + logger.debug('sending response back') response = proto.EventResponse() response.status = proto.EventResponse.OK done.run(response) -- cgit v1.2.3