iowatcher: Add possibility to limit seconds from below
[blktrace.git] / iowatcher / plot.c
index 7f30f77ec1f57d73f0584532b425252881006e22..c19da54c8977b30ff727b2c0060248e665757409 100644 (file)
@@ -69,7 +69,7 @@ static char line[1024];
 static int final_height = 0;
 static int final_width = 0;
 
-struct graph_line_data *alloc_line_data(int seconds, int stop_seconds)
+struct graph_line_data *alloc_line_data(int min_seconds, int max_seconds, int stop_seconds)
 {
        int size = sizeof(struct graph_line_data) + (stop_seconds + 1) * sizeof(struct graph_line_pair);
        struct graph_line_data *gld;
@@ -79,7 +79,8 @@ struct graph_line_data *alloc_line_data(int seconds, int stop_seconds)
                fprintf(stderr, "Unable to allocate memory for graph data\n");
                exit(1);
        }
-       gld->seconds = seconds;
+       gld->min_seconds = min_seconds;
+       gld->max_seconds = max_seconds;
        gld->stop_seconds = stop_seconds;
        return gld;
 }
@@ -90,7 +91,7 @@ void free_line_data(struct graph_line_data *gld)
        free(gld);
 }
 
-struct graph_dot_data *alloc_dot_data(int seconds, u64 max_offset, int stop_seconds)
+struct graph_dot_data *alloc_dot_data(int min_seconds, int max_seconds, u64 min_offset, u64 max_offset, int stop_seconds)
 {
        int size;
        int arr_size;
@@ -111,10 +112,12 @@ struct graph_dot_data *alloc_dot_data(int seconds, u64 max_offset, int stop_seco
                fprintf(stderr, "Unable to allocate memory for graph data\n");
                exit(1);
        }
-       gdd->seconds = seconds;
+       gdd->min_seconds = min_seconds;
+       gdd->max_seconds = max_seconds;
        gdd->stop_seconds = stop_seconds;
        gdd->rows = rows;
        gdd->cols = cols;
+       gdd->min_offset = min_offset;
        gdd->max_offset = max_offset;
        return gdd;
 }
@@ -126,9 +129,8 @@ void free_dot_data(struct graph_dot_data *gdd)
 
 void set_gdd_bit(struct graph_dot_data *gdd, u64 offset, double bytes, double time)
 {
-       double bytes_per_row = (double)gdd->max_offset / gdd->rows;
-
-       double secs_per_col = (double)gdd->seconds / gdd->cols;
+       double bytes_per_row = (double)(gdd->max_offset - gdd->min_offset + 1) / gdd->rows;
+       double secs_per_col = (double)(gdd->max_seconds - gdd->min_seconds) / gdd->cols;
        double col;
        double row;
        int col_int;
@@ -138,14 +140,14 @@ void set_gdd_bit(struct graph_dot_data *gdd, u64 offset, double bytes, double ti
        int bit_mod;
        double mod = bytes_per_row;
 
-       if (offset > gdd->max_offset)
+       if (offset > gdd->max_offset || offset < gdd->min_offset)
                return;
 
        gdd->total_ios++;
        time = time / 1000000000.0;
        while (bytes > 0) {
-               row = (double)offset / bytes_per_row;
-               col = time / secs_per_col;
+               row = (double)(offset - gdd->min_offset) / bytes_per_row;
+               col = (time - gdd->min_seconds) / secs_per_col;
 
                col_int = floor(col);
                row_int = floor(row);
@@ -241,6 +243,8 @@ void write_svg_header(int fd)
        write(fd, header, strlen(header));
        /* write a bunch of spaces so we can stuff in the width and height later */
        write(fd, spaces, strlen(spaces));
+       write(fd, spaces, strlen(spaces));
+       write(fd, spaces, strlen(spaces));
 
        write(fd, defs_start, strlen(defs_start));
        write(fd, filter1, strlen(filter1));
@@ -310,7 +314,6 @@ static int axis_x_off(int x)
        return (int)axis_x_off_double(x);
 }
 
-
 /*
  * this draws a backing rectangle for the plot and it
  * also creates a new svg element so our offsets can
@@ -322,33 +325,40 @@ void setup_axis(struct plot *plot)
        int len;
        int fd = plot->fd;
        int bump_height = tick_font_size * 3 + axis_label_font_size;
+       int local_legend_width = legend_width;
 
-       plot->total_width = axis_x_off(graph_width) + graph_left_pad / 2 + legend_width;
+       if (plot->no_legend)
+               local_legend_width = 0;
+
+       plot->total_width = axis_x_off(graph_width) + graph_left_pad / 2 + local_legend_width;
        plot->total_height = axis_y() + tick_label_pad + tick_font_size;
 
        if (plot->add_xlabel)
                plot->total_height += bump_height;
 
        /* backing rect */
-       snprintf(line, line_len, "<rect x=\"0\" y=\"%d\" width=\"%d\" "
+       snprintf(line, line_len, "<rect x=\"%d\" y=\"%d\" width=\"%d\" "
                 "height=\"%d\" fill=\"white\" stroke=\"none\"/>",
+                plot->start_x_offset,
                plot->start_y_offset, plot->total_width + 40,
                plot->total_height + 20);
        len = strlen(line);
        write(fd, line, len);
 
-       snprintf(line, line_len, "<rect x=\"15\" y=\"%d\" width=\"%d\" "
+       snprintf(line, line_len, "<rect x=\"%d\" y=\"%d\" width=\"%d\" "
                 "filter=\"url(#shadow)\" "
                 "height=\"%d\" fill=\"white\" stroke=\"none\"/>",
+                plot->start_x_offset + 15,
                plot->start_y_offset, plot->total_width, plot->total_height);
        len = strlen(line);
        write(fd, line, len);
        plot->total_height += 20;
+       plot->total_width += 20;
 
        if (plot->total_height + plot->start_y_offset > final_height)
                final_height = plot->total_height + plot->start_y_offset;
-       if (plot->total_width + 40 > final_width)
-               final_width = plot->total_width + 40;
+       if (plot->start_x_offset + plot->total_width + 40 > final_width)
+               final_width = plot->start_x_offset + plot->total_width + 40;
 
        /* create an svg object for all our coords to be relative against */
        snprintf(line, line_len, "<svg x=\"%d\" y=\"%d\">\n", plot->start_x_offset, plot->start_y_offset);
@@ -377,32 +387,37 @@ void setup_axis_spindle(struct plot *plot)
        int fd = plot->fd;
        int bump_height = tick_font_size * 3 + axis_label_font_size;
 
-       plot->total_width = axis_x_off(graph_width) + graph_left_pad / 2 + legend_width;
+       legend_x_off = -60;
+
+       plot->total_width = axis_x_off(graph_width) + legend_width;
        plot->total_height = axis_y() + tick_label_pad + tick_font_size;
 
        if (plot->add_xlabel)
                plot->total_height += bump_height;
 
        /* backing rect */
-       snprintf(line, line_len, "<rect x=\"0\" y=\"%d\" width=\"%d\" "
+       snprintf(line, line_len, "<rect x=\"%d\" y=\"%d\" width=\"%d\" "
                 "height=\"%d\" fill=\"white\" stroke=\"none\"/>",
-               plot->start_y_offset, plot->total_width + 40,
+                plot->start_x_offset,
+               plot->start_y_offset, plot->total_width + 10,
                plot->total_height + 20);
        len = strlen(line);
        write(fd, line, len);
 
-       snprintf(line, line_len, "<rect x=\"15\" y=\"%d\" width=\"%d\" "
+       snprintf(line, line_len, "<rect x=\"%d\" y=\"%d\" width=\"%d\" "
                 "filter=\"url(#shadow)\" "
                 "height=\"%d\" fill=\"white\" stroke=\"none\"/>",
-               plot->start_y_offset, plot->total_width, plot->total_height);
+                plot->start_x_offset + 15,
+               plot->start_y_offset, plot->total_width - 30,
+               plot->total_height);
        len = strlen(line);
        write(fd, line, len);
        plot->total_height += 20;
 
        if (plot->total_height + plot->start_y_offset > final_height)
                final_height = plot->total_height + plot->start_y_offset;
-       if (plot->total_width + 40 > final_width)
-               final_width = plot->total_width + 40;
+       if (plot->start_x_offset + plot->total_width + 40 > final_width)
+               final_width = plot->start_x_offset + plot->total_width + 40;
 
        /* create an svg object for all our coords to be relative against */
        snprintf(line, line_len, "<svg x=\"%d\" y=\"%d\">\n", plot->start_x_offset, plot->start_y_offset);
@@ -472,7 +487,8 @@ void set_xticks(struct plot *plot, int num_ticks, int first, int last)
                if (!tick_only) {
                        snprintf(line, line_len, "<text x=\"%d\" y=\"%d\" font-family=\"%s\" font-size=\"%d\" "
                                "fill=\"black\" style=\"text-anchor: %s\">%d</text>\n",
-                               tick_x, text_y, font_family, tick_font_size, anchor, step * i);
+                               tick_x, text_y, font_family, tick_font_size, anchor,
+                               first + step * i);
                        write(plot->fd, line, strlen(line));
                }
                tick_x += pixels_per_tick;
@@ -548,7 +564,7 @@ void set_yticks(struct plot *plot, int num_ticks, int first, int last, char *uni
                         "fill=\"black\" style=\"text-anchor: %s\">%d%s</text>\n",
                        text_x,
                        axis_y_off(tick_y - tick_font_size / 2),
-                       font_family, tick_font_size, anchor, step * i, units);
+                       font_family, tick_font_size, anchor, first + step * i, units);
                write(plot->fd, line, strlen(line));
                tick_y += pixels_per_tick;
        }
@@ -582,8 +598,10 @@ static void close_svg(int fd)
 int close_plot(struct plot *plot)
 {
        close_svg(plot->fd);
-       plot->start_y_offset += plot->total_height;
-       plot->add_xlabel = 0;
+       if (plot->direction == PLOT_DOWN)
+               plot->start_y_offset += plot->total_height;
+       else if (plot->direction == PLOT_ACROSS)
+               plot->start_x_offset += plot->total_width;
        return 0;
 }
 
@@ -613,6 +631,9 @@ int close_plot_file(struct plot *plot)
                 "width=\"%d\" height=\"%d\">\n",
                 final_width, final_height);
        write(plot->fd, line, strlen(line));
+       snprintf(line, line_len, "<rect x=\"0\" y=\"0\" width=\"%d\" "
+                "height=\"%d\" fill=\"white\"/>\n", final_width, final_height);
+       write(plot->fd, line, strlen(line));
        close(plot->fd);
        plot->fd = 0;
        return 0;
@@ -679,35 +700,81 @@ void scale_line_graph_time(u64 *max, char **units)
        *max /= div;
 }
 
-int svg_line_graph(struct plot *plot, struct graph_line_data *gld, char *color)
+int svg_line_graph(struct plot *plot, struct graph_line_data *gld, char *color, int thresh1, int thresh2)
 {
        int i;
        double val;
+       double avg;
        int rolling;
        int fd = plot->fd;
        char *start = "<path d=\"";
        double yscale = ((double)gld->max) / graph_height;
-       double xscale = (double)(gld->seconds - 1) / graph_width;
+       double xscale = (double)(gld->max_seconds - gld->min_seconds - 1) / graph_width;
        char c = 'M';
        double x;
+       int printed_header = 0;
+       int printed_lines = 0;
 
-       if (rolling_avg_secs)
+       if (thresh1 && thresh2)
+               rolling = 0;
+       else if (rolling_avg_secs)
                rolling = rolling_avg_secs;
        else
-               rolling = gld->stop_seconds / 25;
+               rolling = (gld->stop_seconds - gld->min_seconds) / 25;
 
-       write(fd, start, strlen(start));
-       for (i = 0; i < gld->stop_seconds; i++) {
-               val = rolling_avg(gld->data, i, rolling);
-               val = val / yscale;
-               x = (double)i / xscale;
-               snprintf(line, line_len, "%c %d %d ", c, axis_x_off(x), axis_y_off(val));
+       for (i = gld->min_seconds; i < gld->stop_seconds; i++) {
+               avg = rolling_avg(gld->data, i, rolling);
+               if (yscale == 0)
+                       val = 0;
+               else
+                       val = avg / yscale;
+
+               if (val > graph_height)
+                       val = graph_height;
+               if (val < 0)
+                       val = 0;
+
+               x = (double)(i - gld->min_seconds) / xscale;
+               if (!thresh1 && !thresh2) {
+
+                       if (!printed_header) {
+                               write(fd, start, strlen(start));
+                               printed_header = 1;
+                       }
+
+                       /* in full line mode, everything in the graph is connected */
+                       snprintf(line, line_len, "%c %d %d ", c, axis_x_off(x), axis_y_off(val));
+                       c = 'L';
+                       write(fd, line, strlen(line));
+                       printed_lines = 1;
+               } else if (avg > thresh1 || avg > thresh2) {
+                       int len = 10;
+                       if (!printed_header) {
+                               write(fd, start, strlen(start));
+                               printed_header = 1;
+                       }
+
+                       /* otherwise, we just print a bar up there to show this one data point */
+                       if (i >= gld->stop_seconds - 2)
+                               len = -10;
+
+                       /*
+                        * we don't use the rolling averages here to show high
+                        * points in the data
+                        */
+                       snprintf(line, line_len, "M %d %d h %d ", axis_x_off(x),
+                                axis_y_off(val), len);
+                       write(fd, line, strlen(line));
+                       printed_lines = 1;
+               }
 
-               c = 'L';
+       }
+       if (printed_lines) {
+               snprintf(line, line_len, "\" fill=\"none\" stroke=\"%s\" stroke-width=\"2\"/>\n", color);
                write(fd, line, strlen(line));
        }
-       snprintf(line, line_len, "\" fill=\"none\" stroke=\"%s\" stroke-width=\"2\"/>\n", color);
-       write(fd, line, strlen(line));
+       if (plot->timeline)
+               svg_write_time_line(plot, plot->timeline);
 
        return 0;
 }
@@ -840,13 +907,13 @@ int svg_io_graph_movie(struct graph_dot_data *gdd, struct plot_history *ph, int
        unsigned char val;
        int bit_index;
        int bit_mod;
-       double blocks_per_row = gdd->max_offset / gdd->rows;
-       double movie_blocks_per_cell = gdd->max_offset / (graph_width * graph_height);
+       double blocks_per_row = (gdd->max_offset - gdd->min_offset + 1) / gdd->rows;
+       double movie_blocks_per_cell = (gdd->max_offset - gdd->min_offset + 1) / (graph_width * graph_height);
        double cell_index;
        int margin_orig = graph_inner_y_margin;
 
        graph_inner_y_margin += 5;
-       ph->history_max = gdd->max_offset / movie_blocks_per_cell;
+       ph->history_max = (gdd->max_offset - gdd->min_offset + 1) / movie_blocks_per_cell;
 
        for (row = gdd->rows - 1; row >= 0; row--) {
                bit_index = row * gdd->cols + col;