diff options
Diffstat (limited to 'blkiomon.h')
| -rw-r--r-- | blkiomon.h | 105 |
1 files changed, 105 insertions, 0 deletions
diff --git a/blkiomon.h b/blkiomon.h new file mode 100644 index 0000000..2b1f7b2 --- /dev/null +++ b/blkiomon.h @@ -0,0 +1,105 @@ +/* + * I/O monitor based on block queue trace data + * + * Copyright IBM Corp. 2008 + * + * Author(s): Martin Peschke <mp3@de.ibm.com> + * + * 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 2 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, write to the Free Software + * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA + */ + +#ifndef BLKIOMON_H +#define BLKIOMON_H + +#include <string.h> + +#include "stats.h" +#include "blktrace.h" + +#define BLKIOMON_SIZE_BUCKETS 16 +#define BLKIOMON_D2C_BUCKETS 25 +struct blkiomon_stat { + __u64 time; + __u32 size_hist[BLKIOMON_SIZE_BUCKETS]; + __u32 d2c_hist[BLKIOMON_D2C_BUCKETS]; + struct minmax size_mm; + struct minmax d2c_mm; + __u64 read; + __u64 write; + __u64 bidir; + __u32 device; +}; + +static struct histlog2 size_hist = { + .first = 0, + .delta = 1024, + .num = BLKIOMON_SIZE_BUCKETS +}; + +static struct histlog2 d2c_hist = { + .first = 0, + .delta = 8, + .num = BLKIOMON_D2C_BUCKETS +}; + +static inline void blkiomon_stat_init(struct blkiomon_stat *bstat) +{ + memset(bstat, 0, sizeof(*bstat)); + minmax_init(&bstat->size_mm); + minmax_init(&bstat->d2c_mm); +} + +static inline void blkiomon_stat_to_be(struct blkiomon_stat *bstat) +{ + histlog2_to_be(bstat->size_hist, &size_hist); + histlog2_to_be(bstat->d2c_hist, &d2c_hist); + minmax_to_be(&bstat->size_mm); + minmax_to_be(&bstat->d2c_mm); + bstat->read = cpu_to_be64(bstat->read); + bstat->write = cpu_to_be64(bstat->write); + bstat->bidir = cpu_to_be64(bstat->bidir); + bstat->time = cpu_to_be64(bstat->time); + bstat->device = cpu_to_be32(bstat->device); +} + +static inline void blkiomon_stat_merge(struct blkiomon_stat *dst, + struct blkiomon_stat *src) +{ + histlog2_merge(&size_hist, dst->size_hist, src->size_hist); + histlog2_merge(&d2c_hist, dst->d2c_hist, src->d2c_hist); + minmax_merge(&dst->size_mm, &src->size_mm); + minmax_merge(&dst->d2c_mm, &src->d2c_mm); + dst->read += src->read; + dst->write += src->write; + dst->bidir += src->bidir; +} + +static inline void blkiomon_stat_print(FILE *fp, struct blkiomon_stat *p) +{ + if (!fp) + return; + + fprintf(fp, "\ntime: %s", ctime((void *)&p->time)); + fprintf(fp, "device: %d,%d\n", MAJOR(p->device), MINOR(p->device)); + fprintf(fp, "requests: read %ld, write %ld, bidir: %ld\n", + (unsigned long)p->read, (unsigned long)p->write, + (unsigned long)p->bidir); + minmax_print(fp, "sizes", &p->size_mm); + minmax_print(fp, "d2c", &p->d2c_mm); + histlog2_print(fp, "sizes histogram (in kB)", p->size_hist, &size_hist); + histlog2_print(fp, "d2c histogram (in usec)", p->d2c_hist, &d2c_hist); +} + +#endif |