diff options
| author | Peng Xiao <xiaoquwl@gmail.com> | 2014-09-03 10:02:41 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2014-09-03 10:02:41 +0900 |
| commit | 41d95ac699160f585cc791280eacab4f255f510f (patch) | |
| tree | 9021d278fcba8fb1a0236e4a238413cf7047da21 | |
| parent | f77f84942f8883992639cc3c972c4fdbd7d53250 (diff) | |
bmp: add client information to each bmp message
Differentiate BMP messages from different BMP clients, and modify the
debug logg ing message for client connected and disconnected.
Signed-off-by: Peng Xiao <xiaoquwl@gmail.com>
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
| -rw-r--r-- | ryu/app/bmpstation.py | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/ryu/app/bmpstation.py b/ryu/app/bmpstation.py index f8d22de6..a96500f2 100644 --- a/ryu/app/bmpstation.py +++ b/ryu/app/bmpstation.py @@ -48,7 +48,7 @@ class BMPStation(app_manager.RyuApp): self.loop).serve_forever) def loop(self, sock, addr): - self.logger.debug("start bmp loop: client %s" % str(addr)) + self.logger.debug("BMP client connected, ip=%s, port=%s" % addr) is_active = True buf = bytearray() required_len = bmp.BMPMessage._HDR_LEN @@ -83,14 +83,15 @@ class BMPStation(app_manager.RyuApp): (e, self.failed_pkt_count)) else: t = time.strftime("%Y %b %d %H:%M:%S", time.localtime()) - self.logger.debug("%s | %s\n" % (t, msg)) - self.output_fd.write("%s | %s\n\n" % (t, msg)) + self.logger.debug("%s | %s | %s\n" % (t, addr[0], msg)) + self.output_fd.write("%s | %s | %s\n\n" % (t, addr[0], + msg)) self.output_fd.flush() buf = rest required_len = bmp.BMPMessage._HDR_LEN - self.logger.debug("end bmp loop.") + self.logger.debug("BMP client disconnected, ip=%s, port=%s" % addr) sock.close() self.output_fd.close() self.failed_dump_fd.close() |