source: branches/0.4/web/addons/job_monarch/graph.php @ 797

Last change on this file since 797 was 797, checked in by ramonb, 11 years ago
  • give single metric graphs: Now/Min/Avg/Max? values for current and archive RRDS
  • Property svn:keywords set to Id
File size: 19.2 KB
Line 
1<?php
2/*
3 *
4 * This file is part of Jobmonarch
5 *
6 * Copyright (C) 2006  Ramon Bastiaans
7 *
8 * Jobmonarch is free software; you can redistribute it and/or modify
9 * it under the terms of the GNU General Public License as published by
10 * the Free Software Foundation; either version 2 of the License, or
11 * (at your option) any later version.
12 *
13 * Jobmonarch is distributed in the hope that it will be useful,
14 * but WITHOUT ANY WARRANTY; without even the implied warranty of
15 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16 * GNU General Public License for more details.
17 *
18 * You should have received a copy of the GNU General Public License
19 * along with this program; if not, write to the Free Software
20 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA
21 *
22 * SVN $Id: graph.php 797 2013-04-06 15:25:58Z ramonb $
23 */
24
25global $rrds, $start, $r, $conf, $m;
26
27include "./libtoga.php";
28
29# Graph specific variables
30$size = escapeshellcmd( rawurldecode( $_GET["z"] ));
31$graph = escapeshellcmd( rawurldecode( $_GET["g"] ));
32$grid = escapeshellcmd( rawurldecode( $_GET["G"] ));
33$self = escapeshellcmd( rawurldecode( $_GET["me"] ));
34$max = escapeshellcmd( rawurldecode( $_GET["x"] ));
35$min = escapeshellcmd( rawurldecode( $_GET["n"] ));
36$value = escapeshellcmd( rawurldecode( $_GET["v"] ));
37$load_color = escapeshellcmd( rawurldecode( $_GET["l"] ));
38$vlabel = escapeshellcmd( rawurldecode( $_GET["vl"] ));
39$j_title = escapeshellcmd( rawurldecode( $_GET["t"] ));
40$hostname = escapeshellcmd( rawurldecode( $_GET["h"] ));
41$range = escapeshellcmd( rawurldecode( $_GET["r"] ));
42
43if( strpos( $size, 'overview' ) )
44{
45    $my_dir = getcwd();
46
47    global $context;
48
49    $context = 'host';
50
51    chdir( $GANGLIA_PATH );
52
53    include "./ganglia.php";
54    include "./get_ganglia.php";
55
56    chdir( $my_dir );
57}
58
59if ( !empty( $_GET ) ) 
60{
61        extract( $_GET );
62}
63
64$sourcetime = $st;
65
66
67$cluster = $c;
68$metricname = ($g) ? $g : $m;
69
70# Assumes we have a $start variable (set in get_context.php).
71if ($size == "small") 
72{
73    $height = 40;
74    $width = 130;
75} 
76else if ($size == "medium") 
77{
78    $height = 75;
79    $width = 300;
80} 
81else if ($size == "overview-medium") 
82{
83    $height = 75;
84    $width = 300;
85} 
86else 
87{
88    $height = 100;
89    $width = 400;
90}
91
92// RB: Perform some formatting/spacing magic.. tinkered to fit
93//
94if ($size == 'small') {
95   $eol1 = '\\l';
96   $space1 = ' ';
97   $space2 = '         ';
98} else if ($size == 'medium') {
99   $eol1 = '';
100   $space1 = ' ';
101   $space2 = '';
102   $extras = ' --font LEGEND:7 ';
103} else if ($size == 'overview-medium') {
104   $eol1   = '';
105   $space1 = '';
106   $space2 = '';
107   $extras = ' --font LEGEND:7 ';
108} else if ($size == 'large') {
109   $eol1 = '';
110   $space1 = '       ';
111   $space2 = '       ';
112} else if ($size == 'xlarge') {
113   $eol1 = '';
114   $space1 = '             ';
115   $space2 = '             ';
116} else if ($size == 'mobile') {
117   $eol1 = '';
118   $space1 = ' ';
119   $space2 = '';
120}
121
122$jobstart_color = "3AE302";
123$jobstop_color = "F5164A";
124
125if($command) 
126{
127      $command = '';
128}
129
130$graph = $metricname;
131
132$rrd_dirs = Array();
133
134if (isset($graph)) 
135{
136    $series = '';
137    if( $size == 'overview-medium' )
138    {
139        $rrd_dirs[] = $conf['rrds'] . '/' . $cluster .'/'. $hostname;
140    }
141    else
142    {
143        $trd = new TarchRrdGraph( $cluster, $hostname );
144        $rrd_dirs = $trd->getRrdDirs( $period_start, $period_stop );
145
146    }
147
148    if($graph == "cpu_report") 
149    {
150
151        $style = "CPU";
152
153        $upper_limit = "--upper-limit 100 --rigid";
154        $lower_limit = "--lower-limit 0";
155
156        $vertical_label = "--vertical-label Percent ";
157
158        $def_nr = 0;
159
160        foreach( $rrd_dirs as $rrd_dir ) 
161        {
162
163            if( $def_nr == 0 ) 
164            {
165
166                $user_str = ":'User CPU'";
167                $nice_str = ":'Nice CPU'";
168                $system_str = ":'System CPU'";
169                $wio_str = ":'WAIT CPU'";
170                $idle_str = ":'Idle CPU'";
171            } 
172            else 
173            {
174
175                $user_str = "";
176                $nice_str = "";
177                $system_str = "";
178                $wio_str = "";
179                $idle_str = "";
180            }
181
182            $series .= "DEF:'cpu_user${def_nr}'='${rrd_dir}/cpu_user.rrd':'sum':AVERAGE "
183                ."DEF:'cpu_nice${def_nr}'='${rrd_dir}/cpu_nice.rrd':'sum':AVERAGE "
184                ."DEF:'cpu_system${def_nr}'='${rrd_dir}/cpu_system.rrd':'sum':AVERAGE "
185                ."DEF:'cpu_idle${def_nr}'='${rrd_dir}/cpu_idle.rrd':'sum':AVERAGE "
186                ."AREA:'cpu_user${def_nr}'#".$conf['cpu_user_color']."${user_str} "
187                ."STACK:'cpu_nice${def_nr}'#".$conf['cpu_nice_color']."${nice_str} "
188                ."STACK:'cpu_system${def_nr}'#".$conf['cpu_system_color']."${system_str} ";
189
190            if (file_exists("$rrd_dir/cpu_wio.rrd")) 
191            {
192                $series .= "DEF:'cpu_wio${def_nr}'='${rrd_dir}/cpu_wio.rrd':'sum':AVERAGE "
193                    ."STACK:'cpu_wio${def_nr}'#".$conf['cpu_wio_color']."${wio_str} ";
194            }
195
196            $series .= "STACK:'cpu_idle${def_nr}'#".$conf['cpu_idle_color']."${idle_str} ";
197
198            $def_nr++;
199        }
200
201    } 
202    else if ($graph == "job_report") 
203    {
204        $style = "Jobs";
205
206        $lower_limit = "--lower-limit 0 --rigid";
207        $vertical_label = "--vertical-label Jobs";
208
209        $def_nr = 0;
210
211        $rrd_dir = $conf['rrds'] . "/$clustername/$hostname/";
212
213        $rj_rrd    = $rrd_dir . "zplugin_monarch_rj.rrd";
214        $qj_rrd    = $rrd_dir . "zplugin_monarch_qj.rrd";
215
216        $sorted_hosts    = array();
217        $sorted_hosts[]  = $rjqj_host;
218
219        $rj_str = ":'Running Jobs'";
220        $qj_str = ":'Queued Jobs'";
221
222        $series .= "DEF:'running_jobs'='${rj_rrd}':'sum':AVERAGE "
223            ."DEF:'queued_jobs'='${qj_rrd}':'sum':AVERAGE ";
224
225       
226        $series .= "LINE3:'running_jobs'#ff0000${rj_str} ";
227
228        if ( $conf['graphreport_stats'] ) 
229        {
230            $series .= "CDEF:running_pos=running_jobs,0,INF,LIMIT "
231                    . "VDEF:running_last=running_pos,LAST "
232                    . "VDEF:running_min=running_pos,MINIMUM "
233                    . "VDEF:running_avg=running_pos,AVERAGE "
234                    . "VDEF:running_max=running_pos,MAXIMUM "
235                    . "GPRINT:'running_last':' ${space1}Now\:%5.0lf' "
236                    . "GPRINT:'running_min':'${space1}Min\:%5.0lf${eol1}' "
237                    . "GPRINT:'running_avg':'${space2}Avg\:%5.0lf' "
238                    . "GPRINT:'running_max':'${space1}Max\:%5.0lf\\l' ";
239        }
240
241        $series .= "LINE3:'queued_jobs'#999999${qj_str} ";
242
243        if ( $conf['graphreport_stats'] ) 
244        {
245            $series .= "CDEF:queued_pos=queued_jobs,0,INF,LIMIT "
246                    . "VDEF:queued_last=queued_pos,LAST "
247                    . "VDEF:queued_min=queued_pos,MINIMUM "
248                    . "VDEF:queued_avg=queued_pos,AVERAGE "
249                    . "VDEF:queued_max=queued_pos,MAXIMUM "
250                    . "GPRINT:'queued_last':'  ${space1}Now\:%5.0lf' "
251                    . "GPRINT:'queued_min':'${space1}Min\:%5.0lf${eol1}' "
252                    . "GPRINT:'queued_avg':'${space2}Avg\:%5.0lf' "
253                    . "GPRINT:'queued_max':'${space1}Max\:%5.0lf\\l' ";
254        }
255    } 
256    else if ($graph == "mem_report") 
257    {
258        $style = "Memory";
259
260        $lower_limit = "--lower-limit 0 --rigid";
261        $extras .= "--base 1024";
262        $vertical_label = "--vertical-label Bytes";
263
264        $def_nr = 0;
265
266        foreach( $rrd_dirs as $rrd_dir ) 
267        {
268
269            if( $def_nr == 0 ) 
270            {
271
272                $memuse_str = ":'Memory Used'";
273                $memshared_str = ":'Memory Shared'";
274                $memcached_str = ":'Memory Cached'";
275                $membuff_str = ":'Memory Buffered'";
276                $memswap_str = ":'Memory Swapped'";
277                $total_str = ":'Total In-Core Memory'";
278            } 
279            else 
280            {
281
282                $memuse_str = "";
283                $memshared_str = "";
284                $memcached_str = "";
285                $membuff_str = "";
286                $memswap_str = "";
287                $total_str = "";
288            }
289
290            $series .= "DEF:'mem_total${def_nr}'='${rrd_dir}/mem_total.rrd':'sum':AVERAGE "
291                ."CDEF:'bmem_total${def_nr}'=mem_total${def_nr},1024,* "
292                ."DEF:'mem_shared${def_nr}'='${rrd_dir}/mem_shared.rrd':'sum':AVERAGE "
293                ."CDEF:'bmem_shared${def_nr}'=mem_shared${def_nr},1024,* "
294                ."DEF:'mem_free${def_nr}'='${rrd_dir}/mem_free.rrd':'sum':AVERAGE "
295                ."CDEF:'bmem_free${def_nr}'=mem_free${def_nr},1024,* "
296                ."DEF:'mem_cached${def_nr}'='${rrd_dir}/mem_cached.rrd':'sum':AVERAGE "
297                ."CDEF:'bmem_cached${def_nr}'=mem_cached${def_nr},1024,* "
298                ."DEF:'mem_buffers${def_nr}'='${rrd_dir}/mem_buffers.rrd':'sum':AVERAGE "
299                ."CDEF:'bmem_buffers${def_nr}'=mem_buffers${def_nr},1024,* "
300                ."CDEF:'bmem_used${def_nr}'='bmem_total${def_nr}','bmem_shared${def_nr}',-,'bmem_free${def_nr}',-,'bmem_cached${def_nr}',-,'bmem_buffers${def_nr}',- "
301                ."AREA:'bmem_used${def_nr}'#".$conf['mem_used_color']."${memuse_str} "
302                ."STACK:'bmem_shared${def_nr}'#".$conf['mem_shared_color']."${memshared_str} "
303                ."STACK:'bmem_cached${def_nr}'#".$conf['mem_cached_color']."${memcached_str} "
304                ."STACK:'bmem_buffers${def_nr}'#".$conf['mem_buffered_color']."${membuff_str} ";
305
306            if (file_exists("$rrd_dir/swap_total.rrd")) 
307            {
308                $series .= "DEF:'swap_total${def_nr}'='${rrd_dir}/swap_total.rrd':'sum':AVERAGE "
309                    ."DEF:'swap_free${def_nr}'='${rrd_dir}/swap_free.rrd':'sum':AVERAGE "
310                    ."CDEF:'bmem_swapped${def_nr}'='swap_total${def_nr}','swap_free${def_nr}',-,1024,* "
311                    ."STACK:'bmem_swapped${def_nr}'#".$conf['mem_swapped_color']."${memswap_str} ";
312            }
313
314            $series .= "LINE2:'bmem_total${def_nr}'#".$conf['cpu_num_color']."${total_str} ";
315
316            $def_nr++;
317        }
318
319    } 
320    else if ($graph == "load_report") 
321    {
322        $style = "Load";
323
324        $lower_limit = "--lower-limit 0 --rigid";
325        $vertical_label = "--vertical-label 'Load/Procs'";
326
327        $def_nr = 0;
328
329        foreach( $rrd_dirs as $rrd_dir ) 
330        {
331
332            if( $def_nr == 0 ) 
333            {
334
335                $load_str = ":'1-min Load'";
336                $cpu_str = ":'CPUs'";
337                $run_str = ":'Running Processes'";
338            } 
339            else 
340            {
341                $load_str = "";
342                $cpu_str = "";
343                $run_str = "";
344            }
345
346            $series .= "DEF:'load_one${def_nr}'='${rrd_dir}/load_one.rrd':'sum':AVERAGE "
347                ."DEF:'proc_run${def_nr}'='${rrd_dir}/proc_run.rrd':'sum':AVERAGE "
348                ."DEF:'cpu_num${def_nr}'='${rrd_dir}/cpu_num.rrd':'sum':AVERAGE ";
349            $series .="AREA:'load_one${def_nr}'#".$conf['load_one_color']."${load_str} ";
350            $series .="LINE2:'cpu_num${def_nr}'#".$conf['cpu_num_color']."${cpu_str} ";
351            $series .="LINE2:'proc_run${def_nr}'#".$conf['proc_run_color']."${run_str} ";
352
353            $def_nr++;
354        }
355
356    } 
357    else if ($graph == "network_report") 
358    {
359        $style = "Network";
360
361        $lower_limit = "--lower-limit 0 --rigid";
362        $extras .= "--base 1024";
363        $vertical_label = "--vertical-label 'Bytes/sec'";
364
365        $def_nr = 0;
366
367        foreach( $rrd_dirs as $rrd_dir ) 
368        {
369
370            if( $def_nr == 0 ) 
371            {
372
373                $in_str = ":'In'";
374                $out_str = ":'Out'";
375            } 
376            else 
377            {
378
379                $in_str = "";
380                $out_str = "";
381            }
382
383            $series .= "DEF:'bytes_in${def_nr}'='${rrd_dir}/bytes_in.rrd':'sum':AVERAGE "
384                ."DEF:'bytes_out${def_nr}'='${rrd_dir}/bytes_out.rrd':'sum':AVERAGE "
385                ."LINE2:'bytes_in${def_nr}'#".$conf['mem_cached_color']."${in_str} "
386                ."LINE2:'bytes_out${def_nr}'#".$conf['mem_used_color']."${out_str} ";
387
388            $def_nr++;
389        }
390
391    } 
392    else if ($graph == "packet_report") 
393    {
394        $style = "Packets";
395
396        $lower_limit = "--lower-limit 0 --rigid";
397        $extras .= "--base 1024";
398        $vertical_label = "--vertical-label 'Packets/sec'";
399
400        $def_nr = 0;
401
402        foreach( $rrd_dirs as $rrd_dir ) 
403        {
404
405            if( $def_nr == 0 ) 
406            {
407
408                $in_str = ":'In'";
409                $out_str = ":'Out'";
410            } 
411            else 
412            {
413
414                $in_str = "";
415                $out_str = "";
416            }
417
418            $series .= "DEF:'bytes_in${def_nr}'='${rrd_dir}/pkts_in.rrd':'sum':AVERAGE "
419                ."DEF:'bytes_out${def_nr}'='${rrd_dir}/pkts_out.rrd':'sum':AVERAGE "
420                ."LINE2:'bytes_in${def_nr}'#".$conf['mem_cached_color']."${in_str} "
421                ."LINE2:'bytes_out${def_nr}'#".$conf['mem_used_color']."${out_str} ";
422
423            $def_nr++;
424        }
425
426    } 
427    else 
428    {
429        /* Custom graph */
430        $style = "";
431
432        $subtitle = $metricname;
433        if($context == "host")
434        {
435            if ($size == "small")
436                $prefix = $metricname;
437            else
438                $prefix = $hostname;
439
440            $value = $value>1000 ? number_format($value) : number_format($value, 2);
441        }
442
443        if (is_numeric($max))
444            $upper_limit = "--upper-limit '$max' ";
445        if (is_numeric($min))
446            $lower_limit ="--lower-limit '$min' ";
447
448        if ($vlabel)
449        {
450            $vertical_label = "--vertical-label '$vlabel'";
451        }
452        else 
453        {
454            if ($upper_limit or $lower_limit) 
455            {
456                $max = $max>1000 ? number_format($max) : number_format($max, 2);
457                $min = $min>0 ? number_format($min,2) : $min;
458
459                $vertical_label ="--vertical-label '$min - $max' ";
460            }
461        }
462
463        $def_nr = 0;
464
465
466        foreach( $rrd_dirs as $rrd_dir ) 
467        {
468
469            if( $def_nr == 0 ) 
470            {
471                $title_str = ":'${subtitle}'";
472            } 
473            else 
474            {
475                $title_str = "";
476            }
477
478            $rrd_file = "$rrd_dir/$metricname.rrd";
479            $series .= "DEF:'sum${def_nr}'='$rrd_file':'sum':AVERAGE "
480                ."AREA:'sum${def_nr}'#".$conf['default_metric_color']."${title_str} ";
481
482            if( $conf['graphreport_stats'] )
483            {
484                $series .= "CDEF:sum${def_nr}_nonans=sum${def_nr},UN,0,sum${def_nr},IF ";
485            }
486
487            $def_nr++;
488        }
489
490        if( $conf['graphreport_stats'] )
491        {
492            $s_last         = $def_nr - 1;
493            $series_sum     = "CDEF:sum=sum0_nonans";
494
495            if( $def_nr > 1 )
496            {
497                foreach (range(1, ($s_last)) as $print_nr ) 
498                {
499                    $series_sum     .= ",sum{$print_nr}_nonans,+";
500                }
501            }
502
503            $series_sum .= " ";
504
505            $series_last    = "VDEF:'sum_last'=sum,LAST ";
506            $series_minimum = "VDEF:'sum_min'=sum,MINIMUM ";
507            $series_average = "VDEF:'sum_avg'=sum,AVERAGE ";
508            $series_maximum = "VDEF:'sum_max'=sum,MAXIMUM ";
509
510            $series .= $series_sum . $series_last . $series_minimum . $series_average . $series_maximum;
511
512            $series .= "COMMENT:\"\\n\" ";
513            $series .= "GPRINT:'sum_last':'${space1}Now\:%6.1lf%s' "
514                    . "GPRINT:'sum_min':'${space1}Min\:%6.1lf%s${eol1}' "
515                    . "GPRINT:'sum_avg':'${space2}Avg\:%6.1lf%s' "
516                    . "GPRINT:'sum_max':'${space1}Max\:%6.1lf%s\\l' ";
517        }
518    }
519}
520if( $series != '' ) 
521{
522    if ($job_start)
523    {
524        $series .= "VRULE:${job_start}#${jobstart_color}:'job start':dashes=4,2 ";
525    }
526    if ($job_stop)
527    {
528        $series .= "VRULE:${job_stop}#${jobstop_color}:'job stop':dashes=4,2 ";
529    }
530}
531
532if($graph == "job_report")
533{
534    if($range == 'job' )
535    {
536        $title = "Last: $j_title";
537    }
538    else
539    {
540        $title = "Last: $range";
541    }
542}
543else
544{
545    $title = "$hostname";
546}
547
548function determineXGrid( $p_start, $p_stop ) 
549{
550
551    $period = intval( $p_stop - $p_start );
552
553    // Syntax: <minor_grid_lines_time_declr>:<major_grid_lines_time_declr>:<labels_time_declr>:<offset>:<format>
554    //
555    // Where each <*time_declr*> = <time_type>:<time_interval>
556
557    //$my_lines1 = intval( $period / 3.0 );
558    //$my_lines2 = intval( $period / 6.0 );
559
560    //$my_grid = "SECOND:$my_lines2:SECOND:$my_lines1:SECOND:$my_lines1:0:%R";
561
562    //return "--x-grid $my_grid";
563
564    // Less than 1 minute
565    if( $period < 60 ) 
566    {
567
568        $tm_formt = "%X";
569        $my_grid = "SECOND:15:SECOND:30:SECOND:30:0:$tm_formt";
570
571    // Less than 10 minutes
572    } 
573    else if( $period < 600 ) 
574    {
575
576        $tm_formt = "%R";
577        $my_grid = "MINUTE:1:MINUTE:3:MINUTE:3:0:$tm_formt";
578
579    // Less than 1 hour
580    } 
581    else if( $period < 3600 ) 
582    {
583
584        $tm_formt = "%R";
585        $my_grid = "MINUTE:5:MINUTE:15:MINUTE:15:0:$tm_formt";
586
587    // Less than 15 hour
588    } 
589    else if( $period < 3600 ) 
590    {
591
592        $tm_formt = "%R";
593        $my_grid = "HOUR:1:HOUR:2:HOUR:2:0:$tm_formt";
594
595    // Less than 1 day
596    //
597    } 
598    else if( $period < 86400 ) 
599    {
600
601        $tm_formt = "%R";
602        $my_grid = "HOUR:2:HOUR:5:HOUR:5:0:$tm_formt";
603
604    // Less than 15 days
605    //
606    } 
607    else if( $period < 1296000 ) 
608    {
609
610        $tm_formt = "%e-%m";
611        $my_grid = "HOUR:1:DAY:3:DAY:3:0:'$tm_formt'";
612       
613    // Less than 30 days (a month)
614    //
615    } 
616    else if( $period < 2592000 ) 
617    {
618
619        $tm_formt = "%e-%m";
620        $my_grid = "DAY:5:DAY:10:DAY:10:0:'$tm_formt'";
621    }
622
623    if( isset( $my_grid ) ) 
624    {
625
626        $ret_str = "--x-grid $my_grid";
627        return array($ret_str,$tm_formt);
628
629    } 
630    else 
631    {
632        return array( "", "" );
633    }
634}
635
636$lower_limit = "--lower-limit 0";
637
638if( !isset( $load_color ) or ( $load_color == '') )
639{
640    $load_color = 'FFFFFF';
641}
642
643# Calculate time range.
644if ( isset($sourcetime) )
645{
646    $end = $sourcetime;
647    # Get_context makes start negative.
648    $start = $sourcetime + $start;
649
650    # Fix from Phil Radden, but step is not always 15 anymore.
651    if ($range=="month")
652    {
653        $end = floor($end / 672) * 672;
654    }
655        $command = $conf['rrdtool']. " graph - --start $start --end $end ".
656                "--width $width --height $height $lower_limit ".
657                "--title '$title' $extras $background ".
658                $series;
659}
660else
661{
662    $command = $conf['rrdtool'] . " graph - --start $period_start --end $period_stop ".
663               "--width $width --height $height $lower_limit --color BACK#$load_color ".
664               "--title '$title' $extras $background ".
665               $series;
666}
667
668$debug=0;
669
670
671# Did we generate a command?   Run it.
672if($command) 
673{
674    /*Make sure the image is not cached*/
675    header ("Expires: Mon, 26 Jul 1997 05:00:00 GMT");   // Date in the past
676    header ("Last-Modified: " . gmdate("D, d M Y H:i:s") . " GMT"); // always modified
677    header ("Cache-Control: no-cache, must-revalidate");   // HTTP/1.1
678    header ("Pragma: no-cache");                     // HTTP/1.0
679    if ($debug) 
680    {
681        header ("Content-type: text/html");
682        print "$command\n\n\n\n\n";
683    } 
684    else 
685    {
686        header ("Content-type: image/gif");
687        passthru($command);
688    }
689}
690?>
Note: See TracBrowser for help on using the repository browser.