diff options
author | Kali Kaneko <kali@leap.se> | 2013-09-03 15:52:39 +0200 |
---|---|---|
committer | Kali Kaneko <kali@leap.se> | 2013-09-03 15:55:17 +0200 |
commit | 21b7235a4368c6681f2788893dd5073c9fffd37d (patch) | |
tree | 4081ddfe26f1b52e0862af559148f03a996fe10e /src | |
parent | f3b3982a0e53b1ff2cfc7fa9c3288e3156bfdd55 (diff) |
cosmetic changes to imports
Diffstat (limited to 'src')
-rw-r--r-- | src/leap/common/events/client.py | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/leap/common/events/client.py b/src/leap/common/events/client.py index 816cec1..ff1f52a 100644 --- a/src/leap/common/events/client.py +++ b/src/leap/common/events/client.py @@ -14,7 +14,6 @@ # # You should have received a copy of the GNU General Public License # along with this program. If not, see <http://www.gnu.org/licenses/>. - """ The client end point of the events mechanism. @@ -27,18 +26,15 @@ server that it wants to be notified whenever signals of that type are sent by some other client. """ - import logging -import threading from protobuf.socketrpc import RpcService -from leap.common.events import ( - events_pb2 as proto, - server, - daemon, - mac_auth, -) + +from leap.common.events import events_pb2 as proto +from leap.common.events import server +from leap.common.events import daemon +from leap.common.events import mac_auth logger = logging.getLogger(__name__) @@ -118,6 +114,10 @@ def register(signal, callback, uid=None, replace=False, reqcbk=None, if signal not in registered_callbacks: registered_callbacks[signal] = [] cbklist = registered_callbacks[signal] + + # TODO should check that the callback has the right + # number of arguments. + if uid and filter(lambda (x, y): x == uid, cbklist): if not replace: raise CallbackAlreadyRegistered() |