--- /dev/null
+import bwlimit
+
+import logger
+import tools
+
+
+_old_rec = {}
+
+def update(rec):
+ global _old_rec
+ if rec != _old_rec:
+ if rec['cap'] != _old_rec.get('cap'):
+ logger.log('setting node bw cap to %d' % rec['cap'])
+# bwlimit.init('eth0', rec['cap'])
+ if rec['exempt_ips'] != _old_rec.get('exempt_ips'):
+ logger.log('initializing exempt ips to %s' % rec['exempt_ips'])
+# bwlimit.exempt_init('Internet2', rec['exempt_ips'])
+ _old_rec = tools.deepcopy(rec)