X-Git-Url: https://git.xandkar.net/?a=blobdiff_plain;f=bin%2Fkhatus_bar;h=2c7ee32c1c961024d868f3b9c364a3cd13237152;hb=2d710f2862fb523a4fabac01c155dac692df910d;hp=0be697928b6b6335d8c3ac30668edf0d6f98073f;hpb=ae2fb49299a202eb53caadc16c772557c73bf163;p=khatus.git diff --git a/bin/khatus_bar b/bin/khatus_bar index 0be6979..2c7ee32 100755 --- a/bin/khatus_bar +++ b/bin/khatus_bar @@ -13,6 +13,7 @@ BEGIN { FS = msg_fs ? msg_fs : "|" OFS = msg_fs ? msg_fs : "|" Kfs = key_fs ? key_fs : ":" + GC_Interval = GC_Interval ? GC_Interval : 3600 # seconds _total_to_diff["khatus_sensor_net_addr_io", "bytes_read" ] = 1 _total_to_diff["khatus_sensor_net_addr_io", "bytes_written" ] = 1 @@ -65,7 +66,7 @@ function cache_update( src, key, val, len_line, len_head, len_val, time) { _cache[src, key] = val time = cache_get_time() _cache_mtime[src, key] = time - if (time % 3600 == 0) { + if (time % GC_Interval == 0) { cache_gc() } } @@ -96,14 +97,18 @@ function cache_get_time( src, key, time) { return time } -function cache_gc( src_and_key, unused_for) { +function cache_gc( src_and_key, parts, src, key, unused_for) { for (src_and_key in _cache) { - unused_for = cache_get_time() - _cache_atime[src_and_key] - if (unused_for > 3600) { + split(src_and_key, parts, SUBSEP) + src = parts[1] + key = parts[2] + unused_for = cache_get_time() - _cache_atime[src, key] + if (unused_for > GC_Interval) { print_msg_info(\ - "cache_gc", "Deleting unused src_and_key: " src_and_key \ + "cache_gc", + sprintf("Deleting unused data SRC=%s KEY=%s", src, key) \ ) - delete _cache[src_and_key] + delete _cache[src, key] } } } @@ -199,9 +204,9 @@ function make_status_cpu( l, t, f) { function make_status_disk( u, w, r, src_u, src_io) { src_u = "khatus_sensor_disk_space" src_io = "khatus_sensor_disk_io" - u = cache_get_fmt_def(src_u , "disk_usage_percentage", 10, "%s") - w = cache_get_fmt_def(src_io , "sectors_written" , 5, "%0.3f") - r = cache_get_fmt_def(src_io , "sectors_read" , 5, "%0.3f") + u = cache_get_fmt_def(src_u , "disk_usage_percentage", 10, "%s") + w = cache_get_fmt_def(src_io, "sectors_written" , 5, "%0.3f") + r = cache_get_fmt_def(src_io, "sectors_read" , 5, "%0.3f") return sprintf("D=[%s%% %s▲ %s▼]", u, w, r) }