get_io.c

Go to the documentation of this file.

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <sys/ioctl.h>
#include <linux/fs.h>
#include <errno.h>
#include "assert.h"
#include "xio.h"

static time_t times[2];
static unsigned long long bytes[2];

int __GetIoPoint()
{
        FILE *F1 = NULL;
        char iface[1025] = { '\0' };
        char line[1025] = { '\0' };
        char *word = NULL;
        unsigned long long iface_bytes[2] = { 0 };
        unsigned long long iface_bytes_this = 0;
        unsigned long long iface_byte_total = 0;
        int skip = 0;
        int sector_size = 0;
        int sector_fd = 0;
        int using_diskstats = 1;
        char device_path[255] = { 0 };
        char error_str[1025] = { 0 };

        F1 = fopen("/proc/diskstats", "r");
        if (F1 == NULL) {
                using_diskstats = 0;
                F1 = fopen("/proc/partitions", "r");
                if (F1 == NULL) {
                        perror ("/proc/net/dev\n");
                        return(1);
                }
        }

        while (!feof(F1)) {
                fgets(line, 1024, F1);

                if (feof(F1))
                        break;

                word = strtok(line, " \t");
                word = strtok(NULL, " \t");
                if (!using_diskstats) {
                        word = strtok(NULL, " \t");
                }
                word = strtok(NULL, " \t");
                if (word == NULL)
                        continue;
                strcpy(iface, word);

                word = strtok(NULL, " \t");
                word = strtok(NULL, " \t");
                word = strtok(NULL, " \t");
                if (word != NULL) {
                        sscanf(word, "%llu", &iface_bytes[0]);
                }

                word = strtok(NULL, " \t");
                word = strtok(NULL, " \t");
                word = strtok(NULL, " \t");
                if (word != NULL) {
                        sscanf(word, "%llu", &iface_bytes[1]);
                }

                iface_bytes_this = 0;
                if (!xio_resources.interface) {
                        iface_bytes_this = iface_bytes[0] + iface_bytes[1];
                }
                else {
                        int found = 0;

                        word = strtok(xio_resources.interface, ", \t");
                        while (word != NULL) {
                                if (!strcasecmp(word,iface)) {
                                        iface_bytes_this = iface_bytes[0] + iface_bytes[1];
                                }
                                word = strtok(NULL, ", \t");
                        }
                }

                sector_size = 0;
                if (iface_bytes_this != 0) {
                        snprintf(device_path, 254, "/dev/%s", iface);
                        /* Using O_NONBLOCK|O_NDELAY means that xio doesn't cause the tray to
                         * close on CD/DVD drives
                         */
                        sector_fd = open(device_path, O_RDONLY|O_NONBLOCK|O_NDELAY);
                        if (sector_fd == -1) {
                                if 
                                        (errno != 123) /* Ignore "No medium found" for CD/DVD drives */
                                {
                                        snprintf(error_str, 1024,
                                                "error[%d]: open() on device %s", errno, device_path);
                                        perror(error_str);
                                }
                                continue;
                        }
                        if (ioctl(sector_fd, BLKSSZGET, &sector_size) == -1) {
                                snprintf(error_str, 1024,
                                        "error[%d]: ioctl on device %s", errno, device_path);
                                perror(error_str);
                                close(sector_fd);
                                continue;
                        }
                        close(sector_fd);
                }
                iface_bytes_this *= sector_size;

                iface_byte_total += iface_bytes_this;
        }
        fclose(F1);

        bytes[0] = bytes[1];
        bytes[1] = iface_byte_total;
        times[0] = times[1];
        times[1] = time(NULL);

        /* fprintf(stderr, "%llu %llu %llu %llu\n", bytes[0], bytes[1], times[0], times[1]); /**/

        return(0);
}

void InitIoPoint()
{
        times[0] = 0;
        times[1] = 0;
        bytes[0] = 0;
        bytes[1] = 0;
        __GetIoPoint();
        __GetIoPoint();
}

void GetIoPoint( w, closure, call_data )
     Widget     w;
     XtPointer  closure;
     XtPointer  call_data;
{
        unsigned long long ull_value = 0;
        unsigned long long ull_tdiff = 0;
        int i_value = 0.0;
        int i_tdiff = 0.0;

        ASSERT(w != NULL);
        ASSERT(call_data != NULL);

        __GetIoPoint();

        ASSERT(w != NULL);

        if (bytes[1] > bytes[0]) {
                ull_value = bytes[1] - bytes[0];
        }
        else {
                ull_value = bytes[0] - bytes[1];
        }
        /* fprintf(stderr, "%llu ", ull_value); /**/

        if (times[1] > times[0]) {
                ull_tdiff = times[1] - times[0];
        }
        else {
                ull_tdiff = times[0] - times[1];
        }
        /* fprintf(stderr, "%llu ", ull_tdiff); /**/
        if (ull_tdiff == 0) {
                *(int *)call_data = 0;
                ASSERT(w != NULL);
                return;
        }

        i_tdiff = (int)ull_tdiff;
        /* fprintf(stderr, "%d ", i_tdiff); /**/

        i_value = (int)ull_value;
        /* fprintf(stderr, "%d ", i_value); /**/

        i_value /= i_tdiff;
        /* fprintf(stderr, "%d ", i_value); /**/

        /* fprintf(stderr, "\n"); /**/

        *(int *)call_data = i_value;

        ASSERT(w != NULL);
}

---