From bf706ac73fd9b1e14c51ce4355c4f3ebdeb071b6 Mon Sep 17 00:00:00 2001
From: Stefan Koegl <stefan@skoegl.net>
Date: Sun, 23 May 2010 14:21:09 +0200
Subject: [PATCH] let bwmon run continously

---
 bwmon/main.py | 94 ++++++++++++++++++++++++++++++++---------------------------
 1 file changed, 51 insertions(+), 43 deletions(-)
 rewrite bwmon/main.py (83%)

diff --git a/bwmon/main.py b/bwmon/main.py
dissimilarity index 83%
index 244319d..aa4d5e6 100755
--- a/bwmon/main.py
+++ b/bwmon/main.py
@@ -1,43 +1,51 @@
-#!/usr/bin/python
-import proc
-
-def list_connections():
-    """
-    prints a list of processes
-    """
-    fd_map = proc.get_fd_map()
-    conntrack = proc.parse_ip_conntrack()
-
-    connections = proc.get_connections()
-    for con in connections.itervalues():
-
-        if not con['inode']:
-            continue
-
-        if not con['inode'] in fd_map:
-            print 'inode %s not im map' % con['inode']
-            continue
-
-        process = fd_map[con['inode']]
-
-
-        key1 = proc.ip_hash(con['local'], con['remote'])
-        key2 = proc.ip_hash(con['remote'], con['local'])
-        key = None
-
-        if key1 in conntrack:
-            key = key1
-        elif key2 in conntrack:
-            key = key2
-
-        if key and 'bytes' in conntrack[key]:
-            byte_count = conntrack[key]['bytes']
-        else:
-            byte_count = '?'
-
-        print '%d: %s: %s -> %s (%s Bytes)' % (process['pid'], process['cmd'], con['local'], con['remote'], byte_count)
-
-
-if __name__ == '__main__':
-    list_connections()
-
+#!/usr/bin/python
+import proc
+import time
+
+def list_connections():
+    """
+    prints a list of processes
+    """
+
+    fd_map = {}
+    conntrack = {}
+    connections = {}
+
+    while True:
+        fd_map.update(proc.get_fd_map())
+        conntrack.update(proc.parse_ip_conntrack())
+
+        connections.update(proc.get_connections())
+        for con in connections.itervalues():
+
+            if not con['inode']:
+                continue
+
+            if not con['inode'] in fd_map:
+                print 'inode %s not im map' % con['inode']
+                continue
+
+            process = fd_map[con['inode']]
+
+
+            key1 = proc.ip_hash(con['local'], con['remote'])
+            key2 = proc.ip_hash(con['remote'], con['local'])
+            key = None
+
+            if key1 in conntrack:
+                key = key1
+            elif key2 in conntrack:
+                key = key2
+
+            if key and 'bytes' in conntrack[key]:
+                byte_count = conntrack[key]['bytes']
+            else:
+                byte_count = '?'
+
+            print '%d: %s: %s -> %s (%s Bytes)' % (process['pid'], process['cmd'], con['local'], con['remote'], byte_count)
+        time.sleep(1)
+
+
+if __name__ == '__main__':
+    list_connections()
+
-- 
2.11.4.GIT