X-Git-Url: https://git.xandkar.net/?a=blobdiff_plain;f=src%2Fawk%2Fexe%2Fbar.awk;h=43126ffd2b1906e7da215bd58b8630c220d00f7b;hb=1cdd2ba229f2086b9270617872de9c312adc1d11;hp=6862ee8f0b34e4f4f6cb61c319a772d316ed04b7;hpb=03c229bffd594c1facb72e0d042a88c0505c8dbc;p=khatus.git

diff --git a/src/awk/exe/bar.awk b/src/awk/exe/bar.awk
old mode 100755
new mode 100644
index 6862ee8..43126ff
--- a/src/awk/exe/bar.awk
+++ b/src/awk/exe/bar.awk
@@ -10,26 +10,30 @@
 # -----------------------------------------------------------------------------
 # Input
 # -----------------------------------------------------------------------------
-$1 == "OK" {
-    cache_update()
+$3 == "data" {
+    delete msg
+    msg_in_parse(msg, $0)
+    cache_update(msg["node"], msg["module"], msg["key"], msg["val"])
 }
 
-$1 == "OK" && \
-$2 == "khatus_sensor_datetime" {
+$1 == Node && \
+$2 == "khatus_sensor_datetime" && \
+$3 == "data" {
     # Code for bar_make_status is expected to be passed as an
     # additional source file, using  -f  flag.
-    msg_out_ok("status_bar", bar_make_status())
+    msg_out_status_bar(bar_make_status())
 }
 
-
 # -----------------------------------------------------------------------------
-# Status bar
+# Energy
 # -----------------------------------------------------------------------------
 
-function bar_make_status_energy(    state, charge, direction_of_change) {
-    cache_get(state , "khatus_sensor_energy", "battery_state"     , 0)
-    cache_get(charge, "khatus_sensor_energy", "battery_percentage", 0)
+function bar_make_status_energy_percent() {
+    return cache_get_fmt_def("khatus_sensor_energy", "battery_percentage", 0, "%d")
+}
 
+function bar_make_status_energy_direction(    state, direction_of_change) {
+    cache_get(state, "khatus_sensor_energy", "battery_state", 0)
     if (state["value"] == "discharging") {
         direction_of_change = "<"
     } else if (state["value"] == "charging") {
@@ -37,11 +41,14 @@ function bar_make_status_energy(    state, charge, direction_of_change) {
     } else {
         direction_of_change = "="
     }
-
-    return sprintf("E%s%d%%", direction_of_change, charge["value"])
+    return direction_of_change
 }
 
-function bar_make_status_mem(    total, used, percent, status) {
+# -----------------------------------------------------------------------------
+# Memory
+# -----------------------------------------------------------------------------
+
+function bar_make_status_mem_percent(    total, used, percent, percent_str) {
     cache_get(total, "khatus_sensor_memory", "total", 5)
     cache_get(used , "khatus_sensor_memory", "used" , 5)
     # Checking total["value"] to avoid division by zero when data is missing
@@ -49,110 +56,142 @@ function bar_make_status_mem(    total, used, percent, status) {
         !used["is_expired"] && \
         total["value"] \
         ) {
-        percent = util_round((used["value"] / total["value"]) * 100)
-        status = sprintf("%d%%", percent)
+        percent = num_round((used["value"] / total["value"]) * 100)
+        percent_str = sprintf("%d", percent)
     } else {
-        status = "__"
+        percent_str = "__"
     }
-    return sprintf("M=%s", status)
-}
-
-function bar_make_status_procs() {
-    # From man ps:
-    #   D    uninterruptible sleep (usually IO)
-    #   R    running or runnable (on run queue)
-    #   S    interruptible sleep (waiting for an event to complete)
-    #   T    stopped by job control signal
-    #   t    stopped by debugger during the tracing
-    #   W    paging (not valid since the 2.6.xx kernel)
-    #   X    dead (should never be seen)
-    #   Z    defunct ("zombie") process, terminated but not reaped by its parent
-    #
-    # Additionally, not documented in ps man page:
-    #   I    Idle
-    #
+    return percent_str
+}
+
+# -----------------------------------------------------------------------------
+# Processes
+# -----------------------------------------------------------------------------
+# From man ps:
+#   D    uninterruptible sleep (usually IO)
+#   R    running or runnable (on run queue)
+#   S    interruptible sleep (waiting for an event to complete)
+#   T    stopped by job control signal
+#   t    stopped by debugger during the tracing
+#   W    paging (not valid since the 2.6.xx kernel)
+#   X    dead (should never be seen)
+#   Z    defunct ("zombie") process, terminated but not reaped by its parent
+#
+# Additionally, not documented in ps man page:
+#   I    Idle
+
+function bar_make_status_procs_count_all() {
+    return cache_get_fmt_def("khatus_sensor_procs", "total_procs", 15, "%d")
+}
+
+function bar_make_status_procs_count_r(    src) {
     src = "khatus_sensor_procs"
-    all = cache_get_fmt_def(src, "total_procs"            , 15, "%d")
-    r   = cache_get_fmt_def(src, "total_per_state" Kfs "R", 15, "%d", "0")
-    d   = cache_get_fmt_def(src, "total_per_state" Kfs "D", 15, "%d", "0")
-    t   = cache_get_fmt_def(src, "total_per_state" Kfs "T", 15, "%d", "0")
-    i   = cache_get_fmt_def(src, "total_per_state" Kfs "I", 15, "%d", "0")
-    z   = cache_get_fmt_def(src, "total_per_state" Kfs "Z", 15, "%d", "0")
-    return sprintf("P=[%s %sr %sd %st %si %sz]", all, r, d, t, i, z)
-}
-
-function bar_make_status_cpu(    l, t, f) {
-    l_src = "khatus_sensor_loadavg"
-    t_src = "khatus_sensor_temperature"
-    f_src = "khatus_sensor_fan"
-    l = cache_get_fmt_def(l_src, "load_avg_1min", 5, "%4.2f")
-    t = cache_get_fmt_def(t_src, "temp_c"       , 5, "%d"   )
-    f = cache_get_fmt_def(f_src, "speed"        , 5, "%4d"  )
-    return sprintf("C=[%s %s°C %srpm]", l, t, f)
-}
-
-function bar_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")
-    return sprintf("D=[%s%% %s▲ %s▼]", u, w, r)
-}
-
-function bar_make_status_net(    \
-    number_of_net_interfaces_to_show, \
-    net_interfaces_to_show, \
-    io, \
-    wi, \
-    i, \
-    interface, \
-    label, \
-    wifi, \
-    addr, \
-    w, \
-    r, \
-    io_stat, \
-    out, \
-    sep \
-) {
-    number_of_net_interfaces_to_show = \
-        split(Opt_Net_Interfaces_To_Show, net_interfaces_to_show, ",")
-    io = "khatus_sensor_net_addr_io"
-    wi = "khatus_sensor_net_wifi_status"
-    out = ""
-    sep = ""
-    for (i = number_of_net_interfaces_to_show; i > 0; i--) {
-        interface = net_interfaces_to_show[i]
-        label = substr(interface, 1, 1)
-        if (interface ~ "^w") {
-            wifi = cache_get_fmt_def(wi, "status" Kfs interface, 10, "%s")
-            label = label ":" wifi
-        }
-        addr = cache_get_fmt_def(io, "addr"          Kfs interface, 5, "%s", "")
-        w    = cache_get_fmt_def(io, "bytes_written" Kfs interface, 5, "%0.3f")
-        r    = cache_get_fmt_def(io, "bytes_read"    Kfs interface, 5, "%0.3f")
-        io_stat = addr ? sprintf("%s▲ %s▼", w, r) : "--"
-        out = out sep label ":" io_stat
-        sep = " "
-    }
-    return sprintf("N[%s]", out)
+    return cache_get_fmt_def(src, "total_per_state" Kfs "R", 15, "%d", "0")
+}
+
+function bar_make_status_procs_count_d(    src) {
+    src = "khatus_sensor_procs"
+    return cache_get_fmt_def(src, "total_per_state" Kfs "D", 15, "%d", "0")
+}
+
+function bar_make_status_procs_count_t(    src) {
+    src = "khatus_sensor_procs"
+    return cache_get_fmt_def(src, "total_per_state" Kfs "T", 15, "%d", "0")
+}
+
+function bar_make_status_procs_count_i(    src) {
+    src = "khatus_sensor_procs"
+    return cache_get_fmt_def(src, "total_per_state" Kfs "I", 15, "%d", "0")
 }
 
-function bar_make_status_bluetooth(    src, key) {
+function bar_make_status_procs_count_z(    src) {
+    src = "khatus_sensor_procs"
+    return cache_get_fmt_def(src, "total_per_state" Kfs "Z", 15, "%d", "0")
+}
+
+# -----------------------------------------------------------------------------
+# CPU
+# -----------------------------------------------------------------------------
+
+function bar_make_status_cpu_loadavg(    src) {
+    src = "khatus_sensor_loadavg"
+    return cache_get_fmt_def(src, "load_avg_1min", 5, "%4.2f")
+}
+
+function bar_make_status_cpu_temperature() {
+    return cache_get_fmt_def("khatus_sensor_temperature", "temp_c", 5, "%d")
+}
+
+function bar_make_status_cpu_fan_speed() {
+    return cache_get_fmt_def("khatus_sensor_fan", "speed", 5, "%4d")
+}
+
+# -----------------------------------------------------------------------------
+# Disk
+# -----------------------------------------------------------------------------
+
+function bar_make_status_disk_space(    src) {
+    src = "khatus_sensor_disk_space"
+    return cache_get_fmt_def(src, "disk_usage_percentage", 10, "%s")
+}
+
+function bar_make_status_disk_io_w(    src) {
+    src = "khatus_sensor_disk_io"
+    return cache_get_fmt_def(src, "sectors_written", 5, "%0.3f")
+}
+
+function bar_make_status_disk_io_r(    src) {
+    src = "khatus_sensor_disk_io"
+    return cache_get_fmt_def(src, "sectors_read", 5, "%0.3f")
+}
+
+# -----------------------------------------------------------------------------
+# Network
+# -----------------------------------------------------------------------------
+
+function bar_make_status_net_addr(interface,    src) {
+    src = "khatus_sensor_net_addr_io"
+    return cache_get_fmt_def(src, "addr" Kfs interface, 5, "%s", "")
+}
+
+function bar_make_status_net_io_w(interface,    src) {
+    src = "khatus_sensor_net_addr_io"
+    return cache_get_fmt_def(src, "bytes_written" Kfs interface, 5, "%0.3f")
+}
+
+function bar_make_status_net_io_r(interface,    src) {
+    src = "khatus_sensor_net_addr_io"
+    return cache_get_fmt_def(src, "bytes_read" Kfs interface, 5, "%0.3f")
+}
+
+function bar_make_status_net_wifi(interface,    src) {
+    src = "khatus_sensor_net_wifi_status"
+    return cache_get_fmt_def(src, "status" Kfs interface, 10, "%s")
+}
+
+# -----------------------------------------------------------------------------
+# Bluetooth
+# -----------------------------------------------------------------------------
+
+function bar_make_status_bluetooth_power(    src) {
     src = "khatus_sensor_bluetooth_power"
-    key = "power_status"
-    return sprintf("B=%s", cache_get_fmt_def(src, key, 10, "%s"))
+    return cache_get_fmt_def(src, "power_status", 10, "%s")
 }
 
-function bar_make_status_screen_brightness(    src, key) {
+# -----------------------------------------------------------------------------
+# Backlight (screen brightness)
+# -----------------------------------------------------------------------------
+
+function bar_make_status_backlight_percent(    src) {
     src = "khatus_sensor_screen_brightness"
-    key = "percentage"
-    return sprintf("*%s%%", cache_get_fmt_def(src, key, 5, "%d"))
+    return cache_get_fmt_def(src, "percentage", 5, "%d")
 }
 
-function bar_make_status_volume(    sink, mu, vl, vr, show) {
-    sink = Opt_Pulseaudio_Sink
+# -----------------------------------------------------------------------------
+# Volume
+# -----------------------------------------------------------------------------
+
+function bar_make_status_volume_pulseaudio_sink(sink,    mu, vl, vr, show) {
     cache_get(mu, "khatus_sensor_volume", "mute"      Kfs sink, 5)
     cache_get(vl, "khatus_sensor_volume", "vol_left"  Kfs sink, 5)
     cache_get(vr, "khatus_sensor_volume", "vol_right" Kfs sink, 5)
@@ -161,15 +200,19 @@ function bar_make_status_volume(    sink, mu, vl, vr, show) {
              if (mu["value"] == "yes") {show = "X"}
         else if (mu["value"] == "no")  {show = vl["value"] " " vr["value"]}
         else {
-            msg_out_error(\
-                "bar_make_status_volume", \
+            msg_out_log_error(\
+                "bar_make_status_volume_pulseaudio_sink: " sink ". ", \
                 "Unexpected value for 'mute' field: " mu["value"] \
             )
         }
     }
-    return sprintf("(%s)", show)
+    return show
 }
 
+# -----------------------------------------------------------------------------
+# MPD
+# -----------------------------------------------------------------------------
+
 function bar_make_status_mpd(    state, status) {
     cache_get(state, "khatus_sensor_mpd", "state", 5)
     if (!state["is_expired"] && state["value"]) {
@@ -180,7 +223,7 @@ function bar_make_status_mpd(    state, status) {
         } else if (state["value"] == "stop") {
             status = bar_make_status_mpd_state_known("⬛")
         } else {
-            msg_out_error(\
+            msg_out_log_error(\
                 "bar_make_status_mpd", \
                 "Unexpected value for 'state' field: " state["value"] \
             )
@@ -189,8 +232,7 @@ function bar_make_status_mpd(    state, status) {
     } else {
         status = "--"
     }
-
-    return sprintf("[%s]", status)
+    return status
 }
 
 function bar_make_status_mpd_state_known(symbol,    s, song, time, percentage) {
@@ -202,13 +244,20 @@ function bar_make_status_mpd_state_known(symbol,    s, song, time, percentage) {
     return sprintf("%s %s %s %s", symbol, time, percent, song)
 }
 
-function bar_make_status_weather(    src, hour, t_f) {
+# -----------------------------------------------------------------------------
+# Weather
+# -----------------------------------------------------------------------------
+
+function bar_make_status_weather_temp_f(    src, hour) {
     src = "khatus_sensor_weather"
     hour = 60 * 60
-    t_f = cache_get_fmt_def(src, "temperature_f", 3 * hour, "%d")
-    return sprintf("%s°F", t_f)
+    return cache_get_fmt_def(src, "temperature_f", 3 * hour, "%d")
 }
 
+# -----------------------------------------------------------------------------
+# Datetime
+# -----------------------------------------------------------------------------
+
 function bar_make_status_datetime(    dt) {
     return cache_get_fmt_def("khatus_sensor_datetime", "datetime", 5, "%s")
 }