diff options
author | YAMAMOTO Takashi <yamamoto@valinux.co.jp> | 2014-03-26 13:04:14 +0900 |
---|---|---|
committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2014-04-10 07:09:56 +0900 |
commit | 77e82d31113541e75e725e106d066cca4b739b71 (patch) | |
tree | 301678041c6a5567d63410e7261ab139ca3c44b6 | |
parent | d27deb34bea9e774d4b4439e060950db27a55de1 (diff) |
controller.handler: simplify code
and use consistent variable names. no functional changes.
Signed-off-by: YAMAMOTO Takashi <yamamoto@valinux.co.jp>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
-rw-r--r-- | ryu/base/app_manager.py | 14 | ||||
-rw-r--r-- | ryu/controller/handler.py | 18 |
2 files changed, 14 insertions, 18 deletions
diff --git a/ryu/base/app_manager.py b/ryu/base/app_manager.py index aab1ba68..291c0ad7 100644 --- a/ryu/base/app_manager.py +++ b/ryu/base/app_manager.py @@ -336,21 +336,21 @@ class AppManager(object): for _k, m in inspect.getmembers(i, inspect.ismethod): if not hasattr(m, 'callers'): continue - for e in m.callers.values(): - if not e.ev_source: + for ev_cls, c in m.callers.iteritems(): + if not c.ev_source: continue # name is module name of ev_cls - name = e.ev_source.split('.')[-1] + name = c.ev_source.split('.')[-1] if name in SERVICE_BRICKS: brick = SERVICE_BRICKS[name] brick.register_observer( - e.ev_cls, i.name, e.dispatchers) + ev_cls, i.name, c.dispatchers) # allow RyuApp and Event class are in different module for brick in SERVICE_BRICKS.itervalues(): - if e.ev_cls in brick._EVENTS: - brick.register_observer(e.ev_cls, i.name, - e.dispatchers) + if ev_cls in brick._EVENTS: + brick.register_observer(ev_cls, i.name, + c.dispatchers) @staticmethod def _report_brick(name, app): diff --git a/ryu/controller/handler.py b/ryu/controller/handler.py index 24e5bb65..66adf52e 100644 --- a/ryu/controller/handler.py +++ b/ryu/controller/handler.py @@ -31,10 +31,9 @@ class _Caller(object): """Describe how to handle an event class. """ - def __init__(self, ev_cls, dispatchers, ev_source): + def __init__(self, dispatchers, ev_source): """Initialize _Caller. - :param ev_cls: The event class to accept. :param dispatchers: A list of states or a state, in which this is in effect. None and [] mean all states. @@ -42,7 +41,6 @@ class _Caller(object): ev_cls.__module__ for set_ev_cls. None for set_ev_handler. """ - self.ev_cls = ev_cls self.dispatchers = dispatchers self.ev_source = ev_source @@ -53,8 +51,7 @@ def set_ev_cls(ev_cls, dispatchers=None): if 'callers' not in dir(handler): handler.callers = {} for e in _listify(ev_cls): - c = _Caller(e, _listify(dispatchers), e.__module__) - handler.callers[e] = c + handler.callers[e] = _Caller(_listify(dispatchers), e.__module__) return handler return _set_ev_cls_dec @@ -64,8 +61,7 @@ def set_ev_handler(ev_cls, dispatchers=None): if 'callers' not in dir(handler): handler.callers = {} for e in _listify(ev_cls): - c = _Caller(e, _listify(dispatchers), None) - handler.callers[e] = c + handler.callers[e] = _Caller(_listify(dispatchers), None) return handler return _set_ev_cls_dec @@ -86,16 +82,16 @@ def register_instance(i): for _k, m in inspect.getmembers(i, inspect.ismethod): # LOG.debug('instance %s k %s m %s', i, _k, m) if _has_caller(m): - for c in m.callers.values(): - i.register_handler(c.ev_cls, m) + for ev_cls, c in m.callers.iteritems(): + i.register_handler(ev_cls, m) def get_dependent_services(cls): services = [] for _k, m in inspect.getmembers(cls, inspect.ismethod): if _has_caller(m): - for c in m.callers.values(): - service = getattr(sys.modules[c.ev_cls.__module__], + for ev_cls, c in m.callers.iteritems(): + service = getattr(sys.modules[ev_cls.__module__], '_SERVICE_NAME', None) if service: # avoid cls that registers the own events (like |