source: trunk/web/addons/job_monarch/overview.php @ 299

Last change on this file since 299 was 299, checked in by bastiaans, 15 years ago

web/addons/job_monarch/conf.php:

  • added COLUMN_NODES option to display job node hostnames column

web/addons/job_monarch/search.php,
web/addons/job_monarch/overview.php:

  • added handling of COLUMN_NODES

web/addons/job_monarch/templates/search.tpl,
web/addons/job_monarch/templates/overview.tpl:

  • added COLUMN_NODES to html
  • Property svn:keywords set to Id
File size: 21.5 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: overview.php 299 2007-04-06 11:21:35Z bastiaans $
23 */
24
25global $GANGLIA_PATH, $clustername, $tpl, $filter, $cluster, $get_metric_string, $cluster_url, $sh;
26global $hosts_up, $m, $start, $end, $filterorder, $COLUMN_REQUESTED_MEMORY, $COLUMN_QUEUED, $COLUMN_NODES, $hostname, $piefilter;
27
28$data_gatherer = new DataGatherer( $clustername );
29
30$tpl->assign( "clustername", $clustername );
31
32if( $JOB_ARCHIVE )
33        $tpl->assign( "cluster_url", rawurlencode($clustername) );
34
35$data_gatherer->parseXML();
36
37$heartbeat = $data_gatherer->getHeartbeat();
38$jobs = $data_gatherer->getJobs();
39$gnodes = $data_gatherer->getNodes();
40$cpus = $data_gatherer->getCpus();
41
42function setupFilterSettings() {
43        global $tpl, $filter, $clustername, $piefilter;
44
45        $filter_image_url = "";
46
47        $tpl->gotoBlock( "_ROOT" );
48
49        foreach( $filter as $filtername => $filtervalue ) {
50                $tpl->assign( "f_".$filtername, $filtervalue );
51                $filter_image_url .= "&$filtername=$filtervalue";
52        }
53
54        $tpl->assign( "clusterimage", "./image.php?c=".rawurlencode($clustername)."&view=big-clusterimage".$filter_image_url );
55        $tpl->assign( "f_order", $filterorder );
56
57        if( array_key_exists( "id", $filter ) )
58                $piefilter = 'id';
59        else if( array_key_exists( "user", $filter ) )
60                $piefilter = 'user';
61        else if( array_key_exists( "queue", $filter ) )
62                $piefilter = 'queue';
63
64        $pie = drawPie();
65        $tpl->assign("pie", $pie );
66}
67
68function timeToEpoch( $time ) {
69
70        $time_fields = explode( ':', $time );
71
72        if( count($time_fields) == 3 ) {
73
74                $hours = $time_fields[0];
75                $minutes = $time_fields[1];
76                $seconds = $time_fields[2];
77
78        } else if( count($time_fields) == 2 ) {
79
80                $hours = 0;
81                $minutes = $time_fields[0];
82                $seconds = $time_fields[1];
83
84        } else if( count($time_fields) == 1 ) {
85
86                $hours = 0;
87                $minutes = 0;
88                $seconds = $time_fields[0];
89        }
90
91        $myepoch = intval( $seconds + (intval( $minutes * 60 )) + (intval( $hours * 3600 )) );
92
93        return $myepoch;
94}
95
96function makeTime( $time ) {
97
98        $days = intval( $time / 86400 );
99        $time = ($days>0) ? $time % ($days * 86400) : $time;
100
101        //printf( "time = %s, days = %s\n", $time, $days );
102
103        $date_str = '';
104        $day_str = '';
105
106        if( $days > 0 ) {
107                if( $days > 1 )
108                        $day_str .= $days . ' days';
109                else
110                        $day_str .= $days . ' day';
111        }
112
113        $hours = intval( $time / 3600 );
114        $time = $hours ? $time % ($hours * 3600) : $time;
115
116        //printf( "time = %s, days = %s, hours = %s\n", $time, $days, $hours );
117
118        if( $hours > 0 ) {
119                $date_str .= $hours . ':';
120                $date_unit = 'hours';
121        }
122               
123        $minutes = intval( $time / 60 );
124        $seconds = $minutes ? $time % ($minutes * 60) : $time;
125
126        if( $minutes > 0 ) {
127
128                if( $minutes >= 10 )
129                        $date_str .= $minutes . ':';
130                else
131                        $date_str .= '0' . $minutes . ':';
132
133                $date_unit = (!isset($date_unit)) ? 'minutes' : $date_unit;
134        } else {
135                if($hours > 0 ) {
136                        $date_str .= '00:';
137                        $date_unit = (!isset($date_unit)) ? 'minutes' : $date_unit;
138                }
139        }
140
141
142        $date_unit = (!isset($date_unit)) ? 'seconds' : $date_unit;
143
144        if( $seconds > 0 ) {
145
146                if( $seconds >= 10 )
147                        $date_str .= $seconds . ' ' . $date_unit;
148                else
149                        $date_str .= '0' . $seconds . ' ' . $date_unit;
150                       
151        } else if ( $hours > 0 or $minutes > 0 )
152
153                $date_str .= '00 ' . $date_unit;
154
155        if( $days > 0) {
156
157                if( $hours > 0 or $minutes > 0 or $seconds > 0 )
158                        $date_str = $day_str . ' - ' . $date_str;
159                else
160                        $date_str = $day_str;
161        }
162
163        return $date_str;
164}
165
166//function makeDate( $time ) {
167//      return strftime( "%a %d %b %Y %H:%M:%S", $time );
168//}
169
170function colorRed( $color ) {
171        return substr( $color, 0, 2 );
172}
173function colorGreen( $color ) {
174        return substr( $color, 2, 2 );
175}
176function colorBlue( $color ) {
177        return substr( $color, 4, 2 );
178}
179
180function colorDiffer( $first, $second ) {
181
182        // Make sure these two colors differ atleast 50 R/G/B
183        $min_diff = 50;
184
185        $c1r = hexDec( colorRed( $first ) );
186        $c1g = hexDec( colorGreen( $first ) );
187        $c1b = hexDec( colorBlue( $first ) );
188
189        $c2r = hexDec( colorRed( $second ) );
190        $c2g = hexDec( colorGreen( $second ) );
191        $c2b = hexDec( colorBlue( $second ) );
192
193        $rdiff = ($c1r >= $c2r) ? $c1r - $c2r : $c2r - $c1r;
194        $gdiff = ($c1g >= $c2g) ? $c1g - $c2g : $c2g - $c1g;
195        $bdiff = ($c1b >= $c2b) ? $c1b - $c2b : $c2b - $c1b;
196
197        if( $rdiff >= $min_diff or $gdiff >= $min_diff or $bdiff >= $min_diff )
198                return TRUE;
199        else
200                return FALSE;
201}
202
203function randomColor( $known_colors ) {
204
205        $start = "004E00";
206       
207        $start_red = colorRed( $start );
208        $start_green = colorGreen( $start );
209        $start_blue = colorBlue( $start );
210       
211        $end = "FFFFFF";
212
213        $end_red = colorRed( $end );
214        $end_green = colorGreen( $end );
215        $end_blue = colorBlue( $end );
216
217        $change_color = TRUE;
218
219        while( $change_color ) {
220
221                $change_color = FALSE;
222
223                $new_red = rand( hexDec( $start_red ), hexDec( $end_red ) );
224                $new_green = rand( hexDec( $start_green ), hexDec( $end_green ) );
225                $new_blue = rand( hexDec( $start_blue ), hexDec( $end_blue ) );
226
227                $new = decHex( $new_red ) . decHex( $new_green ) . decHex( $new_blue );
228
229                foreach( $known_colors as $old )
230
231                        if( !colorDiffer( $new, $old ) )
232
233                                $change_color = TRUE;
234        }
235
236        // Whoa! Actually found a good color ;)
237        return $new;
238}
239
240function drawJobPie() {
241}
242
243function drawUserPie() {
244
245}
246
247function drawQueuePie() {
248
249}
250
251
252function drawPie() {
253
254        global $jobs, $gnodes, $piefilter, $filter;
255
256        $nodes = $gnodes;
257
258        if( isset($piefilter) ) 
259                $pie_args = "title=" . rawurlencode("Cluster ".$piefilter." usage");
260        else
261                $pie_args = "title=" . rawurlencode("Cluster queue usage");
262               
263        $pie_args .= "&size=250x150";
264
265        $queues = array();
266        $nr_jobs = count( $jobs );
267        $nr_nodes = count( $nodes );
268
269        $emptynodes = 0;
270
271        $job_weight = array();
272
273        foreach( $nodes as $node ) {
274
275                $myjobs = $node->getJobs();
276
277                if( count( $myjobs ) == 0 )
278                        $emptynodes++;
279        }
280        $used_nodes = $nr_nodes - $emptynodes;
281
282        $empty_percentage = ($emptynodes / $nr_nodes) * 100;
283        $job_percentage = 100 - $empty_percentage; 
284
285        $qcolors = array();
286        $color = randomColor( $qcolors );
287        $qcolors[] = $color;
288        $pie_args .= "&free=$empty_percentage,$color";
289
290        if( isset( $piefilter ) )
291                $filterpie = array();
292
293        foreach( $nodes as $node ) {
294
295                $node_jobs = $node->getJobs();
296                $nr_node_jobs = count( $node_jobs );
297                $myhost = $node->getHostname();
298
299                foreach( $node_jobs as $myjob ) {
300
301                        // Determine the weight of this job on the node it is running
302                        // - what percentage of the node is in use by this job
303                        //
304                        $job_weight[$myjob] = ( 100 / count( $node_jobs ) ) / 100;
305                        $qname = $jobs[$myjob][queue];
306
307                        if( isset($piefilter) ) {
308                                $countjob = 1;
309                                if( $piefilter == 'id' ) {
310                                        if( $myjob != $filter[$piefilter] )
311                                                $countjob = 0;
312                                } else if( $piefilter == 'user' ) {
313                                        if( $jobs[$myjob][owner] != $filter[$piefilter] )
314                                                $countjob = 0;
315                                } else {
316                                        if( $jobs[$myjob][$piefilter] != $filter[$piefilter] )
317                                                $countjob = 0;
318                                }
319
320                                if( $countjob ) {
321
322                                        if( !isset( $filterpie[$filter[$piefilter]] ) )
323                                                $filterpie[$filter[$piefilter]] = $job_weight[$myjob];
324                                        else
325                                                $filterpie[$filter[$piefilter]] = $filterpie[$filter[$piefilter]] + $job_weight[$myjob];
326                                } else {
327                                        if( !isset( $filterpie["other"] ) )
328                                                $filterpie["other"] = $job_weight[$myjob];
329                                        else
330                                                $filterpie["other"] = $filterpie["other"] + $job_weight[$myjob];
331
332                                }
333                               
334                        } else {
335
336                                if( !isset( $queues[$qname] ) )
337                                        $queues[$qname] = $job_weight[$myjob];
338                                else
339                                        $queues[$qname] = $queues[$qname] + $job_weight[$myjob];
340                        }
341                }
342        }
343
344        //$qcolors = array();
345        if( isset( $piefilter ) )
346                $graphvals = $filterpie;
347        else
348                $graphvals = $queues;
349
350        foreach( $graphvals as $name => $totalweight) {
351
352                $percentage = ( $totalweight / $used_nodes ) * $job_percentage;
353               
354                $color = randomColor( $qcolors );
355                $qcolors[] = $color;
356                $pie_args .= "&$name=$percentage,$color";
357        }
358        $pie = "../../pie.php?$pie_args";
359
360        return $pie;
361}
362
363
364function sortJobs( $jobs, $sortby, $sortorder ) {
365
366        $sorted = array();
367
368        $cmp = create_function( '$a, $b', 
369                "global \$sortby, \$sortorder;".
370
371                "if( \$a == \$b ) return 0;".
372
373                "if (\$sortorder==\"desc\")".
374                        "return ( \$a < \$b ) ? 1 : -1;".
375                "else if (\$sortorder==\"asc\")".
376                        "return ( \$a > \$b ) ? 1 : -1;" );
377
378        foreach( $jobs as $jobid => $jobattrs ) {
379
380                        $state = $jobattrs[status];
381                        $user = $jobattrs[owner];
382                        $queue = $jobattrs[queue];
383                        $name = $jobattrs[name];
384                        $req_cpu = $jobattrs[requested_time];
385                        $req_memory = $jobattrs[requested_memory];
386
387                        if( $state == 'R' )
388                                $nodes = count( $jobattrs[nodes] );
389                        else
390                                $nodes = $jobattrs[nodes];
391
392                        $ppn = (int) $jobattrs[ppn] ? $jobattrs[ppn] : 1;
393                        $cpus = $nodes * $ppn;
394                        $queued_time = (int) $jobattrs[queued_timestamp];
395                        $start_time = (int) $jobattrs[start_timestamp];
396                        $runningtime = $report_time - $start_time;
397
398                        switch( $sortby ) {
399                                case "id":
400                                        $sorted[$jobid] = $jobid;
401                                        break;
402
403                                case "state":
404                                        $sorted[$jobid] = $state;
405                                        break;
406
407                                case "user":
408                                        $sorted[$jobid] = $user;
409                                        break;
410
411                                case "queue":
412                                        $sorted[$jobid] = $queue;
413                                        break;
414
415                                case "name":
416                                        $sorted[$jobid] = $name;
417                                        break;
418
419                                case "req_cpu":
420                                        $sorted[$jobid] = timeToEpoch( $req_cpu );
421                                        break;
422
423                                case "req_mem":
424                                        $sorted[$jobid] = $req_memory;
425                                        break;
426
427                                case "nodes":
428                                        $sorted[$jobid] = $nodes;
429                                        break;
430
431                                case "cpus":
432                                        $sorted[$jobid] = $cpus;
433                                        break;
434
435                                case "queued":
436                                        $sorted[$jobid] = $queued_time;
437                                        break;
438
439                                case "start":
440                                        $sorted[$jobid] = $start_time;
441                                        break;
442
443                                case "runningtime":
444                                        $sorted[$jobid] = $runningtime;
445                                        break;
446
447                                default:
448                                        break;
449
450                        }
451        }
452
453        //uasort( $sorted, $cmp );
454        if( $sortorder == "asc" )
455                arsort( $sorted );
456        else if( $sortorder == "desc" )
457                asort( $sorted );
458
459        return $sorted;
460}
461
462function makeOverview() {
463
464        global $jobs, $nodes, $heartbeat, $clustername, $tpl;
465        global $sortorder, $sortby, $filter, $sh, $hc, $m;
466        global $cluster_url, $get_metric_string, $host_url, $metrics;
467        global $start, $end, $reports, $gnodes, $default_showhosts;
468        global $COLUMN_QUEUED, $COLUMN_REQUESTED_MEMORY, $COLUMN_NODES, $hostname;
469        $metricname = $m;
470
471        $tpl->assign("sortorder", $sortorder );
472        $tpl->assign("sortby", $sortby );
473
474        $sorted_jobs = sortJobs( $jobs, $sortby, $sortorder );
475
476        $even = 1;
477
478        $used_jobs = 0;
479        $used_cpus = 0;
480        $used_nodes = 0;
481
482        $queued_jobs = 0;
483        $queued_nodes = 0;
484        $queued_cpus = 0;
485
486        $total_nodes = 0;
487        $total_cpus = 0;
488        $total_jobs = 0;
489
490        $all_used_nodes = array();
491        $total_used_nodes = array();
492
493        $running_name_nodes = array();
494
495        $running_nodes = 0;
496        $running_jobs = 0;
497        $running_cpus = 0;
498
499        $avail_nodes = count( $gnodes );
500        $avail_cpus = cluster_sum("cpu_num", $metrics);
501
502        $view_cpus = 0;
503        $view_jobs = 0;
504        $view_nodes = 0;
505
506        $all_nodes = 0;
507        $all_jobs = 0;
508        $all_cpus = 0;
509
510        $view_name_nodes = array();
511
512        if( $COLUMN_REQUESTED_MEMORY ) {
513                $tpl->newBlock( "column_header_req_mem" );
514        }
515
516        if( $COLUMN_NODES ) {
517                $tpl->newBlock( "column_header_nodes" );
518        }
519
520        if( $COLUMN_QUEUED ) {
521                $tpl->newBlock( "column_header_queued" );
522        }
523
524        $last_displayed_job = null;
525
526        foreach( $sorted_jobs as $jobid => $sortdec ) {
527
528                $report_time = $jobs[$jobid][reported];
529
530                if( $jobs[$jobid][status] == 'R' )
531                        $nodes = count( $jobs[$jobid][nodes] );
532                else if( $jobs[$jobid][status] == 'Q' )
533                        $nodes = $jobs[$jobid][nodes];
534
535                $ppn = (int) $jobs[$jobid][ppn] ? $jobs[$jobid][ppn] : 1;
536                $cpus = $nodes * $ppn;
537
538                if( $report_time == $heartbeat ) {
539
540                        $display_job = 1;
541
542                        foreach( $jobs[$jobid][nodes] as $tempnode )
543                                $all_used_nodes[] = $tempnode;
544
545                        $used_cpus += $cpus;
546
547                        if( $jobs[$jobid][status] == 'R' ) {
548                                $running_cpus += $cpus;
549                                $running_jobs++;
550
551                                $found_node_job = 0;
552
553                                foreach( $jobs[$jobid][nodes] as $tempnode ) {
554                                        $running_name_nodes[] = $tempnode;
555
556                                        if( isset( $hostname ) && $hostname != '' ) {
557                                                //$filter[host] = $hostname;
558
559                                                $domain_len = 0 - strlen( $jobs[$jobid][domain] );
560                                                $hostnode = $tempnode;
561                                                if( substr( $hostnode, $domain_len ) != $jobs[$jobid][domain] ) {
562                                                        $hostnode = $hostnode. '.'. $jobs[$jobid][domain];
563                                                }
564
565                                                if( $hostname == $hostnode ) {
566                                                        $found_node_job = 1;
567                                                        $display_job = 1;
568                                                } else if( !$found_node_job ) {
569                                                        $display_job = 0;
570                                                }
571                                        }
572                                }
573                        }
574
575                        if( $jobs[$jobid][status] == 'Q' ) {
576                                if( isset( $hostname ) && $hostname != '' )
577                                        $display_job = 0;
578
579                                $queued_cpus += $cpus;
580                                $queued_nodes += $nodes;
581                                $queued_jobs++;
582                        }
583
584                        foreach( $filter as $filtername=>$filtervalue ) {
585
586                                if( $filtername == 'id' && $jobid != $filtervalue )
587                                        $display_job = 0;
588                                else if( $filtername == 'state' && $jobs[$jobid][status] != $filtervalue )
589                                        $display_job = 0;
590                                else if( $filtername == 'queue' && $jobs[$jobid][queue] != $filtervalue )
591                                        $display_job = 0;
592                                else if( $filtername == 'user' && $jobs[$jobid][owner] != $filtervalue )
593                                        $display_job = 0;
594                        }
595
596                        if( $display_job ) {
597
598                                $tpl->newBlock("node");
599                                $tpl->assign( "clustername", $clustername );
600                                $tpl->assign("id", $jobid );
601
602                                $last_displayed_job = $jobid;
603
604                                $tpl->assign("state", $jobs[$jobid][status] );
605
606                                $fullstate = '';
607                                if( $jobs[$jobid][status] == 'R' ) {
608                                        $fullstate = "Running";
609                                } else if( $jobs[$jobid][status] == 'Q' ) {
610                                        $fullstate = "Queued";
611                                }
612
613                                $tpl->assign("fullstate", $fullstate );
614                               
615                                $tpl->assign("user", $jobs[$jobid][owner] );
616                                $tpl->assign("queue", $jobs[$jobid][queue] );
617
618                                $fulljobname = $jobs[$jobid][name];
619                                $shortjobname = '';
620
621                                $tpl->assign("fulljobname", $fulljobname );
622
623                                if( mb_strwidth( $fulljobname ) > 10 ) {
624                                        $tpl->newBlock("jobname_hint_start");
625                                        $tpl->gotoBlock("node");
626
627                                        $shortjobname = mb_strimwidth( $fulljobname, 0, 9 ) . '..';
628                                } else {
629                                        $shortjobname = $fulljobname;
630                                }
631                               
632                                $tpl->assign("name", $shortjobname );
633
634                                if( strlen( $fulljobname ) > 10 ) {
635                                        $tpl->newBlock("jobname_hint_end");
636                                        $tpl->gotoBlock("node");
637                                }
638
639                                $domain = $jobs[$jobid][domain];
640                                $tpl->assign("req_cpu", makeTime( timeToEpoch( $jobs[$jobid][requested_time] ) ) );
641
642                                if( $COLUMN_REQUESTED_MEMORY ) {
643                                        $tpl->newBlock( "column_req_mem" );
644                                        $tpl->assign( "req_memory", $jobs[$jobid][requested_memory] );
645                                        $tpl->gotoBlock( "node" );
646                                }
647
648
649                                if( $COLUMN_QUEUED ) {
650                                        $tpl->newBlock( "column_queued" );
651                                        $tpl->assign( "queued", makeDate( $jobs[$jobid][queued_timestamp] ) );
652                                        $tpl->gotoBlock( "node" );
653                                }
654
655                                $ppn = (int) $jobs[$jobid][ppn] ? $jobs[$jobid][ppn] : 1;
656                                $cpus = $nodes * $ppn;
657                                $tpl->assign("nodes", $nodes );
658                                $tpl->assign("cpus", $cpus );
659                                $start_time = (int) $jobs[$jobid][start_timestamp];
660                                $job_start = $start_time;
661
662                                $view_cpus += $cpus;
663                                $view_jobs++;
664
665                                if( $jobs[$jobid][status] == 'R' ) {
666                                        foreach( $jobs[$jobid][nodes] as $tempnode )
667                                                $view_name_nodes[] = $tempnode;
668
669                                        if( $COLUMN_NODES ) {
670                                                $tpl->newBlock( "column_nodes" );
671                                                $nodes_hostnames = implode( " ", $jobs[$jobid][nodes] );
672                                                $tpl->assign( "nodes_hostnames", $nodes_hostnames );
673                                                $tpl->gotoBlock( "node" );
674                                        }
675                                } else if( $jobs[$jobid][status] == 'Q' ) {
676                                        $view_nodes += (int) $jobs[$jobid][nodes];
677                                }
678
679                                if( $even ) {
680
681                                        $tpl->assign("nodeclass", "even");
682                                        $even = 0;
683                                } else {
684
685                                        $tpl->assign("nodeclass", "odd");
686                                        $even = 1;
687                                }
688
689                                if( $start_time ) {
690
691                                        $runningtime = makeTime( $report_time - $start_time );
692                                        $job_runningtime = $report_time - $start_time;
693                                        $tpl->assign("started", makeDate( $start_time ) );
694                                        $tpl->assign("runningtime", $runningtime );
695                                }
696                        }
697                }
698        }
699        $all_used_nodes = array_unique( $all_used_nodes );
700        $view_name_nodes = array_unique( $view_name_nodes );
701        $running_name_nodes = array_unique( $running_name_nodes );
702
703        $used_nodes = count( $all_used_nodes );
704        $view_nodes += count( $view_name_nodes );
705        $running_nodes += count( $running_name_nodes );
706
707        $total_nodes = $queued_nodes + $running_nodes;
708        $total_cpus = $queued_cpus + $running_cpus;
709        $total_jobs = $queued_jobs + $running_jobs;
710
711        $tpl->assignGlobal("avail_nodes", $avail_nodes );
712        $tpl->assignGlobal("avail_cpus", $avail_cpus );
713
714        $tpl->assignGlobal("queued_nodes", $queued_nodes );
715        $tpl->assignGlobal("queued_jobs", $queued_jobs );
716        $tpl->assignGlobal("queued_cpus", $queued_cpus );
717
718        $tpl->assignGlobal("total_nodes", $total_nodes );
719        $tpl->assignGlobal("total_jobs", $total_jobs );
720        $tpl->assignGlobal("total_cpus", $total_cpus );
721
722        $tpl->assignGlobal("running_nodes", $running_nodes );
723        $tpl->assignGlobal("running_jobs", $running_jobs );
724        $tpl->assignGlobal("running_cpus", $running_cpus );
725
726        $tpl->assignGlobal("used_nodes", $used_nodes );
727        $tpl->assignGlobal("used_jobs", $used_jobs );
728        $tpl->assignGlobal("used_cpus", $used_cpus );
729
730        $free_nodes = $avail_nodes - $running_nodes;
731        $free_cpus = $avail_cpus - $running_cpus;
732
733        $tpl->assignGlobal("free_nodes", $free_nodes );
734        $tpl->assignGlobal("free_cpus", $free_cpus );
735
736        $tpl->assignGlobal("view_nodes", $view_nodes );
737        $tpl->assignGlobal("view_jobs", $view_jobs );
738        $tpl->assignGlobal("view_cpus", $view_cpus );
739
740        $tpl->assignGlobal("report_time", makeDate( $heartbeat));
741
742        if( intval($view_jobs) == 1 and $start_time )
743                if( $last_displayed_job != null )
744                        $filter[id] = $last_displayed_job;
745
746        makeHeader( 'overview' );
747        setupFilterSettings();
748
749        if( intval($view_jobs) == 1 and $start_time ) {
750
751                $tpl->newBlock( "showhosts" );
752
753                # Present a width list
754                $cols_menu = "<SELECT NAME=\"hc\" OnChange=\"toga_form.submit();\">\n";
755
756
757                $hostcols = ($hc) ? $hc : 4;
758
759                foreach(range(1,25) as $cols) {
760                        $cols_menu .= "<OPTION VALUE=$cols ";
761                        if ($cols == $hostcols)
762                                $cols_menu .= "SELECTED";
763                        $cols_menu .= ">$cols\n";
764                }
765                $cols_menu .= "</SELECT>\n";
766
767                //$tpl->assign("cluster", $clustername);
768                $tpl->assign("metric","$metricname $units");
769                $tpl->assign("id", $filter[id]);
770                # Host columns menu defined in header.php
771                $tpl->assign("cols_menu", $cols_menu);
772
773                $showhosts = isset($sh) ? $sh : $default_showhosts;
774                //if( !$showhosts) $showhosts = $default_showhosts;
775                $tpl->assign("checked$showhosts", "checked");
776
777                if( $showhosts ) {
778                        //-----
779
780                        if( !isset($start) ) $start="jobstart";
781                        if( !isset($stop) ) $stop="now";
782                        //$tpl->assign("start", $start);
783                        //$tpl->assign("stop", $stop);
784
785                        $sorted_hosts = array();
786                        $hosts_up = $jobs[$filter[id]][nodes];
787
788                        $r = intval($job_runningtime * 1.25);
789
790                        $jobrange = ($job_runningtime < 3600) ? -3600 : -$r ;
791                        $jobstart = $report_time - $job_runningtime;
792
793                        if ($reports[$metricname])
794                                $metricval = "g";
795                        else
796                                $metricval = "m";
797                               
798                        foreach ($hosts_up as $host ) {
799
800                                $domain_len = 0 - strlen( $domain );
801                                if( substr( $host, $domain_len ) != $domain ) {
802                                        $host = $host. '.'.$domain;
803                                }
804                                $cpus = $metrics[$host]["cpu_num"][VAL];
805                                if (!$cpus) $cpus=1;
806                                $load_one  = $metrics[$host]["load_one"][VAL];
807                                $load = ((float) $load_one)/$cpus;
808                                $host_load[$host] = $load;
809                                $percent_hosts[load_color($load)] += 1;
810                                if ($metricname=="load_one")
811                                        $sorted_hosts[$host] = $load;
812                                else
813                                        $sorted_hosts[$host] = $metrics[$host][$metricname][VAL];
814                        }
815                        switch ($sort) {
816                                case "descending":
817                                        arsort($sorted_hosts);
818                                        break;
819                                case "by hostname":
820                                        ksort($sorted_hosts);
821                                        break;
822                                default:
823                                case "ascending":
824                                        asort($sorted_hosts);
825                                        break;
826                        }
827
828                        //$sorted_hosts = array_merge($down_hosts, $sorted_hosts);
829
830                        # First pass to find the max value in all graphs for this
831                        # metric. The $start,$end variables comes from get_context.php,
832                        # included in index.php.
833                        list($min, $max) = find_limits($sorted_hosts, $metricname);
834
835                        # Second pass to output the graphs or metrics.
836                        $i = 1;
837                        foreach ( $sorted_hosts as $host=>$value  ) {
838                                $tpl->newBlock ("sorted_list");
839                                //$host = $host. '.'.$domain;
840                                $host_url = rawurlencode($host);
841                                $cluster_url = rawurlencode($clustername);
842
843                                $textval = "";
844                                //printf("host = %s, value = %s", $host, $value);
845                                //echo "$host: $value, ";
846                                $val = $metrics[$host][$metricname];
847                                $class = "metric";
848                                $host_link="\"../../?c=$cluster_url&h=$host_url&r=job&jr=$jobrange&js=$jobstart\"";
849
850                                if ($val[TYPE]=="timestamp" or $always_timestamp[$metricname]) {
851                                        $textval = date("r", $val[VAL]);
852                                } elseif ($val[TYPE]=="string" or $val[SLOPE]=="zero" or $always_constant[$metricname] or ($max_graphs > 0 and $i > $max_graphs )) {
853                                        $textval = "$val[VAL] $val[UNITS]";
854                                } else {
855                                        $load_color = load_color($host_load[$host]);
856                                        $graphargs = ($reports[$metricname]) ? "g=$metricname&" : "m=$metricname&";
857                                        $graphargs .= "z=small&c=$cluster_url&h=$host_url&l=$load_color" ."&v=$val[VAL]&r=job&jr=$jobrange&js=$jobstart";
858                                        if( $max > 0 ) {
859
860                                                $graphargs .= "&x=$max&n=$min";
861                                        }
862                                }
863                                if ($textval) {
864                                        $cell="<td class=$class>".  "<b><a href=$host_link>$host</a></b><br>".  "<i>$metricname:</i> <b>$textval</b></td>";
865                                } else {
866                                        $cell="<td><a href=$host_link>".  "<img src=\"../../graph.php?$graphargs\" ".  "alt=\"$host\" border=0></a></td>";
867                                }
868
869                                $tpl->assign("metric_image", $cell);
870                                if (! ($i++ % $hostcols) )
871                                         $tpl->assign ("br", "</tr><tr>");
872                        }
873                }
874//---
875        }
876}
877?>
Note: See TracBrowser for help on using the repository browser.