source: trunk/web/addons/toga/overview.php @ 119

Last change on this file since 119 was 119, checked in by bastiaans, 18 years ago

web/addons/toga/overview.php, web/addons/toga/index.php, web/addons/toga/templates/overview.tpl:

  • Added clickable filters to joblist
File size: 8.0 KB
Line 
1<?php
2global $GANGLIA_PATH, $clustername, $tpl, $filter;
3
4$data_gatherer = new DataGatherer();
5
6//$tpl->assign( "self", "./index.php" );
7$tpl->assign( "clustername", $clustername );
8$tpl->assign( "clusterimage", "./image.php?c=".rawurlencode($clustername)."&view=big-clusterimage" );
9
10$data_gatherer->parseXML();
11
12$heartbeat = $data_gatherer->getHeartbeat();
13$jobs = $data_gatherer->getJobs();
14$nodes = $data_gatherer->getNodes();
15
16foreach( $filter as $filtername => $filtervalue ) {
17        $tpl->assign( "f_".$filtername, $filtervalue );
18}
19
20$tpl->assign("heartbeat", makeDate( $heartbeat ) );
21
22$pie = drawPie();
23$tpl->assign("pie", $pie );
24
25function makeTime( $time ) {
26
27        $days = intval( $time / 86400 );
28        $time = $days ? $time % ($days * 86400) : $time;
29
30        if( $days > 0 ) {
31                if( $days > 1 )
32                        $date_str .= $days . ' days - ';
33                else
34                        $date_str .= $days . ' day - ';
35        }
36
37        $hours = intval( $time / 3600 );
38        $time = $hours ? $time % ($hours * 3600) : $time;
39
40        if( $hours > 0 ) {
41                $date_str .= $hours . ':';
42                $date_unit = ' hours';
43        }
44               
45        $minutes = intval( $time / 60 );
46        $seconds = $minutes ? $time % ($minutes * 60) : $time;
47
48        if( $minutes > 0 ) {
49
50                if( $minutes >= 10 )
51                        $date_str .= $minutes . ':';
52                else
53                        $date_str .= '0' . $minutes . ':';
54
55                $date_unit = (!isset($date_unit)) ? 'minutes' : $date_unit;
56        } else if( $days > 0 or $hours > 0 ) {
57                $date_str .= '00:';
58                $date_unit = (!isset($date_unit)) ? 'minutes' : $date_unit;
59        }
60
61        $date_unit = (!isset($date_unit)) ? 'seconds' : $date_unit;
62
63        if( $seconds > 0 ) {
64
65                if( $seconds >= 10 )
66                        $date_str .= $seconds . ' ' . $date_unit;
67                else
68                        $date_str .= '0' . $seconds . ' ' . $date_unit;
69                       
70        } else if ( $days > 0 or $hours > 0 or $minutes > 0 )
71                $date_str .= '00 ' . $date_unit;
72
73        return $date_str;
74}
75
76function makeDate( $time ) {
77        return strftime( "%a %d %b %Y %H:%M:%S", $time );
78}
79
80function colorRed( $color ) {
81        return substr( $color, 0, 2 );
82}
83function colorGreen( $color ) {
84        return substr( $color, 2, 2 );
85}
86function colorBlue( $color ) {
87        return substr( $color, 4, 2 );
88}
89
90function colorDiffer( $first, $second ) {
91
92        // Make sure these two colors differ atleast 50 R/G/B
93        $min_diff = 50;
94
95        $c1r = decHex( colorRed( $first ) );
96        $c1g = decHex( colorGreen( $first ) );
97        $c1b = decHex( colorBlue( $first ) );
98
99        $c2r = decHex( colorRed( $second ) );
100        $c2g = decHex( colorGreen( $second ) );
101        $c2b = decHex( colorBlue( $second ) );
102
103        $rdiff = ($c1r >= $c2r) ? $c1r - $c2r : $c2r - $c1r;
104        $gdiff = ($c1g >= $c2g) ? $c1g - $c2g : $c2g - $c1g;
105        $bdiff = ($c1b >= $c2b) ? $c1b - $c2b : $c2b - $c1b;
106
107        if( $rdiff >= $min_diff or $gdiff >= $min_diff or $bdiff >= $min_diff )
108                return TRUE;
109        else
110                return FALSE;
111}
112
113function randomColor( $known_colors ) {
114
115        $start = hexdec( "004E00" );
116        $end = hexdec( "FFFFFF" );
117
118        if( count( $known_colors ) == 0 )
119                return dechex(rand( $start, $end ));
120
121        $color_changed = TRUE;
122
123        while( $color_changed ) {
124
125                $color_changed = FALSE;
126
127                foreach( $known_colors as $old ) {
128
129                        if( !isset( $new ) )
130                                $new = rand( $start, $end );
131
132                        if( !colorDiffer( dechex( $new ), $old ) )
133
134                                while( !colorDiffer( $new, $old ) ) {
135
136                                        $new = rand( $start, $end );
137                                        $color_changed = TRUE;
138                                }
139                }
140        }
141
142        // Whoa! Actually found a good color ;)
143        return dechex( $new );
144}
145
146function drawPie() {
147
148        global $jobs, $nodes;
149
150        $pie_args = "title=" . rawurlencode("Cluster Jobload");
151        $pie_args .= "&size=250x150";
152
153        $queues = array();
154        $nr_jobs = count( $jobs );
155        $nr_nodes = count( $nodes );
156
157        $emptynodes = 0;
158
159        foreach( $nodes as $node ) {
160
161                $myjobs = $node->getJobs();
162
163                if( count( $myjobs ) == 0 )
164                        $emptynodes++;
165                else
166                        $nodes_jobs = $nodes_jobs + count( $myjobs );
167        }
168
169        $empty_percentage = ($emptynodes / $nr_nodes) * 100;
170        $job_percentage = 100 - $empty_percentage; 
171
172        $color = randomColor( $qcolors );
173        $qcolors[] = $color;
174        $pie_args .= "&free=$empty_percentage,$color";
175
176        foreach( $jobs as $jobid => $jobattrs ) {
177
178                $qname = $jobattrs[queue];
179
180                if( !array_search( $qname, $queues ) ) {
181
182                        if( !isset( $queues[$qname] ) )
183                                $queues[$qname] = array();
184
185                        $queues[$qname][] = $jobid;
186                }
187        }
188
189        $qcolors = array();
190        foreach( $queues as $queue => $myjobs ) {
191
192                $qjobs = count ( $myjobs );
193                $percentage = ( $qjobs / $nr_jobs ) * $job_percentage;
194                $color = randomColor( $qcolors );
195                $qcolors[] = $color;
196                $pie_args .= "&$queue=$percentage,$color";
197        }
198        $pie = "../../pie.php?$pie_args";
199
200        return $pie;
201}
202
203
204function sortJobs( $jobs, $sortby, $sortorder ) {
205
206        $sorted = array();
207
208        $cmp = create_function( '$a, $b', 
209                "global \$sortby, \$sortorder;".
210
211                "if( \$a == \$b ) return 0;".
212
213                "if (\$sortorder==\"desc\")".
214                        "return ( \$a < \$b ) ? 1 : -1;".
215                "else if (\$sortorder==\"asc\")".
216                        "return ( \$a > \$b ) ? 1 : -1;" );
217
218        foreach( $jobs as $jobid => $jobattrs ) {
219
220                        $state = $jobattrs[status];
221                        $user = $jobattrs[owner];
222                        $queue = $jobattrs[queue];
223                        $name = $jobattrs[name];
224                        $req_cpu = $jobattrs[requested_time];
225                        $req_memory = $jobattrs[requested_memory];
226                        $nodes = count( $jobattrs[nodes] );
227                        $ppn = (int) $jobattrs[ppn] ? $jobattrs[ppn] : 1;
228                        $cpus = $nodes * $ppn;
229                        $start_time = (int) $jobattrs[start_timestamp];
230                        $runningtime = $report_time - $start_time;
231
232                        switch( $sortby ) {
233                                case "id":
234                                        $sorted[$jobid] = $jobid;
235                                        break;
236
237                                case "state":
238                                        $sorted[$jobid] = $state;
239                                        break;
240
241                                case "user":
242                                        $sorted[$jobid] = $user;
243                                        break;
244
245                                case "queue":
246                                        $sorted[$jobid] = $queue;
247                                        break;
248
249                                case "name":
250                                        $sorted[$jobid] = $name;
251                                        break;
252
253                                case "req_cpu":
254                                        $sorted[$jobid] = $req_cpu;
255                                        break;
256
257                                case "req_mem":
258                                        $sorted[$jobid] = $req_memory;
259                                        break;
260
261                                case "nodes":
262                                        $sorted[$jobid] = $nodes;
263                                        break;
264
265                                case "cpus":
266                                        $sorted[$jobid] = $cpus;
267                                        break;
268
269                                case "start":
270                                        $sorted[$jobid] = $start_time;
271                                        break;
272
273                                case "runningtime":
274                                        $sorted[$jobid] = $runningtime;
275                                        break;
276
277                                default:
278                                        break;
279
280                        }
281        }
282
283        uasort( $sorted, $cmp );
284
285        return $sorted;
286}
287
288function makeOverview() {
289
290        global $jobs, $nodes, $heartbeat, $clustername, $tpl;
291        global $sortorder, $sortby, $filter;
292
293        $tpl->assign("sortorder", $sortorder );
294        $tpl->assign("sortby", $sortby );
295
296        $sorted_jobs = sortJobs( $jobs, $sortby, $sortorder );
297
298        $even = 1;
299
300        foreach( $sorted_jobs as $jobid => $sortdec ) {
301
302                $report_time = $jobs[$jobid][reported];
303
304                if( $report_time == $heartbeat ) {
305
306                        if( count( $filter ) == 0 )
307                                $display_job = 1;
308                        else
309                                $display_job = 0;
310
311                        foreach( $filter as $filtername=>$filtervalue ) {
312
313                                if( $filtername == 'id' && $jobid == $filtervalue )
314                                        $display_job = 1;
315                                else if( $filtername == 'state' && $jobs[$jobid][status] == $filtervalue )
316                                        $display_job = 1;
317                                else if( $filtername == 'queue' && $jobs[$jobid][queue] == $filtervalue )
318                                        $display_job = 1;
319                                else if( $filtername == 'user' && $jobs[$jobid][owner] == $filtervalue )
320                                        $display_job = 1;
321                        }
322
323                        if( $display_job ) {
324
325                                $tpl->newBlock("node");
326                                $tpl->assign( "clustername", $clustername );
327                                $tpl->assign("id", $jobid );
328                                $tpl->assign("state", $jobs[$jobid][status] );
329                                $tpl->assign("user", $jobs[$jobid][owner] );
330                                $tpl->assign("queue", $jobs[$jobid][queue] );
331                                $tpl->assign("name", $jobs[$jobid][name] );
332                                $tpl->assign("req_cpu", $jobs[$jobid][requested_time] );
333                                $tpl->assign("req_memory", $jobs[$jobid][requested_memory] );
334                                $nodes = count( $jobs[$jobid][nodes] );
335                                $ppn = (int) $jobs[$jobid][ppn] ? $jobs[$jobid][ppn] : 1;
336                                $cpus = $nodes * $ppn;
337                                $tpl->assign("nodes", $nodes );
338                                $tpl->assign("cpus", $cpus );
339                                $start_time = (int) $jobs[$jobid][start_timestamp];
340
341                                if( $even ) {
342
343                                        $tpl->assign("nodeclass", "even");
344                                        $even = 0;
345                                } else {
346
347                                        $tpl->assign("nodeclass", "odd");
348                                        $even = 1;
349                                }
350
351                                if( $start_time ) {
352
353                                        $runningtime = makeTime( $report_time - $start_time );
354                                        $tpl->assign("started", makeDate( $start_time ) );
355                                        $tpl->assign("runningtime", $runningtime );
356                                }
357                        }
358                }
359        }
360}
361?>
Note: See TracBrowser for help on using the repository browser.