diff options
| author | Satoshi Fujimoto <satoshi.fujimoto7@gmail.com> | 2017-06-16 11:45:43 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2017-06-23 12:08:18 +0900 |
| commit | cf667e409728a0f444b6193ad8342fb77881e3c2 (patch) | |
| tree | 9f66c78e5bf6574c38dc71bd4f764ecb6d46da3d | |
| parent | 2edfb20884c537d64aa1cbb8bb8889b5f46eae23 (diff) | |
service/ovsdb: Add properties to EventNewOVSDBConnection
Currently, EventNewOVSDBConnection only has system_id.
This patch let the class has RemoteOvsdb to get more
informations through it.
e.g.)
@set_ev_cls(ovsdb_event.EventNewOVSDBConnection)
def handle_new_ovsdb_connection(self, ev):
system_id = ev.system_id
remote_addr = ev.client.address
Signed-off-by: Satoshi Fujimoto <satoshi.fujimoto7@gmail.com>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
| -rw-r--r-- | ryu/services/protocols/ovsdb/event.py | 10 | ||||
| -rw-r--r-- | ryu/services/protocols/ovsdb/manager.py | 2 |
2 files changed, 8 insertions, 4 deletions
diff --git a/ryu/services/protocols/ovsdb/event.py b/ryu/services/protocols/ovsdb/event.py index 486e5c74..f162b528 100644 --- a/ryu/services/protocols/ovsdb/event.py +++ b/ryu/services/protocols/ovsdb/event.py @@ -119,13 +119,17 @@ class EventModifyReply(ryu_event.EventReplyBase): class EventNewOVSDBConnection(ryu_event.EventBase): - def __init__(self, system_id): + def __init__(self, client): super(EventNewOVSDBConnection, self).__init__() - self.system_id = system_id + self.client = client def __str__(self): return '%s<system_id=%s>' % (self.__class__.__name__, - self.system_id) + self.client.system_id) + + @property + def system_id(self): + return self.client.system_id class EventReadRequest(ryu_event.EventRequestBase): diff --git a/ryu/services/protocols/ovsdb/manager.py b/ryu/services/protocols/ovsdb/manager.py index 86a2d1ff..98225034 100644 --- a/ryu/services/protocols/ovsdb/manager.py +++ b/ryu/services/protocols/ovsdb/manager.py @@ -146,7 +146,7 @@ class OVSDB(app_manager.RyuApp): if app: self._clients[app.name] = app app.start() - ev = event.EventNewOVSDBConnection(app.system_id) + ev = event.EventNewOVSDBConnection(app) self.send_event_to_observers(ev) else: |