/* * * Conky, a system monitor, based on torsmo * * Any original torsmo code is licensed under the BSD license * * All code written since the fork of torsmo is licensed under the GPL * * Please see COPYING for details * * Copyright (c) 2004, Hannu Saransaari and Lauri Hakkarainen * Copyright (c) 2005-2019 Brenden Matthews, Philip Kovacs, et. al. * (see AUTHORS) * All rights reserved. * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * You should have received a copy of the GNU General Public License * along with this program. If not, see . * */ #include #include #include #include #include #include #include #include #include #include #include #include "config.h" #include "conky.h" #include "core.h" #include "fs.h" #include "logging.h" #include "misc.h" #include "net_stat.h" #include "specials.h" #include "temphelper.h" #include "timeinfo.h" #include "top.h" /* check for OS and include appropriate headers */ #if defined(__linux__) #include "linux.h" #elif defined(__FreeBSD__) || defined(__FreeBSD_kernel__) #include "freebsd.h" #elif defined(__DragonFly__) #include "dragonfly.h" #elif defined(__OpenBSD__) #include "openbsd.h" #elif defined(__APPLE__) && defined(__MACH__) #include "darwin.h" // strings.h #endif #include "update-cb.hh" #ifdef BUILD_CURL #include "ccurl_thread.h" #endif /* BUILD_CURL */ /* folds a string over top of itself, like so: * * if start is "blah", and you call it with count = 1, the result will be "lah" */ void strfold(char *start, int count) { char *curplace; for (curplace = start + count; *curplace != 0; curplace++) { *(curplace - count) = *curplace; } *(curplace - count) = 0; } #ifndef HAVE_STRNDUP // use our own strndup() if it's not available char *strndup(const char *s, size_t n) { if (strlen(s) > n) { char *ret = malloc(n + 1); strncpy(ret, s, n); ret[n] = 0; return ret; } else { return strdup(s); } } #endif /* HAVE_STRNDUP */ int update_uname() { uname(&info.uname_s); #if defined(__DragonFly__) { size_t desc_n; char desc[256]; if (sysctlbyname("kern.version", nullptr, &desc_n, NULL, 0) == -1 || sysctlbyname("kern.version", desc, &desc_n, nullptr, 0) == -1) perror("kern.version"); else { char *start = desc; strsep(&start, " "); strcpy(info.uname_v, strsep(&start, " ")); } if (errno == ENOMEM) printf("desc_n %zu\n", desc_n); } #endif return 0; } double get_time() { struct timespec tv {}; #ifdef _POSIX_MONOTONIC_CLOCK clock_gettime(CLOCK_MONOTONIC, &tv); #else clock_gettime(CLOCK_REALTIME, &tv); #endif return tv.tv_sec + (tv.tv_nsec * 1e-9); } /* Converts '~/...' paths to '/home/blah/...'. It's similar to * variable_substitute, except only cheques for $HOME and ~/ in * path. If HOME is unset it uses an empty string for substitution */ std::string to_real_path(const std::string &source) { const char *homedir = getenv("HOME") != nullptr ? getenv("HOME") : ""; if (source.find("~/") == 0) { return homedir + source.substr(1); } if (source.find("$HOME/") == 0) { return homedir + source.substr(5); } return source; } int open_fifo(const char *file, int *reported) { int fd = 0; fd = open(file, O_RDONLY | O_NONBLOCK | O_CLOEXEC); if (fd == -1) { if ((reported == nullptr) || *reported == 0) { NORM_ERR("can't open %s: %s", file, strerror(errno)); if (reported != nullptr) { *reported = 1; } } return -1; } return fd; } FILE *open_file(const char *file, int *reported) { FILE *fp = nullptr; fp = fopen(file, "re"); if (fp == nullptr) { if ((reported == nullptr) || *reported == 0) { NORM_ERR("can't open %s: %s", file, strerror(errno)); if (reported != nullptr) { *reported = 1; } } return nullptr; } return fp; } std::string variable_substitute(std::string s) { std::string::size_type pos = 0; while ((pos = s.find('$', pos)) != std::string::npos) { if (pos + 1 >= s.size()) { break; } if (s[pos + 1] == '$') { s.erase(pos, 1); ++pos; } else { std::string var; std::string::size_type l = 0; if (isalpha((unsigned char)s[pos + 1]) != 0) { l = 1; while (pos + l < s.size() && (isalnum((unsigned char)s[pos + l]) != 0)) { ++l; } var = s.substr(pos + 1, l - 1); } else if (s[pos + 1] == '{') { l = s.find('}', pos); if (l == std::string::npos) { break; } l -= pos - 1; var = s.substr(pos + 2, l - 3); } else { ++pos; } if (l != 0u) { s.erase(pos, l); const char *val = getenv(var.c_str()); if (val != nullptr) { s.insert(pos, val); pos += strlen(val); } } } } return s; } void format_seconds(char *buf, unsigned int n, long seconds) { long days; int hours, minutes; if (times_in_seconds.get(*state)) { snprintf(buf, n, "%ld", seconds); return; } days = seconds / 86400; seconds %= 86400; hours = seconds / 3600; seconds %= 3600; minutes = seconds / 60; seconds %= 60; if (days > 0) { snprintf(buf, n, "%ldd %dh %dm", days, hours, minutes); } else { snprintf(buf, n, "%dh %dm %lds", hours, minutes, seconds); } } void format_seconds_short(char *buf, unsigned int n, long seconds) { long days; int hours, minutes; if (times_in_seconds.get(*state)) { snprintf(buf, n, "%ld", seconds); return; } days = seconds / 86400; seconds %= 86400; hours = seconds / 3600; seconds %= 3600; minutes = seconds / 60; seconds %= 60; if (days > 0) { snprintf(buf, n, "%ldd %dh", days, hours); } else if (hours > 0) { snprintf(buf, n, "%dh %dm", hours, minutes); } else { snprintf(buf, n, "%dm %lds", minutes, seconds); } } conky::simple_config_setting no_buffers("no_buffers", true, true); conky::simple_config_setting bar_fill("console_bar_fill", "#", false); conky::simple_config_setting bar_unfill("console_bar_unfill", ".", false); conky::simple_config_setting github_token("github_token", "", false); void update_stuff() { /* clear speeds, addresses and up status in case device was removed and * doesn't get updated */ #ifdef HAVE_OPENMP #pragma omp parallel for schedule(dynamic, 10) #endif /* HAVE_OPENMP */ for (int i = 0; i < MAX_NET_INTERFACES; ++i) { if (netstats[i].dev != nullptr) { netstats[i].up = 0; netstats[i].recv_speed = 0.0; netstats[i].trans_speed = 0.0; netstats[i].addr.sa_data[2] = 0; netstats[i].addr.sa_data[3] = 0; netstats[i].addr.sa_data[4] = 0; netstats[i].addr.sa_data[5] = 0; } } /* this is a stub on all platforms except solaris */ prepare_update(); /* if you registered a callback with conky::register_cb, this will run it */ conky::run_all_callbacks(); /* XXX: move the following into the update_meminfo() functions? */ if (no_buffers.get(*state)) { info.mem -= info.bufmem; info.memeasyfree += info.bufmem; } } /* Ohkie to return negative values for temperatures */ int round_to_int_temp(float f) { return static_cast(f); } /* Don't return negative values for cpugraph, bar, gauge, percentage. * Causes unreasonable numbers to show */ unsigned int round_to_int(float f) { if (f >= 0.0) { return static_cast(f + 0.5); } return 0; } void scan_loadavg_arg(struct text_object *obj, const char *arg) { obj->data.i = 0; if ((arg != nullptr) && (arg[1] == 0) && (isdigit((unsigned char)arg[0]) != 0)) { obj->data.i = atoi(arg); if (obj->data.i > 3 || obj->data.i < 1) { NORM_ERR("loadavg arg needs to be in range (1,3)"); obj->data.i = 0; } } /* convert to array index (or the default (-1)) */ obj->data.i--; } void print_loadavg(struct text_object *obj, char *p, unsigned int p_max_size) { float *v = info.loadavg; if (obj->data.i < 0) { snprintf(p, p_max_size, "%.2f %.2f %.2f", v[0], v[1], v[2]); } else { snprintf(p, p_max_size, "%.2f", v[obj->data.i]); } } void scan_no_update(struct text_object *obj, const char *arg) { obj->data.s = static_cast(malloc(text_buffer_size.get(*state))); evaluate(arg, obj->data.s, text_buffer_size.get(*state)); obj->data.s = static_cast(realloc(obj->data.s, strlen(obj->data.s) + 1)); } void free_no_update(struct text_object *obj) { free(obj->data.s); } void print_no_update(struct text_object *obj, char *p, unsigned int p_max_size) { snprintf(p, p_max_size, "%s", obj->data.s); } #ifdef BUILD_X11 void scan_loadgraph_arg(struct text_object *obj, const char *arg) { char *buf = nullptr; buf = scan_graph(obj, arg, 0); free_and_zero(buf); } double loadgraphval(struct text_object *obj) { (void)obj; return info.loadavg[0]; } #endif /* BUILD_X11 */ uint8_t cpu_percentage(struct text_object *obj) { if ((unsigned int)obj->data.i > info.cpu_count) { NORM_ERR("obj->data.i %i info.cpu_count %i", obj->data.i, info.cpu_count); CRIT_ERR(nullptr, nullptr, "attempting to use more CPUs than you have!"); } if (info.cpu_usage != nullptr) { return round_to_int(info.cpu_usage[obj->data.i] * 100.0); } return 0; } double cpu_barval(struct text_object *obj) { if (info.cpu_usage != nullptr) { return info.cpu_usage[obj->data.i]; } return 0.; } #define PRINT_HR_GENERATOR(name) \ void print_##name(struct text_object *obj, char *p, \ unsigned int p_max_size) { \ human_readable(apply_base_multiplier(obj->data.s, info.name), p, \ p_max_size); \ } PRINT_HR_GENERATOR(mem) PRINT_HR_GENERATOR(memwithbuffers) PRINT_HR_GENERATOR(memeasyfree) PRINT_HR_GENERATOR(memfree) PRINT_HR_GENERATOR(memmax) PRINT_HR_GENERATOR(memdirty) PRINT_HR_GENERATOR(swap) PRINT_HR_GENERATOR(swapfree) PRINT_HR_GENERATOR(swapmax) uint8_t mem_percentage(struct text_object *obj) { (void)obj; return (info.memmax != 0u ? round_to_int(info.mem * 100 / info.memmax) : 0); } double mem_barval(struct text_object *obj) { (void)obj; return info.memmax != 0u ? (static_cast(info.mem) / info.memmax) : 0; } double mem_with_buffers_barval(struct text_object *obj) { (void)obj; return info.memmax != 0u ? (static_cast(info.memwithbuffers) / info.memmax) : 0; } uint8_t swap_percentage(struct text_object *obj) { (void)obj; return (info.swapmax != 0u ? round_to_int(info.swap * 100 / info.swapmax) : 0); } double swap_barval(struct text_object *obj) { (void)obj; return info.swapmax != 0u ? (static_cast(info.swap) / info.swapmax) : 0; } void print_kernel(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; snprintf(p, p_max_size, "%s", info.uname_s.release); } void print_machine(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; snprintf(p, p_max_size, "%s", info.uname_s.machine); } void print_nodename(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; snprintf(p, p_max_size, "%s", info.uname_s.nodename); } void print_nodename_short(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; snprintf(p, p_max_size, "%s", info.uname_s.nodename); for (int i = 0; p[i] != 0; i++) { if (p[i] == '.') { p[i] = 0; break; } } } void print_sysname(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; snprintf(p, p_max_size, "%s", info.uname_s.sysname); } #if defined(__DragonFly__) void print_version(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; snprintf(p, p_max_size, "%s", info.uname_v); } #endif void print_uptime(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; format_seconds(p, p_max_size, static_cast(info.uptime)); } void print_uptime_short(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; format_seconds_short(p, p_max_size, static_cast(info.uptime)); } void print_processes(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; spaced_print(p, p_max_size, "%hu", 4, info.procs); } void print_running_processes(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; spaced_print(p, p_max_size, "%hu", 4, info.run_procs); } void print_running_threads(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; spaced_print(p, p_max_size, "%hu", 4, info.run_threads); } void print_threads(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; spaced_print(p, p_max_size, "%hu", 4, info.threads); } void print_buffers(struct text_object *obj, char *p, unsigned int p_max_size) { human_readable(apply_base_multiplier(obj->data.s, info.buffers), p, p_max_size); } void print_cached(struct text_object *obj, char *p, unsigned int p_max_size) { human_readable(apply_base_multiplier(obj->data.s, info.cached), p, p_max_size); } void print_evaluate(struct text_object *obj, char *p, unsigned int p_max_size) { std::vector buf(text_buffer_size.get(*state)); evaluate(obj->data.s, &buf[0], buf.size()); evaluate(&buf[0], p, p_max_size); } int if_empty_iftest(struct text_object *obj) { std::vector buf(max_user_text.get(*state)); int result = 1; generate_text_internal(&(buf[0]), max_user_text.get(*state), *obj->sub); if (strlen(&(buf[0])) != 0) { result = 0; } return result; } static int check_contains(char *f, char *s) { int ret = 0; FILE *where = open_file(f, nullptr); if (where != nullptr) { char buf1[256]; while (fgets(buf1, 256, where) != nullptr) { if (strstr(buf1, s) != nullptr) { ret = 1; break; } } fclose(where); } else { NORM_ERR("Could not open the file"); } return ret; } int if_existing_iftest(struct text_object *obj) { char *spc; int result = 0; spc = strchr(obj->data.s, ' '); if (spc != nullptr) { *spc = 0; } if (access(obj->data.s, F_OK) == 0) { if (spc == nullptr || (check_contains(obj->data.s, spc + 1) != 0)) { result = 1; } } if (spc != nullptr) { *spc = ' '; } return result; } int if_running_iftest(struct text_object *obj) { #ifdef __linux__ if (!get_process_by_name(obj->data.s)) { #else if (((obj->data.s) != nullptr) && (system(obj->data.s) != 0)) { #endif return 0; } return 1; } #ifndef __OpenBSD__ void print_acpitemp(struct text_object *obj, char *p, unsigned int p_max_size) { temp_print(p, p_max_size, get_acpi_temperature(obj->data.i), TEMP_CELSIUS, 1); } void free_acpitemp(struct text_object *obj) { close(obj->data.i); } #endif /* !__OpenBSD__ */ void print_freq(struct text_object *obj, char *p, unsigned int p_max_size) { static int ok = 1; if (ok != 0) { ok = get_freq(p, p_max_size, "%.0f", 1, obj->data.i); } } void print_freq_g(struct text_object *obj, char *p, unsigned int p_max_size) { static int ok = 1; if (ok != 0) { #ifndef __OpenBSD__ ok = get_freq(p, p_max_size, "%'.2f", 1000, obj->data.i); #else /* OpenBSD has no such flag (SUSv2) */ ok = get_freq(p, p_max_size, "%.2f", 1000, obj->data.i); #endif /* __OpenBSD */ } } #ifndef __OpenBSD__ void print_acpifan(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; get_acpi_fan(p, p_max_size); } void print_acpiacadapter(struct text_object *obj, char *p, unsigned int p_max_size) { get_acpi_ac_adapter(p, p_max_size, static_cast(obj->data.opaque)); } void print_battery(struct text_object *obj, char *p, unsigned int p_max_size) { get_battery_stuff(p, p_max_size, obj->data.s, BATTERY_STATUS); } void print_battery_time(struct text_object *obj, char *p, unsigned int p_max_size) { get_battery_stuff(p, p_max_size, obj->data.s, BATTERY_TIME); } uint8_t battery_percentage(struct text_object *obj) { return get_battery_perct(obj->data.s); } void print_battery_short(struct text_object *obj, char *p, unsigned int p_max_size) { get_battery_short_status(p, p_max_size, obj->data.s); } void print_battery_status(struct text_object *obj, char *p, unsigned int p_max_size) { get_battery_stuff(p, p_max_size, obj->data.s, BATTERY_STATUS); if (0 == strncmp("charging", p, 8)) { snprintf(p, p_max_size, "%s", "charging"); } else if (0 == strncmp("discharging", p, 11) || 0 == strncmp("remaining", p, 9)) { snprintf(p, p_max_size, "%s", "discharging"); } else if (0 == strncmp("charged", p, 7)) { snprintf(p, p_max_size, "%s", "charged"); } else if (0 == strncmp("not present", p, 11) || 0 == strncmp("absent/on AC", p, 12)) { snprintf(p, p_max_size, "%s", "not present"); } else if (0 == strncmp("empty", p, 5)) { snprintf(p, p_max_size, "%s", "empty"); } else if (0 == strncmp("unknown", p, 7)) { snprintf(p, p_max_size, "%s", "unknown"); } } #endif /* !__OpenBSD__ */ void print_blink(struct text_object *obj, char *p, unsigned int p_max_size) { // blinking like this can look a bit ugly if the chars in the font don't have // the same width std::vector buf(max_user_text.get(*state)); static int visible = 1; static int last_len = 0; int i; if (visible != 0) { generate_text_internal(&(buf[0]), max_user_text.get(*state), *obj->sub); last_len = strlen(&(buf[0])); } else { for (i = 0; i < last_len; i++) { buf[i] = ' '; } } snprintf(p, p_max_size, "%s", &(buf[0])); visible = static_cast(static_cast(visible) == 0); } void print_include(struct text_object *obj, char *p, unsigned int p_max_size) { std::vector buf(max_user_text.get(*state)); if (obj->sub == nullptr) { return; } generate_text_internal(&(buf[0]), max_user_text.get(*state), *obj->sub); snprintf(p, p_max_size, "%s", &(buf[0])); } #ifdef BUILD_CURL #define NEW_TOKEN \ "https://github.com/settings/tokens/" \ "new?scopes=notifications&description=conky-query-github\n" static size_t read_github_data_cb(char *, size_t, size_t, char *); static size_t read_github_data_cb(char *data, size_t size, size_t nmemb, char *p) { char *ptr = data; size_t sz = nmemb * size; size_t z = 0; static size_t x = 0; static unsigned int skip = 0U; for (; *ptr; ptr++, z++) { if (z + 4 < sz) { /* Verifying up to *(ptr+4) */ if ('u' == *ptr && 'n' == *(ptr + 1) && 'r' == *(ptr + 2) && 'e' == *(ptr + 3)) { /* "unread" */ ++x; skip = 0U; } if ('m' == *ptr && 'e' == *(ptr + 1) && 's' == *(ptr + 2) && 's' == *(ptr + 3) && z + 13 < sz) { /* "message": */ if ('B' == *(ptr + 10) && 'a' == *(ptr + 11) && 'd' == *(ptr + 12)) { /* "Bad credentials" */ NORM_ERR("Bad credentials: generate a new token:\n" NEW_TOKEN); snprintf(p, 80, "%s", "GitHub: Bad credentials, generate a new token."); skip = 1U; break; } if ('M' == *(ptr + 10) && 'i' == *(ptr + 11) && 's' == *(ptr + 12)) { /* Missing the 'notifications' scope. */ NORM_ERR( "Missing 'notifications' scope. Generate a new " "token\n" NEW_TOKEN); snprintf( p, 80, "%s", "GitHub: Missing the notifications scope. Generate a new token."); skip = 1U; break; } } } } if (0U == skip) { snprintf(p, 49, "%zu", x); } return sz; } void print_github(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; char github_url[256] = {""}; char user_agent[30] = {""}; static char cached_result[256] = {""}; static unsigned int last_update = 1U; CURL *curl = nullptr; CURLcode res; if (0 == strcmp(github_token.get(*state).c_str(), "")) { NORM_ERR( "${github_notifications} requires token. " "Go ahead and generate one " NEW_TOKEN "Insert it in conky.config = { github_token='TOKEN_SHA' }\n"); snprintf(p, p_max_size, "%s", "GitHub notifications requires token, generate a new one."); return; } if (1U != last_update) { --last_update; snprintf(p, p_max_size, "%s", cached_result); return; } snprintf(github_url, 255, "%s%s", "https://api.github.com/notifications?access_token=", github_token.get(*state).c_str()); /* unique string for each conky user, so we dont hit any query limits */ snprintf(user_agent, 29, "conky/%s", github_token.get(*state).c_str()); curl_global_init(CURL_GLOBAL_ALL); if (nullptr == (curl = curl_easy_init())) { goto error; } curl_easy_setopt(curl, CURLOPT_URL, github_url); curl_easy_setopt(curl, CURLOPT_ACCEPT_ENCODING, "gzip"); curl_easy_setopt(curl, CURLOPT_USERAGENT, user_agent); curl_easy_setopt(curl, CURLOPT_USE_SSL, (long)CURLUSESSL_ALL); curl_easy_setopt(curl, CURLOPT_TIMEOUT, 20L); curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, read_github_data_cb); curl_easy_setopt(curl, CURLOPT_WRITEDATA, p); res = curl_easy_perform(curl); if (CURLE_OK != res) { goto error; } snprintf(cached_result, 255, "%s", p); last_update = 60U; error: if (nullptr != curl) { curl_easy_cleanup(curl); } curl_global_cleanup(); if (!isdigit((unsigned char)*p)) { last_update = 1U; } } void print_stock(struct text_object *obj, char *p, unsigned int p_max_size) { if (!obj->data.s) { p[0] = 0; return; } ccurl_process_info(p, p_max_size, obj->data.s, 1); } void free_stock(struct text_object *obj) { free(obj->data.s); } #endif /* BUILD_CURL */ void print_to_bytes(struct text_object *obj, char *p, unsigned int p_max_size) { std::vector buf(max_user_text.get(*state)); long double bytes; char unit[16]; // 16 because we can also have long names (like mega-bytes) generate_text_internal(&(buf[0]), max_user_text.get(*state), *obj->sub); if (sscanf(&(buf[0]), "%Lf%s", &bytes, unit) == 2 && strlen(unit) < 16) { if (strncasecmp("b", unit, 1) == 0) { snprintf(&(buf[0]), max_user_text.get(*state), "%Lf", bytes); } else if (strncasecmp("k", unit, 1) == 0) { snprintf(&(buf[0]), max_user_text.get(*state), "%Lf", bytes * 1024); } else if (strncasecmp("m", unit, 1) == 0) { snprintf(&(buf[0]), max_user_text.get(*state), "%Lf", bytes * 1024 * 1024); } else if (strncasecmp("g", unit, 1) == 0) { snprintf(&(buf[0]), max_user_text.get(*state), "%Lf", bytes * 1024 * 1024 * 1024); } else if (strncasecmp("t", unit, 1) == 0) { snprintf(&(buf[0]), max_user_text.get(*state), "%Lf", bytes * 1024 * 1024 * 1024 * 1024); } } snprintf(p, p_max_size, "%s", &(buf[0])); } void print_updates(struct text_object *obj, char *p, unsigned int p_max_size) { (void)obj; snprintf(p, p_max_size, "%d", get_total_updates()); } int updatenr_iftest(struct text_object *obj) { if (get_total_updates() % get_updatereset() != obj->data.i - 1) { return 0; } return 1; }