Home | History | Annotate | Download | only in btt 
      1 /*
      2  * blktrace output analysis: generate a timeline & gather statistics
      3  *
      4  * (C) Copyright 2009 Hewlett-Packard Development Company, L.P.
      5  *	Alan D. Brunelle (alan.brunelle (at) hp.com)
      6  *
      7  *  This program is free software; you can redistribute it and/or modify
      8  *  it under the terms of the GNU General Public License as published by
      9  *  the Free Software Foundation; either version 2 of the License, or
     10  *  (at your option) any later version.
     11  *
     12  *  This program is distributed in the hope that it will be useful,
     13  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
     14  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     15  *  GNU General Public License for more details.
     16  *
     17  *  You should have received a copy of the GNU General Public License
     18  *  along with this program; if not, write to the Free Software
     19  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
     20  *
     21  */
     22 #include "globals.h"
     23 
     24 struct files {
     25 	FILE *fp;
     26 	char *nm;
     27 };
     28 
     29 struct rstat {
     30 	struct list_head head;
     31 	struct files files[2];
     32 	unsigned long long ios, nblks;
     33 	long long base_sec;
     34 };
     35 
     36 static struct rstat *sys_info;
     37 static LIST_HEAD(rstats);
     38 
     39 static int do_open(struct files *fip, char *bn, char *pn)
     40 {
     41 	fip->nm = malloc(strlen(bn) + 16);
     42 	sprintf(fip->nm, "%s_%s.dat", bn, pn);
     43 
     44 	fip->fp = my_fopen(fip->nm, "w");
     45 	if (fip->fp) {
     46 		add_file(fip->fp, fip->nm);
     47 		return 0;
     48 	}
     49 
     50 	free(fip->nm);
     51 	return -1;
     52 }
     53 
     54 static int init_rsip(struct rstat *rsip, struct d_info *dip)
     55 {
     56 	char *nm = dip ? dip->dip_name : "sys";
     57 
     58 	rsip->base_sec = -1;
     59 	rsip->ios = rsip->nblks = 0;
     60 	if (do_open(&rsip->files[0], nm, "iops_fp") ||
     61 			    do_open(&rsip->files[1], nm, "mbps_fp"))
     62 		return -1;
     63 
     64 	list_add_tail(&rsip->head, &rstats);
     65 	return 0;
     66 }
     67 
     68 static void rstat_emit(struct rstat *rsip, double cur)
     69 {
     70 	double mbps;
     71 
     72 	/*
     73 	 * I/Os per second is easy: just the ios
     74 	 */
     75 	fprintf(rsip->files[0].fp, "%lld %llu\n", rsip->base_sec, rsip->ios);
     76 
     77 	/*
     78 	 * MB/s we convert blocks to mb...
     79 	 */
     80 	mbps = ((double)rsip->nblks * 512.0) / (1024.0 * 1024.0);
     81 	fprintf(rsip->files[1].fp, "%lld %lf\n", rsip->base_sec, mbps);
     82 
     83 	rsip->base_sec = (unsigned long long)cur;
     84 	rsip->ios = rsip->nblks = 0;
     85 }
     86 
     87 static void __add(struct rstat *rsip, double cur, unsigned long long nblks)
     88 {
     89 	if (rsip->base_sec < 0)
     90 		rsip->base_sec = (long long)cur;
     91 	else if (((long long)cur - rsip->base_sec) >= 1)
     92 		rstat_emit(rsip, cur);
     93 
     94 	rsip->ios++;
     95 	rsip->nblks += nblks;
     96 }
     97 
     98 void *rstat_alloc(struct d_info *dip)
     99 {
    100 	struct rstat *rsip = malloc(sizeof(*rsip));
    101 
    102 	if (!init_rsip(rsip, dip))
    103 		return rsip;
    104 
    105 	free(rsip);
    106 	return NULL;
    107 }
    108 
    109 void rstat_free(void *ptr)
    110 {
    111 	struct rstat *rsip = ptr;
    112 
    113 	rstat_emit(rsip, last_t_seen);
    114 	list_del(&rsip->head);
    115 	free(rsip);
    116 }
    117 
    118 void rstat_add(void *ptr, double cur, unsigned long long nblks)
    119 {
    120 	if (ptr != NULL)
    121 		__add((struct rstat *)ptr, cur, nblks);
    122 	__add(sys_info, cur, nblks);
    123 }
    124 
    125 int rstat_init(void)
    126 {
    127 	sys_info = rstat_alloc(NULL);
    128 	return sys_info != NULL;
    129 }
    130 
    131 void rstat_exit(void)
    132 {
    133 	struct list_head *p, *q;
    134 
    135 	list_for_each_safe(p, q, &rstats) {
    136 		struct rstat *rsip = list_entry(p, struct rstat, head);
    137 		rstat_free(rsip);
    138 	}
    139 }
    140