From: t.moriyama <t.moriyama@users.sourceforge.jp>
Date: Sat, 20 Jul 2013 19:48:05 +0000 (+0900)
Subject: add LinuxNetAgent
X-Git-Url: http://git.osdn.net/view?p=ti2%2Fti2.git;a=commitdiff_plain;h=046edf9695a10507a240c34ba045efe2bee461d3

add LinuxNetAgent
---

diff --git a/linkpair/collect/agent/linuxnet_agent.py b/linkpair/collect/agent/linuxnet_agent.py
new file mode 100644
index 0000000..f052080
--- /dev/null
+++ b/linkpair/collect/agent/linuxnet_agent.py
@@ -0,0 +1,84 @@
+# vim: tabstop=4 shiftwidth=4 softtabstop=4
+# -*- coding: utf-8 -*-
+#
+
+__version__ = '1.1'
+
+import re
+from linkpair.device import Device
+from linkpair.port import Port
+from linkpair.collect.agent.base_agent import BaseAgent
+
+
+class LinuxNetAgent(BaseAgent):
+    '''
+    Linux Network Collector Agent
+    '''
+    def run(self):
+        self.get_configuration()
+
+    def get_configuration(self):
+        interfaces = []
+        port_name = ""
+        port_meta = {}
+        found_if = False
+        res_ipaddr = self._runner.exec_cmd("ip addr show")
+        for i in range(0, len(res_ipaddr)):
+            port_start = res_ipaddr[i].strip()
+            if self._u.d_push(
+                re.search(r'(\d+): (\S+): <(\S+)> mtu (\d+) (.*)',
+                    port_start)) is not None:
+                match = self._u.d_pop()
+                port_meta["if_index"] = match.group(1).strip()
+                port_name = match.group(2).strip()
+                port_meta["if_state"] = match.group(3).strip()
+                port_meta["mtu"] = match.group(4).strip()
+                port_meta["if_other_state"] = match.group(5).strip()
+                interfaces.append(port_name)
+                if found_if:
+                    self._cu.add_port(Port(port_name, Port.DEFAULT_TYPE, port_meta))
+                    port_name = ""
+                    port_meta = {}
+                else:
+                    found_if = True
+            elif self._u.d_push(
+                re.search(r'link/ether (\S+) brd (\S+)',
+                    port_start)) is not None:
+                match = self._u.d_pop()
+                port_meta["mac_addr"] = match.group(1).strip()
+                port_meta["mac_bcast_addr"] = match.group(2).strip()
+            elif self._u.d_push(
+                re.search(r'inet (\S+) brd (\S+) scope (\S+)',
+                    port_start)) is not None:
+                match = self._u.d_pop()
+                port_meta["inet_addr"] = match.group(1).strip()
+                port_meta["inet_bcast_addr"] = match.group(2).strip()
+                port_meta["if_scope"] = match.group(3).strip()
+                
+        for interface in interfaces:
+            # interface informations
+            res_ethtool = self._runner.exec_cmd("ethtool -i " + interface)
+            for i in range(0, len(res_ethtool)):
+                ethtool_line = res_ethtool[i].strip()
+                if self._u.d_push(
+                    re.search(r'(\S+): (\S+)',
+                        ethtool_line)) is not None:
+                    match = self._u.d_pop()
+                    if_property = match.group(1).strip()
+                    port_meta[if_property] = match.group(2).strip()
+
+            # interface statistics
+            res_ethtool = self._runner.exec_cmd("ethtool -S " + interface)
+            for i in range(0, len(res_ethtool)):
+                ethtool_line = res_ethtool[i].strip()
+                if self._u.d_push(
+                    re.search(r'(\S+): (\S+)',
+                        ethtool_line)) is not None:
+                    match = self._u.d_pop()
+                    if_property = match.group(1).strip()
+                    port_meta[if_property] = match.group(2).strip()
+                    
+            self._cu.add_port(Port(interface, Port.DEFAULT_TYPE, port_meta))
+            interface = ""
+            port_meta = {}
+