X-Git-Url: http://git.maemo.org/git/?a=blobdiff_plain;f=src%2Flinux.c;h=49e47684180a2d1d5b74aa26753e39610ed823e3;hb=19516645fd679ce8c6779722bb831a42d0b3ddfe;hp=78121bd840c0b8ee27c9e47de54dab400a69f39a;hpb=06de5573e8e13c1d28b2e40a6b1f838df611dcf6;p=monky diff --git a/src/linux.c b/src/linux.c index 78121bd..49e4768 100644 --- a/src/linux.c +++ b/src/linux.c @@ -1,4 +1,7 @@ -/* Conky, a system monitor, based on torsmo +/* -*- mode: c; c-basic-offset: 4; tab-width: 4; indent-tabs-mode: t -*- + * vim: ts=4 sw=4 noet ai cindent syntax=c + * + * Conky, a system monitor, based on torsmo * * Any original torsmo code is licensed under the BSD license * @@ -8,7 +11,7 @@ * * Copyright (c) 2004, Hannu Saransaari and Lauri Hakkarainen * Copyright (c) 2007 Toni Spets - * Copyright (c) 2005-2009 Brenden Matthews, Philip Kovacs, et. al. + * Copyright (c) 2005-2010 Brenden Matthews, Philip Kovacs, et. al. * (see AUTHORS) * All rights reserved. * @@ -30,7 +33,9 @@ #include "logging.h" #include "common.h" #include "linux.h" +#include "net_stat.h" #include "diskio.h" +#include "temphelper.h" #include #include #include @@ -58,6 +63,7 @@ #endif #include #include +#include /* The following ifdefs were adapted from gkrellm */ #include @@ -78,6 +84,14 @@ #include #endif +struct sysfs { + int fd; + int arg; + char devtype[256]; + char type[64]; + float factor, offset; +}; + #define SHORTSTAT_TEMPL "%*s %llu %llu %llu" #define LONGSTAT_TEMPL "%*s %llu %llu %llu " @@ -91,7 +105,7 @@ void prepare_update(void) { } -void update_uptime(void) +int update_uptime(void) { #ifdef HAVE_SYSINFO if (!prefer_proc) { @@ -107,12 +121,12 @@ void update_uptime(void) if (!(fp = open_file("/proc/uptime", &rep))) { info.uptime = 0.0; - return; + return 0; } fscanf(fp, "%lf", &info.uptime); fclose(fp); } - info.mask |= (1 << INFO_UPTIME); + return 0; } int check_mount(char *s) @@ -132,7 +146,7 @@ int check_mount(char *s) } fclose(mtab); } else { - ERR("Could not open mtab"); + NORM_ERR("Could not open mtab"); } return ret; } @@ -140,7 +154,7 @@ int check_mount(char *s) /* these things are also in sysinfo except Buffers: * (that's why I'm reading them from proc) */ -void update_meminfo(void) +int update_meminfo(void) { FILE *meminfo_fp; static int rep = 0; @@ -152,7 +166,7 @@ void update_meminfo(void) info.buffers = info.cached = info.memfree = info.memeasyfree = 0; if (!(meminfo_fp = open_file("/proc/meminfo", &rep))) { - return; + return 0; } while (!feof(meminfo_fp)) { @@ -181,9 +195,8 @@ void update_meminfo(void) info.bufmem = info.cached + info.buffers; - info.mask |= (1 << INFO_MEM) | (1 << INFO_BUFFERS); - fclose(meminfo_fp); + return 0; } int get_laptop_mode(void) @@ -225,6 +238,12 @@ char *get_ioscheduler(char *disk) return strndup("n/a", text_buffer_size); } +static struct { + char *iface; + char *ip; + int count; +} gw_info; + #define COND_FREE(x) if(x) free(x); x = 0 #define SAVE_SET_STRING(x, y) \ if (x && strcmp((char *)x, (char *)y)) { \ @@ -240,15 +259,15 @@ void update_gateway_info_failure(const char *reason) perror(reason); } //2 pointers to 1 location causes a crash when we try to free them both - info.gw_info.iface = strndup("failed", text_buffer_size); - info.gw_info.ip = strndup("failed", text_buffer_size); + gw_info.iface = strndup("failed", text_buffer_size); + gw_info.ip = strndup("failed", text_buffer_size); } /* Iface Destination Gateway Flags RefCnt Use Metric Mask MTU Window IRTT */ #define RT_ENTRY_FORMAT "%63s %lx %lx %x %*d %*d %*d %lx %*d %*d %*d\n" -void update_gateway_info(void) +int update_gateway_info(void) { FILE *fp; struct in_addr ina; @@ -256,15 +275,13 @@ void update_gateway_info(void) unsigned long dest, gate, mask; unsigned int flags; - struct gateway_info *gw_info = &info.gw_info; - - COND_FREE(gw_info->iface); - COND_FREE(gw_info->ip); - gw_info->count = 0; + COND_FREE(gw_info.iface); + COND_FREE(gw_info.ip); + gw_info.count = 0; if ((fp = fopen("/proc/net/route", "r")) == NULL) { update_gateway_info_failure("fopen()"); - return; + return 0; } /* skip over the table header line, which is always present */ @@ -277,17 +294,41 @@ void update_gateway_info(void) break; } if (!(dest || mask) && ((flags & RTF_GATEWAY) || !gate) ) { - gw_info->count++; - SAVE_SET_STRING(gw_info->iface, iface) + gw_info.count++; + SAVE_SET_STRING(gw_info.iface, iface) ina.s_addr = gate; - SAVE_SET_STRING(gw_info->ip, inet_ntoa(ina)) + SAVE_SET_STRING(gw_info.ip, inet_ntoa(ina)) } } fclose(fp); - return; + return 0; } -void update_net_stats(void) +void free_gateway_info(void) +{ + if (gw_info.iface) + free(gw_info.iface); + if (gw_info.ip) + free(gw_info.ip); + memset(&gw_info, 0, sizeof(gw_info)); +} + +int gateway_exists(void) +{ + return !!gw_info.count; +} + +void print_gateway_iface(char *p, int p_max_size) +{ + snprintf(p, p_max_size, "%s", gw_info.iface); +} + +void print_gateway_ip(char *p, int p_max_size) +{ + snprintf(p, p_max_size, "%s", gw_info.ip); +} + +int update_net_stats(void) { FILE *net_dev_fp; static int rep = 0; @@ -311,20 +352,20 @@ void update_net_stats(void) /* get delta */ delta = current_update_time - last_update_time; if (delta <= 0.0001) { - return; + return 0; } /* open file and ignore first two lines */ if (!(net_dev_fp = open_file("/proc/net/dev", &rep))) { clear_net_stats(); - return; + return 0; } fgets(buf, 255, net_dev_fp); /* garbage */ fgets(buf, 255, net_dev_fp); /* garbage (field names) */ /* read each interface */ - for (i2 = 0; i2 < 16; i2++) { + for (i2 = 0; i2 < MAX_NET_INTERFACES; i2++) { struct net_stat *ns; char *s, *p; char temp_addr[18]; @@ -353,7 +394,7 @@ void update_net_stats(void) ns->up = 1; memset(&(ns->addr.sa_data), 0, 14); - memset(ns->addrs, 0, 17 * 16 + 1); /* Up to 17 chars per ip, max 16 interfaces. Nasty memory usage... */ + memset(ns->addrs, 0, 17 * MAX_NET_INTERFACES + 1); /* Up to 17 chars per ip, max MAX_NET_INTERFACES interfaces. Nasty memory usage... */ last_recv = ns->recv; last_trans = ns->trans; @@ -380,8 +421,8 @@ void update_net_stats(void) /*** ip addr patch ***/ i = socket(PF_INET, SOCK_DGRAM, IPPROTO_IP); - conf.ifc_buf = malloc(sizeof(struct ifreq) * 16); - conf.ifc_len = sizeof(struct ifreq) * 16; + conf.ifc_buf = malloc(sizeof(struct ifreq) * MAX_NET_INTERFACES); + conf.ifc_len = sizeof(struct ifreq) * MAX_NET_INTERFACES; memset(conf.ifc_buf, 0, conf.ifc_len); ioctl((long) i, SIOCGIFCONF, &conf); @@ -420,23 +461,17 @@ void update_net_stats(void) curtmp2 = 0; // get an average #ifdef HAVE_OPENMP -#pragma omp parallel for reduction(+:curtmp1, curtmp2) +#pragma omp parallel for reduction(+:curtmp1, curtmp2) schedule(dynamic,10) #endif /* HAVE_OPENMP */ for (i = 0; i < info.net_avg_samples; i++) { curtmp1 = curtmp1 + ns->net_rec[i]; curtmp2 = curtmp2 + ns->net_trans[i]; } - if (curtmp1 == 0) { - curtmp1 = 1; - } - if (curtmp2 == 0) { - curtmp2 = 1; - } ns->recv_speed = curtmp1 / (double) info.net_avg_samples; ns->trans_speed = curtmp2 / (double) info.net_avg_samples; if (info.net_avg_samples > 1) { #ifdef HAVE_OPENMP -#pragma omp parallel for +#pragma omp parallel for schedule(dynamic,10) #endif /* HAVE_OPENMP */ for (i = info.net_avg_samples; i > 1; i--) { ns->net_rec[i - 1] = ns->net_rec[i - 2]; @@ -505,20 +540,45 @@ void update_net_stats(void) first = 0; fclose(net_dev_fp); - - info.mask |= (1 << INFO_NET); + return 0; } int result; -void update_total_processes(void) +int update_total_processes(void) +{ + DIR *dir; + struct dirent *entry; + int ignore1; + char ignore2; + + info.procs = 0; + if (!(dir = opendir("/proc"))) { + return 0; + } + while ((entry = readdir(dir))) { + if (!entry) { + /* Problem reading list of processes */ + closedir(dir); + info.procs = 0; + return 0; + } + if (sscanf(entry->d_name, "%d%c", &ignore1, &ignore2) == 1) { + info.procs++; + } + } + closedir(dir); + return 0; +} + +int update_threads(void) { #ifdef HAVE_SYSINFO if (!prefer_proc) { struct sysinfo s_info; sysinfo(&s_info); - info.procs = s_info.procs; + info.threads = s_info.procs; } else #endif { @@ -526,13 +586,13 @@ void update_total_processes(void) FILE *fp; if (!(fp = open_file("/proc/loadavg", &rep))) { - info.procs = 0; - return; + info.threads = 0; + return 0; } - fscanf(fp, "%*f %*f %*f %*d/%hu", &info.procs); + fscanf(fp, "%*f %*f %*f %*d/%hu", &info.threads); fclose(fp); } - info.mask |= (1 << INFO_PROCS); + return 0; } #define CPU_SAMPLE_COUNT 15 @@ -606,7 +666,7 @@ void get_cpu_count(void) #define TMPL_LONGSTAT "%*s %llu %llu %llu %llu %llu %llu %llu %llu" #define TMPL_SHORTSTAT "%*s %llu %llu %llu %llu" -inline static void update_stat(void) +int update_stat(void) { FILE *stat_fp; static int rep = 0; @@ -619,6 +679,20 @@ inline static void update_stat(void) unsigned int malloc_cpu_size = 0; extern void* global_cpu; + static pthread_mutex_t last_stat_update_mutex = PTHREAD_MUTEX_INITIALIZER; + static double last_stat_update = 0.0; + + /* since we use wrappers for this function, the update machinery + * can't eliminate double invocations of this function. Check for + * them here, otherwise cpu_usage counters are freaking out. */ + pthread_mutex_lock(&last_stat_update_mutex); + if (last_stat_update == current_update_time) { + pthread_mutex_unlock(&last_stat_update_mutex); + return 0; + } + last_stat_update = current_update_time; + pthread_mutex_unlock(&last_stat_update_mutex); + /* add check for !info.cpu_usage since that mem is freed on a SIGUSR1 */ if (!cpu_setup || !info.cpu_usage) { get_cpu_count(); @@ -630,7 +704,7 @@ inline static void update_stat(void) KFLAG_ISSET(KFLAG_IS_LONGSTAT) ? TMPL_LONGSTAT : TMPL_SHORTSTAT; } - if (!cpu) { + if (!global_cpu) { malloc_cpu_size = (info.cpu_count + 1) * sizeof(struct cpu_info); cpu = malloc(malloc_cpu_size); memset(cpu, 0, malloc_cpu_size); @@ -638,11 +712,11 @@ inline static void update_stat(void) } if (!(stat_fp = open_file("/proc/stat", &rep))) { - info.run_procs = 0; + info.run_threads = 0; if (info.cpu_usage) { memset(info.cpu_usage, 0, info.cpu_count * sizeof(float)); } - return; + return 0; } idx = 0; @@ -652,8 +726,7 @@ inline static void update_stat(void) } if (strncmp(buf, "procs_running ", 14) == 0) { - sscanf(buf, "%*s %hu", &info.run_procs); - info.mask |= (1 << INFO_RUN_PROCS); + sscanf(buf, "%*s %hu", &info.run_threads); } else if (strncmp(buf, "cpu", 3) == 0) { double delta; if (isdigit(buf[3])) { @@ -674,7 +747,6 @@ inline static void update_stat(void) cpu[idx].cpu_active_total = cpu[idx].cpu_total - (cpu[idx].cpu_idle + cpu[idx].cpu_iowait); - info.mask |= (1 << INFO_CPU); delta = current_update_time - last_update_time; @@ -687,7 +759,7 @@ inline static void update_stat(void) (float) (cpu[idx].cpu_total - cpu[idx].cpu_last_total); curtmp = 0; #ifdef HAVE_OPENMP -#pragma omp parallel for reduction(+:curtmp) +#pragma omp parallel for reduction(+:curtmp) schedule(dynamic,10) #endif /* HAVE_OPENMP */ for (i = 0; i < info.cpu_avg_samples; i++) { curtmp = curtmp + cpu[idx].cpu_val[i]; @@ -707,7 +779,7 @@ inline static void update_stat(void) cpu[idx].cpu_last_total = cpu[idx].cpu_total; cpu[idx].cpu_last_active_total = cpu[idx].cpu_active_total; #ifdef HAVE_OPENMP -#pragma omp parallel for +#pragma omp parallel for schedule(dynamic,10) #endif /* HAVE_OPENMP */ for (i = info.cpu_avg_samples - 1; i > 0; i--) { cpu[idx].cpu_val[i] = cpu[idx].cpu_val[i - 1]; @@ -715,19 +787,22 @@ inline static void update_stat(void) } } fclose(stat_fp); + return 0; } -void update_running_processes(void) +int update_running_processes(void) { update_stat(); + return 0; } -void update_cpu_usage(void) +int update_cpu_usage(void) { update_stat(); + return 0; } -void update_load_average(void) +int update_load_average(void) { #ifdef HAVE_GETLOADAVG if (!prefer_proc) { @@ -745,47 +820,13 @@ void update_load_average(void) if (!(fp = open_file("/proc/loadavg", &rep))) { info.loadavg[0] = info.loadavg[1] = info.loadavg[2] = 0.0; - return; + return 0; } fscanf(fp, "%f %f %f", &info.loadavg[0], &info.loadavg[1], &info.loadavg[2]); fclose(fp); } - info.mask |= (1 << INFO_LOADAVG); -} - -#define PROC_I8K "/proc/i8k" -#define I8K_DELIM " " -static char *i8k_procbuf = NULL; -void update_i8k(void) -{ - FILE *fp; - - if (!i8k_procbuf) { - i8k_procbuf = (char *) malloc(128 * sizeof(char)); - } - if ((fp = fopen(PROC_I8K, "r")) == NULL) { - CRIT_ERR(NULL, NULL, "/proc/i8k doesn't exist! use insmod to make sure the kernel " - "driver is loaded..."); - } - - memset(&i8k_procbuf[0], 0, 128); - if (fread(&i8k_procbuf[0], sizeof(char), 128, fp) == 0) { - ERR("something wrong with /proc/i8k..."); - } - - fclose(fp); - - i8k.version = strtok(&i8k_procbuf[0], I8K_DELIM); - i8k.bios = strtok(NULL, I8K_DELIM); - i8k.serial = strtok(NULL, I8K_DELIM); - i8k.cpu_temp = strtok(NULL, I8K_DELIM); - i8k.left_fan_status = strtok(NULL, I8K_DELIM); - i8k.right_fan_status = strtok(NULL, I8K_DELIM); - i8k.left_fan_rpm = strtok(NULL, I8K_DELIM); - i8k.right_fan_rpm = strtok(NULL, I8K_DELIM); - i8k.ac_status = strtok(NULL, I8K_DELIM); - i8k.buttons_status = strtok(NULL, I8K_DELIM); + return 0; } /***********************************************************/ @@ -808,7 +849,7 @@ static int get_first_file_in_a_directory(const char *dir, char *s, int *rep) n = scandir(dir, &namelist, no_dots, alphasort); if (n < 0) { if (!rep || !*rep) { - ERR("scandir for %s: %s", dir, strerror(errno)); + NORM_ERR("scandir for %s: %s", dir, strerror(errno)); if (rep) { *rep = 1; } @@ -823,7 +864,7 @@ static int get_first_file_in_a_directory(const char *dir, char *s, int *rep) s[255] = '\0'; #ifdef HAVE_OPENMP -#pragma omp parallel for +#pragma omp parallel for schedule(dynamic,10) #endif /* HAVE_OPENMP */ for (i = 0; i < n; i++) { free(namelist[i]); @@ -834,14 +875,13 @@ static int get_first_file_in_a_directory(const char *dir, char *s, int *rep) } } -int open_sysfs_sensor(const char *dir, const char *dev, const char *type, int n, +static int open_sysfs_sensor(const char *dir, const char *dev, const char *type, int n, int *divisor, char *devtype) { char path[256]; char buf[256]; int fd; int divfd; - struct stat st; memset(buf, 0, sizeof(buf)); @@ -868,13 +908,6 @@ int open_sysfs_sensor(const char *dir, const char *dev, const char *type, int n, } } - /* At least the acpitz hwmon doesn't have a 'device' subdir, - * so check it's existence and strip it from buf otherwise. */ - snprintf(path, 255, "%s%s", dir, dev); - if (stat(path, &st)) { - buf[strlen(buf) - 7] = 0; - } - /* change vol to in, tempf to temp */ if (strcmp(type, "vol") == 0) { type = "in"; @@ -882,16 +915,25 @@ int open_sysfs_sensor(const char *dir, const char *dev, const char *type, int n, type = "temp"; } + /* construct path */ snprintf(path, 255, "%s%s/%s%d_input", dir, dev, type, n); - strncpy(devtype, path, 255); - /* open file */ + /* first, attempt to open file in /device */ fd = open(path, O_RDONLY); if (fd < 0) { - CRIT_ERR(NULL, NULL, "can't open '%s': %s\nplease check your device or remove this " - "var from "PACKAGE_NAME, path, strerror(errno)); + + /* if it fails, strip the /device from dev and attempt again */ + buf[strlen(buf) - 7] = 0; + snprintf(path, 255, "%s%s/%s%d_input", dir, dev, type, n); + fd = open(path, O_RDONLY); + if (fd < 0) { + CRIT_ERR(NULL, NULL, "can't open '%s': %s\nplease check your device or remove this " + "var from "PACKAGE_NAME, path, strerror(errno)); + } } + strncpy(devtype, path, 255); + if (strcmp(type, "in") == 0 || strcmp(type, "temp") == 0 || strcmp(type, "tempf") == 0) { *divisor = 1; @@ -920,19 +962,18 @@ int open_sysfs_sensor(const char *dir, const char *dev, const char *type, int n, /* should read until n == 0 but I doubt that kernel will give these * in multiple pieces. :) */ if (divn < 0) { - ERR("open_sysfs_sensor(): can't read from sysfs"); + NORM_ERR("open_sysfs_sensor(): can't read from sysfs"); } else { divbuf[divn] = '\0'; *divisor = atoi(divbuf); } + close(divfd); } - close(divfd); - return fd; } -double get_sysfs_info(int *fd, int divisor, char *devtype, char *type) +static double get_sysfs_info(int *fd, int divisor, char *devtype, char *type) { int val = 0; @@ -950,7 +991,7 @@ double get_sysfs_info(int *fd, int divisor, char *devtype, char *type) /* should read until n == 0 but I doubt that kernel will give these * in multiple pieces. :) */ if (n < 0) { - ERR("get_sysfs_info(): read from %s failed\n", devtype); + NORM_ERR("get_sysfs_info(): read from %s failed\n", devtype); } else { buf[n] = '\0'; val = atoi(buf); @@ -961,7 +1002,7 @@ double get_sysfs_info(int *fd, int divisor, char *devtype, char *type) /* open file */ *fd = open(devtype, O_RDONLY); if (*fd < 0) { - ERR("can't open '%s': %s", devtype, strerror(errno)); + NORM_ERR("can't open '%s': %s", devtype, strerror(errno)); } /* My dirty hack for computing CPU value @@ -991,59 +1032,81 @@ double get_sysfs_info(int *fd, int divisor, char *devtype, char *type) } } -/* Prior to kernel version 2.6.12, the CPU fan speed was available in - * ADT746X_FAN_OLD, whereas later kernel versions provide this information in - * ADT746X_FAN. */ -#define ADT746X_FAN "/sys/devices/temperatures/sensor1_fan_speed" -#define ADT746X_FAN_OLD "/sys/devices/temperatures/cpu_fan_speed" +#define HWMON_RESET() {\ + buf1[0] = 0; \ + factor = 1.0; \ + offset = 0.0; } -void get_adt746x_fan(char *p_client_buffer, size_t client_buffer_size) +static void parse_sysfs_sensor(struct text_object *obj, const char *arg, const char *path, const char *type) { - static int rep = 0; - char adt746x_fan_state[64]; - FILE *fp; - - if (!p_client_buffer || client_buffer_size <= 0) { + char buf1[64], buf2[64]; + float factor, offset; + int n, found = 0; + struct sysfs *sf; + + if (sscanf(arg, "%63s %d %f %f", buf2, &n, &factor, &offset) == 4) found = 1; else HWMON_RESET(); + if (!found && sscanf(arg, "%63s %63s %d %f %f", buf1, buf2, &n, &factor, &offset) == 5) found = 1; else if (!found) HWMON_RESET(); + if (!found && sscanf(arg, "%63s %63s %d", buf1, buf2, &n) == 3) found = 1; else if (!found) HWMON_RESET(); + if (!found && sscanf(arg, "%63s %d", buf2, &n) == 2) found = 1; else if (!found) HWMON_RESET(); + + if (!found) { + NORM_ERR("i2c failed to parse arguments"); + obj->type = OBJ_text; return; } + DBGP("parsed %s args: '%s' '%s' %d %f %f\n", type, buf1, buf2, n, factor, offset); + sf = malloc(sizeof(struct sysfs)); + memset(sf, 0, sizeof(struct sysfs)); + sf->fd = open_sysfs_sensor(path, (*buf1) ? buf1 : 0, buf2, n, + &sf->arg, sf->devtype); + strncpy(sf->type, buf2, 63); + sf->factor = factor; + sf->offset = offset; + obj->data.opaque = sf; +} - if ((fp = open_file(ADT746X_FAN, &rep)) == NULL - && (fp = open_file(ADT746X_FAN_OLD, &rep)) == NULL) { - sprintf(adt746x_fan_state, "adt746x not found"); - } else { - fgets(adt746x_fan_state, sizeof(adt746x_fan_state), fp); - adt746x_fan_state[strlen(adt746x_fan_state) - 1] = 0; - fclose(fp); - } - - snprintf(p_client_buffer, client_buffer_size, "%s", adt746x_fan_state); +#define PARSER_GENERATOR(name, path) \ +void parse_##name##_sensor(struct text_object *obj, const char *arg) \ +{ \ + parse_sysfs_sensor(obj, arg, path, #name); \ } -/* Prior to kernel version 2.6.12, the CPU temperature was found in - * ADT746X_CPU_OLD, whereas later kernel versions provide this information in - * ADT746X_CPU. */ -#define ADT746X_CPU "/sys/devices/temperatures/sensor1_temperature" -#define ADT746X_CPU_OLD "/sys/devices/temperatures/cpu_temperature" +PARSER_GENERATOR(i2c, "/sys/bus/i2c/devices/") +PARSER_GENERATOR(hwmon, "/sys/class/hwmon/") +PARSER_GENERATOR(platform, "/sys/bus/platform/devices/") -void get_adt746x_cpu(char *p_client_buffer, size_t client_buffer_size) +void print_sysfs_sensor(struct text_object *obj, char *p, int p_max_size) { - static int rep = 0; - char adt746x_cpu_state[64]; - FILE *fp; + double r; + struct sysfs *sf = obj->data.opaque; - if (!p_client_buffer || client_buffer_size <= 0) { + if (!sf) return; - } - if ((fp = open_file(ADT746X_CPU, &rep)) == NULL - && (fp = open_file(ADT746X_CPU_OLD, &rep)) == NULL) { - sprintf(adt746x_cpu_state, "adt746x not found"); + r = get_sysfs_info(&sf->fd, sf->arg, + sf->devtype, sf->type); + + r = r * sf->factor + sf->offset; + + if (!strncmp(sf->type, "temp", 4)) { + temp_print(p, p_max_size, r, TEMP_CELSIUS); + } else if (r >= 100.0 || r == 0) { + snprintf(p, p_max_size, "%d", (int) r); } else { - fscanf(fp, "%2s", adt746x_cpu_state); - fclose(fp); + snprintf(p, p_max_size, "%.1f", r); } +} + +void free_sysfs_sensor(struct text_object *obj) +{ + struct sysfs *sf = obj->data.opaque; + + if (!sf) + return; - snprintf(p_client_buffer, client_buffer_size, "%s", adt746x_cpu_state); + close(sf->fd); + free(obj->data.opaque); + obj->data.opaque = NULL; } #define CPUFREQ_PREFIX "/sys/devices/system/cpu" @@ -1148,7 +1211,7 @@ char get_freq(char *p_client_buffer, size_t client_buffer_size, * Peter Tarjan (ptarjan@citromail.hu) */ /* return cpu voltage in mV (use divisor=1) or V (use divisor=1000) */ -char get_voltage(char *p_client_buffer, size_t client_buffer_size, +static char get_voltage(char *p_client_buffer, size_t client_buffer_size, const char *p_format, int divisor, unsigned int cpu) { FILE *f; @@ -1217,6 +1280,22 @@ char get_voltage(char *p_client_buffer, size_t client_buffer_size, return 1; } +void print_voltage_mv(struct text_object *obj, char *p, int p_max_size) +{ + static int ok = 1; + if (ok) { + ok = get_voltage(p, p_max_size, "%.0f", 1, obj->data.i); + } +} + +void print_voltage_v(struct text_object *obj, char *p, int p_max_size) +{ + static int ok = 1; + if (ok) { + ok = get_voltage(p, p_max_size, "%'.3f", 1000, obj->data.i); + } +} + #define ACPI_FAN_DIR "/proc/acpi/fan/" void get_acpi_fan(char *p_client_buffer, size_t client_buffer_size) @@ -1251,7 +1330,7 @@ void get_acpi_fan(char *p_client_buffer, size_t client_buffer_size) snprintf(p_client_buffer, client_buffer_size, "%s", buf); } -#define SYSFS_AC_ADAPTER_DIR "/sys/class/power_supply/AC" +#define SYSFS_AC_ADAPTER_DIR "/sys/class/power_supply" #define ACPI_AC_ADAPTER_DIR "/proc/acpi/ac_adapter/" /* Linux 2.6.25 onwards ac adapter info is in /sys/class/power_supply/AC/ @@ -1263,22 +1342,33 @@ void get_acpi_fan(char *p_client_buffer, size_t client_buffer_size) POWER_SUPPLY_NAME=AC POWER_SUPPLY_TYPE=Mains POWER_SUPPLY_ONLINE=1 + + Update: it seems the folder name is hardware-dependent. We add an aditional adapter + argument, specifying the folder name. + + Update: on some systems it's /sys/class/power_supply/ADP1 instead of /sys/class/power_supply/AC */ -void get_acpi_ac_adapter(char *p_client_buffer, size_t client_buffer_size) +void get_acpi_ac_adapter(char *p_client_buffer, size_t client_buffer_size, const char *adapter) { static int rep = 0; char buf[256]; char buf2[256]; + struct stat sb; FILE *fp; if (!p_client_buffer || client_buffer_size <= 0) { return; } - snprintf(buf2, sizeof(buf2), "%s/uevent", SYSFS_AC_ADAPTER_DIR); - fp = open_file(buf2, &rep); + if(adapter) + snprintf(buf2, sizeof(buf2), "%s/%s/uevent", SYSFS_AC_ADAPTER_DIR, adapter); + else{ + snprintf(buf2, sizeof(buf2), "%s/AC/uevent", SYSFS_AC_ADAPTER_DIR); + if(stat(buf2, &sb) == -1) snprintf(buf2, sizeof(buf2), "%s/ADP1/uevent", SYSFS_AC_ADAPTER_DIR); + } + if(stat(buf2, &sb) == 0) fp = open_file(buf2, &rep); else fp = 0; if (fp) { /* sysfs processing */ while (!feof(fp)) { @@ -1353,7 +1443,7 @@ int open_acpi_temperature(const char *name) fd = open(path, O_RDONLY); if (fd < 0) { - ERR("can't open '%s': %s", path, strerror(errno)); + NORM_ERR("can't open '%s': %s", path, strerror(errno)); } return fd; @@ -1384,7 +1474,7 @@ double get_acpi_temperature(int fd) n = read(fd, buf, 255); if (n < 0) { - ERR("can't read fd %d: %s", fd, strerror(errno)); + NORM_ERR("can't read fd %d: %s", fd, strerror(errno)); } else { buf[n] = '\0'; sscanf(buf, "temperature: %lf", &last_acpi_temp); @@ -1459,10 +1549,24 @@ present voltage: 16608 mV On some systems POWER_SUPPLY_ENERGY_* is replaced by POWER_SUPPLY_CHARGE_* */ +/*on n900 with power kernel: (non power kernel could use "hal-device bme" and do something else) +/sys/class/power_supply/bq27200-0/uevent +PHYSDEVPATH=/class/i2c-adapter/i2c-2/2-0055 +PHYSDEVBUS=i2c +PHYSDEVDRIVER=bq27200-battery +POWER_SUPPLY_NAME=bq27200-0 +POWER_SUPPLY_TYPE=Battery +POWER_SUPPLY_PRESENT=1 << this is always 1, it means the battery is inserted +POWER_SUPPLY_VOLTAGE_NOW=4039 << this keeps updating during charging +POWER_SUPPLY_CURRENT_NOW=1960 << this goes negative when charging! +POWER_SUPPLY_CAPACITY=98 << supposed to be the %, I THOUGHT it stops updating when charging until it hits 100%, but maybe not? +POWER_SUPPLY_TEMP=39 << only temperature sensor in n900 :( +*/ + #define SYSFS_BATTERY_BASE_PATH "/sys/class/power_supply" -#define ACPI_BATTERY_BASE_PATH "/proc/acpi/battery" -#define APM_PATH "/proc/apm" -#define MAX_BATTERY_COUNT 4 +#define ACPI_BATTERY_BASE_PATH "/proc/acpi/battery" //not for n900 +#define APM_PATH "/proc/apm" //not for n900 +#define MAX_BATTERY_COUNT 4 //more like 1 static FILE *sysfs_bat_fp[MAX_BATTERY_COUNT] = { NULL, NULL, NULL, NULL }; static FILE *acpi_bat_fp[MAX_BATTERY_COUNT] = { NULL, NULL, NULL, NULL }; @@ -1474,6 +1578,12 @@ static char batteries[MAX_BATTERY_COUNT][32]; static int acpi_last_full[MAX_BATTERY_COUNT]; static int acpi_design_capacity[MAX_BATTERY_COUNT]; +//eg 4100 +static int last_battery_volts[MAX_BATTERY_COUNT]; + +//eg 35 +static int last_battery_temp[MAX_BATTERY_COUNT]; + /* e.g. "charging 75%" */ static char last_battery_str[MAX_BATTERY_COUNT][64]; /* e.g. "3h 15m" */ @@ -1492,7 +1602,7 @@ void init_batteries(void) return; } #ifdef HAVE_OPENMP -#pragma omp parallel for +#pragma omp parallel for schedule(dynamic,10) #endif /* HAVE_OPENMP */ for (idx = 0; idx < MAX_BATTERY_COUNT; idx++) { batteries[idx][0] = '\0'; @@ -1543,6 +1653,8 @@ void get_battery_stuff(char *buffer, unsigned int n, const char *bat, int item) memset(last_battery_str[idx], 0, sizeof(last_battery_str[idx])); memset(last_battery_time_str[idx], 0, sizeof(last_battery_time_str[idx])); + //memset(last_battery_volts[idx], 0, sizeof(last_battery_volts[idx])); + //memset(last_battery_temp[idx], 0, sizeof(last_battery_temp[idx])); /* first try SYSFS if that fails try ACPI */ @@ -1556,11 +1668,14 @@ void get_battery_stuff(char *buffer, unsigned int n, const char *bat, int item) if (sysfs_bat_fp[idx] != NULL) { /* SYSFS */ - int present_rate = -1; - int remaining_capacity = -1; - char charging_state[64]; + int present_rate = -9999; //we will put "current now" into this. negative when charging! + int remaining_capacity = -1; //in % + char charging_state[64];//can't get this without hal bme + int voltage = -1; + //int capacity = -1; + int temp = 9999; char present[4]; - + strcpy(present, "no"); strcpy(charging_state, "unknown"); while (!feof(sysfs_bat_fp[idx])) { @@ -1570,100 +1685,108 @@ void get_battery_stuff(char *buffer, unsigned int n, const char *bat, int item) /* let's just hope units are ok */ if (strncmp (buf, "POWER_SUPPLY_PRESENT=1", 22) == 0) - strcpy(present, "yes"); - else if (strncmp (buf, "POWER_SUPPLY_PRESENT=0", 22) == 0) - strcpy(present, "no"); - else if (strncmp (buf, "POWER_SUPPLY_STATUS=", 20) == 0) - sscanf(buf, "POWER_SUPPLY_STATUS=%63s", charging_state); - /* present_rate is not the same as the - current flowing now but it is the same value - which was used in the past. so we continue - the tradition! */ + strcpy(present, "yes");//n900 always yes + else if (strncmp(buf, "POWER_SUPPLY_VOLTAGE_NOW=", 25) == 0) + sscanf(buf, "POWER_SUPPLY_VOLTAGE_NOW=%d", &voltage); +// else if (strncmp (buf, "POWER_SUPPLY_STATUS=", 20) == 0) +// sscanf(buf, "POWER_SUPPLY_STATUS=%63s", charging_state); else if (strncmp(buf, "POWER_SUPPLY_CURRENT_NOW=", 25) == 0) sscanf(buf, "POWER_SUPPLY_CURRENT_NOW=%d", &present_rate); - else if (strncmp(buf, "POWER_SUPPLY_ENERGY_NOW=", 24) == 0) - sscanf(buf, "POWER_SUPPLY_ENERGY_NOW=%d", &remaining_capacity); - else if (strncmp(buf, "POWER_SUPPLY_ENERGY_FULL=", 25) == 0) - sscanf(buf, "POWER_SUPPLY_ENERGY_FULL=%d", &acpi_last_full[idx]); - else if (strncmp(buf, "POWER_SUPPLY_CHARGE_NOW=", 24) == 0) - sscanf(buf, "POWER_SUPPLY_CHARGE_NOW=%d", &remaining_capacity); - else if (strncmp(buf, "POWER_SUPPLY_CHARGE_FULL=", 25) == 0) - sscanf(buf, "POWER_SUPPLY_CHARGE_FULL=%d", &acpi_last_full[idx]); + else if (strncmp(buf, "POWER_SUPPLY_CAPACITY=", 22) == 0) + sscanf(buf, "POWER_SUPPLY_CAPACITY=%d", &remaining_capacity); + else if (strncmp(buf, "POWER_SUPPLY_TEMP=", 18) == 0) + sscanf(buf, "POWER_SUPPLY_TEMP=%d", &temp); +// else if (strncmp(buf, "POWER_SUPPLY_ENERGY_NOW=", 24) == 0) +// sscanf(buf, "POWER_SUPPLY_ENERGY_NOW=%d", &remaining_capacity); +// else if (strncmp(buf, "POWER_SUPPLY_ENERGY_FULL=", 25) == 0) +// sscanf(buf, "POWER_SUPPLY_ENERGY_FULL=%d", &acpi_last_full[idx]); +// else if (strncmp(buf, "POWER_SUPPLY_CHARGE_NOW=", 24) == 0) +// sscanf(buf, "POWER_SUPPLY_CHARGE_NOW=%d", &remaining_capacity); +// else if (strncmp(buf, "POWER_SUPPLY_CHARGE_FULL=", 25) == 0) +// sscanf(buf, "POWER_SUPPLY_CHARGE_FULL=%d", &acpi_last_full[idx]); } fclose(sysfs_bat_fp[idx]); sysfs_bat_fp[idx] = NULL; + + last_battery_volts[idx] = voltage; + last_battery_temp[idx] = temp; /* Hellf[i]re notes that remaining capacity can exceed acpi_last_full */ - if (remaining_capacity > acpi_last_full[idx]) - acpi_last_full[idx] = remaining_capacity; /* normalize to 100% */ + //lance notes, we don't care +// if (remaining_capacity > acpi_last_full[idx]) +// acpi_last_full[idx] = remaining_capacity; /* normalize to 100% */ /* not present */ - if (strcmp(present, "No") == 0) { - strncpy(last_battery_str[idx], "not present", 64); - } + //not possible +// if (strcmp(present, "no") == 0) { +// strncpy(last_battery_str[idx], "not present", 64); +// } /* charging */ - else if (strcmp(charging_state, "Charging") == 0) { - if (acpi_last_full[idx] != 0 && present_rate > 0) { + if (present_rate <= 0) {//if charging /* e.g. charging 75% */ - snprintf(last_battery_str[idx], sizeof(last_battery_str[idx])-1, "charging %i%%", - (int) (((float) remaining_capacity / acpi_last_full[idx]) * 100 )); + snprintf(last_battery_str[idx], sizeof(last_battery_str[idx])-1, "charging %i%%", remaining_capacity); + snprintf(last_battery_time_str[idx], sizeof(last_battery_time_str[idx]) - 1, "unknown"); /* e.g. 2h 37m */ - format_seconds(last_battery_time_str[idx], sizeof(last_battery_time_str[idx])-1, - (long) (((float)(acpi_last_full[idx] - remaining_capacity) / present_rate) * 3600)); - } else if (acpi_last_full[idx] != 0 && present_rate <= 0) { - snprintf(last_battery_str[idx], sizeof(last_battery_str[idx])-1, "charging %d%%", - (int) (((float)remaining_capacity / acpi_last_full[idx]) * 100)); - snprintf(last_battery_time_str[idx], - sizeof(last_battery_time_str[idx]) - 1, "unknown"); - } else { - strncpy(last_battery_str[idx], "charging", sizeof(last_battery_str[idx])-1); - snprintf(last_battery_time_str[idx], - sizeof(last_battery_time_str[idx]) - 1, "unknown"); - } - } +// format_seconds(last_battery_time_str[idx], sizeof(last_battery_time_str[idx])-1, +// (long) (((float)(acpi_last_full[idx] - remaining_capacity) / present_rate) * 3600)); + } + +// else if (acpi_last_full[idx] != 0 && present_rate <= 0) {//supposed to be guessing the time to fully charge, won't work though. +// snprintf(last_battery_str[idx], sizeof(last_battery_str[idx])-1, "charging %d%%", +// (int) (((float)remaining_capacity / acpi_last_full[idx]) * 100)); +// snprintf(last_battery_time_str[idx], +// sizeof(last_battery_time_str[idx]) - 1, "unknown"); +// } else { +// strncpy(last_battery_str[idx], "charging", sizeof(last_battery_str[idx])-1); +// snprintf(last_battery_time_str[idx], +// sizeof(last_battery_time_str[idx]) - 1, "unknown"); +// } +// } /* discharging */ - else if (strncmp(charging_state, "Discharging", 64) == 0) { - if (present_rate > 0) { + else if (present_rate > 0) { + /* e.g. discharging 35% */ - snprintf(last_battery_str[idx], sizeof(last_battery_str[idx])-1, "discharging %i%%", - (int) (((float) remaining_capacity / acpi_last_full[idx]) * 100 )); - /* e.g. 1h 12m */ - format_seconds(last_battery_time_str[idx], sizeof(last_battery_time_str[idx])-1, - (long) (((float) remaining_capacity / present_rate) * 3600)); - } else if (present_rate == 0) { /* Thanks to Nexox for this one */ - snprintf(last_battery_str[idx], sizeof(last_battery_str[idx])-1, "full"); - snprintf(last_battery_time_str[idx], - sizeof(last_battery_time_str[idx]) - 1, "unknown"); - } else { - snprintf(last_battery_str[idx], sizeof(last_battery_str[idx])-1, - "discharging %d%%", - (int) (((float)remaining_capacity / acpi_last_full[idx]) * 100)); - snprintf(last_battery_time_str[idx], + snprintf(last_battery_str[idx], sizeof(last_battery_str[idx])-1, "discharging %i%%", remaining_capacity); + + snprintf(last_battery_time_str[idx], sizeof(last_battery_time_str[idx]) - 1, "unknown"); - } + /* e.g. 1h 12m */ +// format_seconds(last_battery_time_str[idx], sizeof(last_battery_time_str[idx])-1, +// (long) (((float) remaining_capacity / present_rate) * 3600)); +// else { +// snprintf(last_battery_str[idx], sizeof(last_battery_str[idx])-1, +// "discharging %d%%", +// (int) (((float)remaining_capacity / acpi_last_full[idx]) * 100)); +// snprintf(last_battery_time_str[idx], +// sizeof(last_battery_time_str[idx]) - 1, "unknown"); +// } } /* charged */ /* thanks to Lukas Zapletal */ - else if (strncmp(charging_state, "Charged", 64) == 0 || strncmp(charging_state, "Full", 64) == 0) { - /* Below happens with the second battery on my X40, - * when the second one is empty and the first one - * being charged. */ - if (remaining_capacity == 0) - strcpy(last_battery_str[idx], "empty"); - else - strcpy(last_battery_str[idx], "charged"); - } + + if (remaining_capacity == 100) + strcpy(last_battery_str[idx], "charged"); + +// else if (strncmp(charging_state, "Charged", 64) == 0 || strncmp(charging_state, "Full", 64) == 0) { +// /* Below happens with the second battery on my X40, +// * when the second one is empty and the first one +// * being charged. */ +// if (remaining_capacity == 0) +// strcpy(last_battery_str[idx], "empty"); +// else +// strcpy(last_battery_str[idx], "charged"); +// } /* unknown, probably full / AC */ - else { - if (acpi_last_full[idx] != 0 - && remaining_capacity != acpi_last_full[idx]) - snprintf(last_battery_str[idx], 64, "unknown %d%%", - (int) (((float)remaining_capacity / acpi_last_full[idx]) * 100)); - else - strncpy(last_battery_str[idx], "AC", 64); - } - } else if (acpi_bat_fp[idx] != NULL) { +// else { +// if (acpi_last_full[idx] != 0 +// && remaining_capacity != acpi_last_full[idx]) +// snprintf(last_battery_str[idx], 64, "unknown %d%%", +// (int) (((float)remaining_capacity / acpi_last_full[idx]) * 100)); +// else +// strncpy(last_battery_str[idx], "AC", 64); +// } + } else if (acpi_bat_fp[idx] != NULL) {//skipped on n900 /* ACPI */ int present_rate = -1; int remaining_capacity = -1; @@ -1795,7 +1918,9 @@ void get_battery_stuff(char *buffer, unsigned int n, const char *bat, int item) strncpy(last_battery_str[idx], "AC", 64); } } - } else { + fclose(acpi_bat_fp[idx]); + acpi_bat_fp[idx] = NULL; + } else {//also skipped on n900 /* APM */ if (apm_bat_fp[idx] == NULL) { apm_bat_fp[idx] = open_file(APM_PATH, &rep2); @@ -1837,6 +1962,12 @@ void set_return_value(char *buffer, unsigned int n, int item, int idx) case BATTERY_TIME: snprintf(buffer, n, "%s", last_battery_time_str[idx]); break; + case BATTERY_VOLTS: + snprintf(buffer, n, "%i", last_battery_volts[idx]); // voltage + break; + case BATTERY_TEMP: + snprintf(buffer, n, "%i", last_battery_temp[idx]); // temperature + break; default: break; } @@ -1887,7 +2018,7 @@ int get_battery_perct(const char *bat) } last_battery_perct_time[idx] = current_update_time; - /* Only check for SYSFS or ACPI */ + /* Only check for SYSFS */ if (sysfs_bat_fp[idx] == NULL && acpi_bat_fp[idx] == NULL && apm_bat_fp[idx] == NULL) { sysfs_bat_fp[idx] = open_file(sysfs_path, &rep); @@ -1904,68 +2035,72 @@ int get_battery_perct(const char *bat) char buf[256]; if (fgets(buf, 256, sysfs_bat_fp[idx]) == NULL) break; - - if (strncmp(buf, "POWER_SUPPLY_CHARGE_NOW=", 24) == 0) { - sscanf(buf, "POWER_SUPPLY_CHARGE_NOW=%d", &remaining_capacity); - } else if (strncmp(buf, "POWER_SUPPLY_CHARGE_FULL=",25) == 0) { - sscanf(buf, "POWER_SUPPLY_CHARGE_FULL=%d", &acpi_design_capacity[idx]); - } else if (strncmp(buf, "POWER_SUPPLY_ENERGY_NOW=", 24) == 0) { - sscanf(buf, "POWER_SUPPLY_ENERGY_NOW=%d", &remaining_capacity); - } else if (strncmp(buf, "POWER_SUPPLY_ENERGY_FULL=",25) == 0) { - sscanf(buf, "POWER_SUPPLY_ENERGY_FULL=%d", &acpi_design_capacity[idx]); + if (strncmp(buf, "POWER_SUPPLY_CAPACITY=", 22) == 0) { + sscanf(buf, "POWER_SUPPLY_CAPACITY=%d", &remaining_capacity); + +// if (strncmp(buf, "POWER_SUPPLY_CHARGE_NOW=", 24) == 0) { +// sscanf(buf, "POWER_SUPPLY_CHARGE_NOW=%d", &remaining_capacity); +// } else if (strncmp(buf, "POWER_SUPPLY_CHARGE_FULL=",25) == 0) { +// sscanf(buf, "POWER_SUPPLY_CHARGE_FULL=%d", &acpi_design_capacity[idx]); +// } else if (strncmp(buf, "POWER_SUPPLY_ENERGY_NOW=", 24) == 0) { +// sscanf(buf, "POWER_SUPPLY_ENERGY_NOW=%d", &remaining_capacity); +// } else if (strncmp(buf, "POWER_SUPPLY_ENERGY_FULL=",25) == 0) { +// sscanf(buf, "POWER_SUPPLY_ENERGY_FULL=%d", &acpi_design_capacity[idx]); +// } } } - fclose(sysfs_bat_fp[idx]); sysfs_bat_fp[idx] = NULL; - } else if (acpi_bat_fp[idx] != NULL) { - /* ACPI */ - /* read last full capacity if it's zero */ - if (acpi_design_capacity[idx] == 0) { - static int rep2; - char path[128]; - FILE *fp; - - snprintf(path, 127, ACPI_BATTERY_BASE_PATH "/%s/info", bat); - fp = open_file(path, &rep2); - if (fp != NULL) { - while (!feof(fp)) { - char b[256]; - - if (fgets(b, 256, fp) == NULL) { - break; - } - if (sscanf(b, "last full capacity: %d", - &acpi_design_capacity[idx]) != 0) { - break; - } - } - fclose(fp); - } - } - - fseek(acpi_bat_fp[idx], 0, SEEK_SET); - - while (!feof(acpi_bat_fp[idx])) { - char buf[256]; - - if (fgets(buf, 256, acpi_bat_fp[idx]) == NULL) { - break; - } - - if (buf[0] == 'r') { - sscanf(buf, "remaining capacity: %d", &remaining_capacity); - } - } - } + } +// else if (acpi_bat_fp[idx] != NULL) { +// /* ACPI */ +// /* read last full capacity if it's zero */ +// if (acpi_design_capacity[idx] == 0) { +// static int rep2; +// char path[128]; +// FILE *fp; +// +// snprintf(path, 127, ACPI_BATTERY_BASE_PATH "/%s/info", bat); +// fp = open_file(path, &rep2); +// if (fp != NULL) { +// while (!feof(fp)) { +// char b[256]; +// +// if (fgets(b, 256, fp) == NULL) { +// break; +// } +// if (sscanf(b, "last full capacity: %d", +// &acpi_design_capacity[idx]) != 0) { +// break; +// } +// } +// fclose(fp); +// } +// } +// +// fseek(acpi_bat_fp[idx], 0, SEEK_SET); +// +// while (!feof(acpi_bat_fp[idx])) { +// char buf[256]; +// +// if (fgets(buf, 256, acpi_bat_fp[idx]) == NULL) { +// break; +// } +// +// if (buf[0] == 'r') { +// sscanf(buf, "remaining capacity: %d", &remaining_capacity); +// } +// } +// } if (remaining_capacity < 0) { return 0; } /* compute the battery percentage */ - last_battery_perct[idx] = - (int) (((float) remaining_capacity / acpi_design_capacity[idx]) * 100); - if (last_battery_perct[idx] > 100) last_battery_perct[idx] = 100; + last_battery_perct[idx] = + remaining_capacity; + //(int) (((float) remaining_capacity / acpi_design_capacity[idx]) * 100); + //if (last_battery_perct[idx] > 100) last_battery_perct[idx] = 100; return last_battery_perct[idx]; } @@ -2107,7 +2242,7 @@ void get_powerbook_batt_info(char *buffer, size_t n, int i) snprintf(buffer, n, "%s", pb_battery_info[i]); } -void update_top(void) +int update_top(void) { process_find_top(info.cpu, info.memu, info.time #ifdef IOSTATS @@ -2115,34 +2250,41 @@ void update_top(void) #endif ); info.first_process = get_first_process(); + return 0; } -void update_entropy(void) +#define ENTROPY_AVAIL_PATH "/proc/sys/kernel/random/entropy_avail" + +int get_entropy_avail(unsigned int *val) { static int rep = 0; - const char *entropy_avail = "/proc/sys/kernel/random/entropy_avail"; - const char *entropy_poolsize = "/proc/sys/kernel/random/poolsize"; - FILE *fp1, *fp2; + FILE *fp; - info.entropy.entropy_avail = 0; - info.entropy.poolsize = 0; + if (!(fp = open_file(ENTROPY_AVAIL_PATH, &rep))) + return 1; - if ((fp1 = open_file(entropy_avail, &rep)) == NULL) { - return; - } + if (fscanf(fp, "%u", val) != 1) + return 1; - if ((fp2 = open_file(entropy_poolsize, &rep)) == NULL) { - fclose(fp1); - return; - } + fclose(fp); + return 0; +} - fscanf(fp1, "%u", &info.entropy.entropy_avail); - fscanf(fp2, "%u", &info.entropy.poolsize); +#define ENTROPY_POOLSIZE_PATH "/proc/sys/kernel/random/poolsize" - fclose(fp1); - fclose(fp2); +int get_entropy_poolsize(unsigned int *val) +{ + static int rep = 0; + FILE *fp; - info.mask |= (1 << INFO_ENTROPY); + if (!(fp = open_file(ENTROPY_POOLSIZE_PATH, &rep))) + return 1; + + if (fscanf(fp, "%u", val) != 1) + return 1; + + fclose(fp); + return 0; } const char *get_disk_protect_queue(const char *disk) @@ -2165,7 +2307,50 @@ const char *get_disk_protect_queue(const char *disk) return (state > 0) ? "frozen" : "free "; } -void update_diskio(void) +typedef struct DEV_LIST_TYPE +{ + char *dev_name; + int memoized; + struct DEV_LIST_TYPE *next; + +} DEV_LIST, *DEV_LIST_PTR; + +/* Same as sf #2942117 but memoized using a linked list */ +int is_disk(char *dev) +{ + char syspath[PATH_MAX]; + char *slash; + static DEV_LIST_PTR dev_head = NULL; + DEV_LIST_PTR dev_cur, dev_last; + + dev_cur = dev_head; + + while (dev_cur) { + if (strcmp(dev_cur->dev_name, dev) == 0) + return dev_cur->memoized; + dev_last = dev_cur; + dev_cur = dev_cur->next; + } + + dev_cur = (DEV_LIST_PTR)malloc(sizeof(DEV_LIST)); + dev_cur->dev_name = (char *)malloc((strlen(dev)+1)*sizeof(char)); + strcpy(dev_cur->dev_name,dev); + dev_cur->next = NULL; + + while ((slash = strchr(dev, '/'))) + *slash = '!'; + snprintf(syspath, sizeof(syspath), "/sys/block/%s", dev); + dev_cur->memoized = !(access(syspath, F_OK)); + + if (dev_head) + dev_last->next = dev_cur; + else + dev_head = dev_cur; + + return dev_cur->memoized; +} + +int update_diskio(void) { FILE *fp; static int rep = 0; @@ -2181,7 +2366,7 @@ void update_diskio(void) stats.current_write = 0; if (!(fp = open_file("/proc/diskstats", &rep))) { - return; + return 0; } /* read reads and writes from all disks (minor = 0), including cd-roms @@ -2195,8 +2380,11 @@ void update_diskio(void) * XXX: ignore devices which are part of a SW RAID (MD_MAJOR) */ if (col_count == 5 && major != LVM_BLK_MAJOR && major != NBD_MAJOR && major != RAMDISK_MAJOR && major != LOOP_MAJOR) { - total_reads += reads; - total_writes += writes; + /* check needed for kernel >= 2.6.31, see sf #2942117 */ + if (is_disk(devbuf)) { + total_reads += reads; + total_writes += writes; + } } else { col_count = sscanf(buf, "%u %u %s %*u %u %*u %u", &major, &minor, devbuf, &reads, &writes); @@ -2213,4 +2401,5 @@ void update_diskio(void) } update_diskio_values(&stats, total_reads, total_writes); fclose(fp); + return 0; }