X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=bwmon.py;h=be146f69480c4993e579099700e8f3d4aa703c6c;hb=737532f28237ed08d3895b5912866476f909e04f;hp=38a70cc8717ba7ae0e4feed3f6b926ffdbfcde66;hpb=28843cfb70c54f24a08aa32495eac70964c8b1f0;p=nodemanager.git

diff --git a/bwmon.py b/bwmon.py
index 38a70cc..be146f6 100644
--- a/bwmon.py
+++ b/bwmon.py
@@ -662,7 +662,10 @@ def getDefaults(nmdbcopy):
 
 
 def allOff():
-   # Get/set special slice IDs
+    """
+    Turn off all slice HTBs
+    """
+    # Get/set special slice IDs
     root_xid = bwlimit.get_xid("root")
     default_xid = bwlimit.get_xid("default")
     kernelhtbs = gethtbs(root_xid, default_xid)
@@ -674,9 +677,9 @@ def allOff():
 lock = threading.Event()
 def run():
     """
-	When run as a thread, wait for event, lock db, deep copy it, release it, 
-	run bwmon.GetSlivers(), then go back to waiting.
-	"""
+    When run as a thread, wait for event, lock db, deep copy it, release it, 
+    run bwmon.GetSlivers(), then go back to waiting.
+    """
     logger.log("bwmon:  Thread started", 2)
     while True:
         lock.wait()
@@ -685,8 +688,10 @@ def run():
         nmdbcopy = copy.deepcopy(database.db)
         database.db_lock.release()
         try:  
-			if getDefaults(nmdbcopy): sync(nmdbcopy)
-			else: logger.log("bwmon:  DISABLED.")
+            if getDefaults(nmdbcopy) and len(bwlimit.tc("class show dev eth0")) > 0:
+                # class show to check if net:InitNodeLimit:bwlimit.init has run.
+                sync(nmdbcopy)
+            else: logger.log("bwmon:  BW limits DISABLED.")
         except: logger.log_exc()
         lock.clear()