Merge pull request #179 from mihaicmn/feature-threshold-format

Provide format_above_threshold/format_below_threshold options

1 files changed, 179 insertions, 186 deletions

diff --git a/src/print_cpu_temperature.c b/src/print_cpu_temperature.c
index fd2dd90..57cb114 100644
--- a/src/print_cpu_temperature.c
+++ b/src/print_cpu_temperature.c
@@ -44,17 +44,178 @@
 #define MUKTOC(v) ((v - 273150000) / 1000000.0)
 #endif
 
+typedef struct temperature_s {
+    double raw_value;
+    char formatted_value[20];
+} temperature_t;
+
+#define ERROR_CODE 1
+
+static int read_temperature(char *thermal_zone, temperature_t *temperature) {
+#if defined(LINUX)
+    static char buf[16];
+    long int temp;
+
+    if (!slurp(thermal_zone, buf, sizeof(buf)))
+        return ERROR_CODE;
+
+    temp = strtol(buf, NULL, 10);
+    temperature->raw_value = temp / 1000;
+
+    if (temp == LONG_MIN || temp == LONG_MAX || temp <= 0)
+        strcpy(temperature->formatted_value, "?");
+    else
+        sprintf(temperature->formatted_value, "%ld", (temp / 1000));
+
+#elif defined(__DragonFly__)
+    struct sensor th_sensor;
+    size_t th_sensorlen;
+
+    th_sensorlen = sizeof(th_sensor);
+
+    if (sysctlbyname(thermal_zone, &th_sensor, &th_sensorlen, NULL, 0) == -1) {
+        perror("sysctlbyname");
+        return ERROR_CODE;
+    }
+
+    temperature->raw_value = MUKTOC(th_sensor.value);
+    sprintf(temperature->formatted_value, "%.2f", MUKTOC(th_sensor.value));
+
+#elif defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
+    int sysctl_rslt;
+    size_t sysctl_size = sizeof(sysctl_rslt);
+
+    if (sysctlbyname(thermal_zone, &sysctl_rslt, &sysctl_size, NULL, 0))
+        return ERROR_CODE;
+
+    temperature->raw_value = TZ_AVG(sysctl_rslt);
+    sprintf(temperature->formatted_value, "%d.%d", TZ_KELVTOC(sysctl_rslt));
+
+#elif defined(__OpenBSD__)
+    struct sensordev sensordev;
+    struct sensor sensor;
+    size_t sdlen, slen;
+    int dev, numt, mib[5] = {CTL_HW, HW_SENSORS, 0, 0, 0};
+
+    sdlen = sizeof(sensordev);
+    slen = sizeof(sensor);
+
+    for (dev = 0;; dev++) {
+        mib[2] = dev;
+        if (sysctl(mib, 3, &sensordev, &sdlen, NULL, 0) == -1) {
+            if (errno == ENXIO)
+                continue;
+            if (errno == ENOENT)
+                break;
+            return ERROR_CODE;
+        }
+        /* 'path' is the node within the full path (defaults to acpitz0). */
+        if (BEGINS_WITH(sensordev.xname, thermal_zone)) {
+            mib[3] = SENSOR_TEMP;
+            /* Limit to temo0, but should retrieve from a full path... */
+            for (numt = 0; numt < 1 /*sensordev.maxnumt[SENSOR_TEMP]*/; numt++) {
+                mib[4] = numt;
+                if (sysctl(mib, 5, &sensor, &slen, NULL, 0) == -1) {
+                    if (errno != ENOENT) {
+                        warn("sysctl");
+                        continue;
+                    }
+                }
+                temperature->raw_value = MUKTOC(sensor.value);
+                sprintf(temperature->formatted_value, "%.2f", MUKTOC(sensor.value));
+            }
+        }
+    }
+#elif defined(__NetBSD__)
+    int fd, rval;
+    bool err = false;
+    prop_dictionary_t dict;
+    prop_array_t array;
+    prop_object_iterator_t iter;
+    prop_object_iterator_t iter2;
+    prop_object_t obj, obj2, obj3;
+
+    fd = open("/dev/sysmon", O_RDONLY);
+    if (fd == -1)
+        return ERROR_CODE;
+
+    rval = prop_dictionary_recv_ioctl(fd, ENVSYS_GETDICTIONARY, &dict);
+    if (rval == -1) {
+        err = true;
+        goto error_netbsd1;
+    }
+
+    /* No drivers registered? */
+    if (prop_dictionary_count(dict) == 0) {
+        err = true;
+        goto error_netbsd2;
+    }
+
+    iter = prop_dictionary_iterator(dict);
+    if (iter == NULL) {
+        err = true;
+        goto error_netbsd2;
+    }
+
+    /* iterate over the dictionary returned by the kernel */
+    while ((obj = prop_object_iterator_next(iter)) != NULL) {
+        /* skip this dict if it's not what we're looking for */
+        if ((strlen(prop_dictionary_keysym_cstring_nocopy(obj)) != strlen(thermal_zone)) ||
+            (strncmp(thermal_zone,
+                     prop_dictionary_keysym_cstring_nocopy(obj),
+                     strlen(thermal_zone)) != 0))
+            continue;
+
+        array = prop_dictionary_get_keysym(dict, obj);
+        if (prop_object_type(array) != PROP_TYPE_ARRAY) {
+            err = true;
+            goto error_netbsd3;
+        }
+
+        iter2 = prop_array_iterator(array);
+        if (!iter2) {
+            err = true;
+            goto error_netbsd3;
+        }
+
+        /* iterate over array of dicts specific to target sensor */
+        while ((obj2 = prop_object_iterator_next(iter2)) != NULL) {
+            obj3 = prop_dictionary_get(obj2, "cur-value");
+
+            float temp = MUKTOC(prop_number_integer_value(obj3));
+            temperature->raw_value = temp;
+            sprintf(temperature->formatted_value, "%.2f", temp);
+
+            break;
+        }
+        prop_object_iterator_release(iter2);
+    }
+error_netbsd3:
+    prop_object_iterator_release(iter);
+error_netbsd2:
+    prop_object_release(dict);
+error_netbsd1:
+    close(fd);
+    if (err)
+        return ERROR_CODE;
+
+#endif
+    return 0;
+}
+
 /*
  * Reads the CPU temperature from /sys/class/thermal/thermal_zone%d/temp (or
  * the user provided path) and returns the temperature in degree celcius.
  *
  */
-void print_cpu_temperature_info(yajl_gen json_gen, char *buffer, int zone, const char *path, const char *format, int max_threshold) {
+void print_cpu_temperature_info(yajl_gen json_gen, char *buffer, int zone, const char *path, const char *format, const char *format_above_threshold, int max_threshold) {
     char *outwalk = buffer;
 #ifdef THERMAL_ZONE
+    const char *selected_format = format;
     const char *walk;
     bool colorful_output = false;
     char *thermal_zone;
+    temperature_t temperature;
 
     if (path == NULL)
         asprintf(&thermal_zone, THERMAL_ZONE, zone);
@@ -74,200 +235,32 @@ void print_cpu_temperature_info(yajl_gen json_gen, char *buffer, int zone, const
 
     INSTANCE(thermal_zone);
 
-    for (walk = format; *walk != '\0'; walk++) {
+    if (read_temperature(thermal_zone, &temperature) != 0)
+        goto error;
+
+    if (temperature.raw_value >= max_threshold) {
+        START_COLOR("color_bad");
+        colorful_output = true;
+        if (format_above_threshold != NULL)
+            selected_format = format_above_threshold;
+    }
+
+    for (walk = selected_format; *walk != '\0'; walk++) {
         if (*walk != '%') {
             *(outwalk++) = *walk;
             continue;
         }
-
         if (BEGINS_WITH(walk + 1, "degrees")) {
-#if defined(LINUX)
-            static char buf[16];
-            long int temp;
-            if (!slurp(thermal_zone, buf, sizeof(buf)))
-                goto error;
-            temp = strtol(buf, NULL, 10);
-            if (temp == LONG_MIN || temp == LONG_MAX || temp <= 0)
-                *(outwalk++) = '?';
-            else {
-                if ((temp / 1000) >= max_threshold) {
-                    START_COLOR("color_bad");
-                    colorful_output = true;
-                }
-                outwalk += sprintf(outwalk, "%ld", (temp / 1000));
-                if (colorful_output) {
-                    END_COLOR;
-                    colorful_output = false;
-                }
-            }
-#elif defined(__DragonFly__)
-            struct sensor th_sensor;
-            size_t th_sensorlen;
-
-            th_sensorlen = sizeof(th_sensor);
-
-            if (sysctlbyname(thermal_zone, &th_sensor, &th_sensorlen, NULL, 0) == -1) {
-                perror("sysctlbyname");
-                goto error;
-            }
-            if (MUKTOC(th_sensor.value) >= max_threshold) {
-                START_COLOR("color_bad");
-                colorful_output = true;
-            }
-            outwalk += sprintf(outwalk, "%.2f", MUKTOC(th_sensor.value));
-            if (colorful_output) {
-                END_COLOR;
-                colorful_output = false;
-            }
-
-#elif defined(__FreeBSD__) || defined(__FreeBSD_kernel__)
-            int sysctl_rslt;
-            size_t sysctl_size = sizeof(sysctl_rslt);
-            if (sysctlbyname(thermal_zone, &sysctl_rslt, &sysctl_size, NULL, 0))
-                goto error;
-
-            if (TZ_AVG(sysctl_rslt) >= max_threshold) {
-                START_COLOR("color_bad");
-                colorful_output = true;
-            }
-            outwalk += sprintf(outwalk, "%d.%d", TZ_KELVTOC(sysctl_rslt));
-            if (colorful_output) {
-                END_COLOR;
-                colorful_output = false;
-            }
-
-#elif defined(__OpenBSD__)
-            struct sensordev sensordev;
-            struct sensor sensor;
-            size_t sdlen, slen;
-            int dev, numt, mib[5] = {CTL_HW, HW_SENSORS, 0, 0, 0};
-
-            sdlen = sizeof(sensordev);
-            slen = sizeof(sensor);
-
-            for (dev = 0;; dev++) {
-                mib[2] = dev;
-                if (sysctl(mib, 3, &sensordev, &sdlen, NULL, 0) == -1) {
-                    if (errno == ENXIO)
-                        continue;
-                    if (errno == ENOENT)
-                        break;
-                    goto error;
-                }
-                /* 'path' is the node within the full path (defaults to acpitz0). */
-                if (BEGINS_WITH(sensordev.xname, thermal_zone)) {
-                    mib[3] = SENSOR_TEMP;
-                    /* Limit to temo0, but should retrieve from a full path... */
-                    for (numt = 0; numt < 1 /*sensordev.maxnumt[SENSOR_TEMP]*/; numt++) {
-                        mib[4] = numt;
-                        if (sysctl(mib, 5, &sensor, &slen, NULL, 0) == -1) {
-                            if (errno != ENOENT) {
-                                warn("sysctl");
-                                continue;
-                            }
-                        }
-                        if ((int)MUKTOC(sensor.value) >= max_threshold) {
-                            START_COLOR("color_bad");
-                            colorful_output = true;
-                        }
-
-                        outwalk += sprintf(outwalk, "%.2f", MUKTOC(sensor.value));
-
-                        if (colorful_output) {
-                            END_COLOR;
-                            colorful_output = false;
-                        }
-                    }
-                }
-            }
-#elif defined(__NetBSD__)
-            int fd, rval;
-            bool err = false;
-            prop_dictionary_t dict;
-            prop_array_t array;
-            prop_object_iterator_t iter;
-            prop_object_iterator_t iter2;
-            prop_object_t obj, obj2, obj3;
-
-            fd = open("/dev/sysmon", O_RDONLY);
-            if (fd == -1)
-                goto error;
-
-            rval = prop_dictionary_recv_ioctl(fd, ENVSYS_GETDICTIONARY, &dict);
-            if (rval == -1) {
-                err = true;
-                goto error_netbsd1;
-            }
-
-            /* No drivers registered? */
-            if (prop_dictionary_count(dict) == 0) {
-                err = true;
-                goto error_netbsd2;
-            }
-
-            iter = prop_dictionary_iterator(dict);
-            if (iter == NULL) {
-                err = true;
-                goto error_netbsd2;
-            }
-
-            /* iterate over the dictionary returned by the kernel */
-            while ((obj = prop_object_iterator_next(iter)) != NULL) {
-                /* skip this dict if it's not what we're looking for */
-                if ((strlen(prop_dictionary_keysym_cstring_nocopy(obj)) != strlen(thermal_zone)) ||
-                    (strncmp(thermal_zone,
-                             prop_dictionary_keysym_cstring_nocopy(obj),
-                             strlen(thermal_zone)) != 0))
-                    continue;
-
-                array = prop_dictionary_get_keysym(dict, obj);
-                if (prop_object_type(array) != PROP_TYPE_ARRAY) {
-                    err = true;
-                    goto error_netbsd3;
-                }
-
-                iter2 = prop_array_iterator(array);
-                if (!iter2) {
-                    err = true;
-                    goto error_netbsd3;
-                }
-
-                /* iterate over array of dicts specific to target sensor */
-                while ((obj2 = prop_object_iterator_next(iter2)) != NULL) {
-                    obj3 = prop_dictionary_get(obj2, "cur-value");
-
-                    float temp = MUKTOC(prop_number_integer_value(obj3));
-                    if ((int)temp >= max_threshold) {
-                        START_COLOR("color_bad");
-                        colorful_output = true;
-                    }
-
-                    outwalk += sprintf(outwalk, "%.2f", temp);
-
-                    if (colorful_output) {
-                        END_COLOR;
-                        colorful_output = false;
-                    }
-
-                    break;
-                }
-                prop_object_iterator_release(iter2);
-            }
-        error_netbsd3:
-            prop_object_iterator_release(iter);
-        error_netbsd2:
-            prop_object_release(dict);
-        error_netbsd1:
-            close(fd);
-            if (err)
-                goto error;
-
-#endif
-
+            outwalk += sprintf(outwalk, "%s", temperature.formatted_value);
             walk += strlen("degrees");
         }
     }
 
+    if (colorful_output) {
+        END_COLOR;
+        colorful_output = false;
+    }
+
     free(thermal_zone);
 
     OUTPUT_FULL_TEXT(buffer);