source: trunk/web/addons/job_monarch/libtoga.php @ 231

Last change on this file since 231 was 231, checked in by bastiaans, 16 years ago

*.php:

  • added svn keywords propset
  • Property svn:keywords set to Id
File size: 22.1 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: libtoga.php 231 2006-03-10 16:36:38Z bastiaans $
23 *
24 */
25
26
27// If php is compiled without globals
28//
29//if ( !empty( $_GET ) ) {
30//        extract( $_GET );
31//}
32
33class HTTPVariables {
34
35        var $clustername, $metricname;
36        var $restvars, $httpvars;
37
38        function HTTPVariables( $httpvars, $getvars ) {
39
40                $this->restvars = array();
41
42                $this->clustername = $httpvars["c"] ? $httpvars["c"] : null;
43                $this->metricname = $httpvars["m"] ? $httpvars["m"] : null;
44
45                foreach( $httpvars as $httpvar => $httpval ) {
46                       
47                        if( $httpval ) {
48                                $this->restvars[$httpvar] = $httpval;
49                        }
50                }
51
52                foreach( $getvars as $getvar => $getval ) {
53
54                        if( $getval ) {
55                                $this->restvars[$getvar] = $getval;
56                        }
57                }
58        }
59
60        function getClusterName() {
61                return $this->clustername;
62        }
63
64        function getMetricName() {
65                return $this->metricname;
66        }
67
68        function getHttpVar( $var ) {
69                if( isset( $this->restvars[$var] ) )
70                        return $this->restvars[$var];
71                else
72                        return null;
73        }
74}
75
76// Toga's conf
77//
78include_once "./conf.php";
79include_once "./version.php";
80
81global $GANGLIA_PATH;
82global $RRDTOOL;
83global $JOB_ARCHIVE_DIR;
84global $JOB_ARCHIVE_DBASE;
85
86$my_dir = getcwd();
87
88// Load Ganglia's PHP
89chdir( $GANGLIA_PATH );
90
91include_once "./conf.php";
92include_once "./functions.php";
93include_once "./ganglia.php";
94include_once "./get_context.php";
95unset( $start );
96$context = 'cluster';
97include_once "./get_ganglia.php";
98
99// Back to our PHP
100chdir( $my_dir );
101
102global $SMALL_CLUSTERIMAGE_MAXWIDTH, $SMALL_CLUSTERIMAGE_NODEWIDTH, $DATA_SOURCE, $HTTP_GET_VARS, $_GET;
103$httpvars = new HTTPVariables( $HTTP_GET_VARS, $_GET );
104
105// Set cluster context so that Ganglia will
106// provide us with the correct metrics array
107//
108global $context, $clustername, $reports;
109
110//$clustername = $httpvars->getClusterName();
111
112global $default_metric;
113
114// Ganglia's array of host metrics
115//
116global $metrics, $hosts_up;
117
118class TarchDbase {
119
120        var $ip, $dbase, $conn;
121
122        function TarchDbase( $ip = null, $dbase = 'jobarch' ) {
123
124                global $JOB_ARCHIVE_DBASE;
125
126                $db_fields = explode( '/', $JOB_ARCHIVE_DBASE );
127
128                $this->ip = $db_fields[0];
129                $this->dbase = $db_fields[1];
130                $this->conn = null;
131        }
132
133        function connect() {
134
135                if( $this->ip == null and $this->dbase == 'toga' )
136                        $this->conn = pg_connect( "dbname=".$this->dbase );
137                else
138                        $this->conn = pg_connect( "host=".$this->ip." dbname=".$this->dbase );
139        }
140
141        function searchDbase( $id = null, $queue = null, $user = null, $name = null, $start_from_time = null, $start_to_time = null, $end_from_time = null, $end_to_time = null ) {
142
143                if( $id ) 
144                        $query = "SELECT job_id FROM jobs WHERE job_id = '$id' AND job_status = 'F'";
145                else {
146                        $query_args = array();
147                       
148                        if( $queue )
149                                $query_args[] = "job_queue ='$queue'";
150                        if( $user )
151                                $query_args[] = "job_owner ='$user'";
152                        if( $name )
153                                $query_args[] = "job_name = '$name'";
154                        if( $start_from_time )
155                                $query_args[] = "job_start_timestamp >= $start_from_time";
156                        if( $start_to_time )
157                                $query_args[] = "job_start_timestamp <= $start_to_time";
158                        if( $end_from_time )
159                                $query_args[] = "job_stop_timestamp >= $end_from_time";
160                        if( $end_to_time )
161                                $query_args[] = "job_stop_timestamp <= $end_to_time";
162
163                        $query = "SELECT job_id FROM jobs WHERE job_status = 'F' AND ";
164                        $extra_query_args = '';
165
166                        foreach( $query_args as $myquery ) {
167
168                                if( $extra_query_args == '' )
169                                        $extra_query_args = $myquery;
170                                else
171                                        $extra_query_args .= " AND ".$myquery;
172                        }
173                        $query .= $extra_query_args;
174                }
175
176                $ids = $this->queryDbase( $query );
177
178                $ret = array();
179
180                foreach( $ids as $crow)
181                        $ret[] = $crow[job_id];
182
183                return $ret;
184        }
185
186        function getNodesForJob( $jobid ) {
187
188                $result = $this->queryDbase( "SELECT node_id FROM job_nodes WHERE job_id = '$jobid'" );
189
190                $nodes = array();
191
192                foreach( $result as $result_row ) 
193
194                        $nodes[] = $this->getNodeArray( $result_row[node_id] );
195
196                return $nodes;
197        }
198
199        function getJobsForNode( $nodeid ) {
200
201                $result = $this->queryDbase( "SELECT job_id FROM job_nodes WHERE node_id = '$nodeid'" );
202
203                $jobs = array();
204
205                foreach( $result as $result_row )
206
207                        $jobs[] = $this->getJobArray( $result_row[job_id] );
208
209                return $jobs;
210        }
211
212        function getJobArray( $id ) {
213                $result = $this->queryDbase( "SELECT * FROM jobs WHERE job_id = '$id'" );
214
215                return ( $this->makeArray( $result[0] ) );
216        }
217
218        function getNodeArray( $id ) {
219
220                $result = $this->queryDbase( "SELECT * FROM nodes WHERE node_id = '$id'" );
221
222                return ( $this->makeArray( $result[0] ) );
223        }
224
225        function makeArray( $result_row ) {
226
227                $myar = array();
228
229                foreach( $result_row as $mykey => $myval ) {
230
231                        $map_key = explode( '_', $mykey );
232
233                        $rmap_key = array_reverse( $map_key );
234                        array_pop( $rmap_key );
235                        $map_key = array_reverse( $rmap_key );
236                       
237                        $newkey = implode( '_', $map_key );
238                       
239                        $myar[$newkey] = $result_row[$mykey];
240                }
241
242                return $myar;
243        }
244
245        function queryDbase( $query ) {
246
247                $result_rows = array();
248       
249                if( !$this->conn )
250                        $this->connect();
251
252                //printf( "query = [%s]\n", $query );
253                $result = pg_query( $this->conn, $query );
254
255                while ($row = pg_fetch_assoc($result))
256                        $result_rows[] = $row;
257
258                return $result_rows;
259        }
260}
261
262class TarchRrdGraph {
263        var $rrdbin, $rrdvalues, $clustername, $hostname, $tempdir, $tarchdir, $metrics;
264
265        function TarchRrdGraph( $clustername, $hostname ) {
266
267                global $RRDTOOL;
268                global $JOB_ARCHIVE_DIR;
269
270                $this->rrdbin = $RRDTOOL;
271                $this->rrdvalues = array();
272                $this->tarchdir = $JOB_ARCHIVE_DIR;
273                $this->clustername = $clustername;
274                $this->hostname = $hostname;
275        }
276
277        function doCmd( $command ) {
278
279                printf( "command = %s\n", $command );
280                $pipe = popen( $command . ' 2>&1', 'r' );
281
282                if (!$pipe) {
283                        print "pipe failed.";
284                        return "";
285                }
286
287                $output = '';
288                while(!feof($pipe))
289                        $output .= fread($pipe, 1024);
290
291                pclose($pipe);
292
293                $output = explode( "\n", $output );
294                //print_r( $output );
295                return $output;
296        }
297
298        function dirList( $dir ) {
299
300                $dirlist = array();
301
302                if ($handle = opendir( $dir )) {
303                        while (false !== ($file = readdir($handle))) {
304                                if ($file != "." && $file != "..") {
305                                        $dirlist[] = $file;
306                                }
307                        }
308                        closedir($handle);
309                }
310
311                return $dirlist;
312        }
313
314        function getTimePeriods( $start, $end ) {
315
316                //printf("start = %s end = %s\n", $start, $end );
317                $times = array();
318                $dirlist = $this->dirList( $this->tarchdir . '/' . $this->clustername . '/' . $this->hostname );
319
320                //print_r( $dirlist );
321
322                $first = 0;
323                $last = 9999999999999;
324
325                foreach( $dirlist as $dir ) {
326
327                        if( $dir > $first and $dir <= $start )
328                                $first = $dir;
329                        if( $dir < $last and $dir >= $end )
330                                $last = $dir;
331                }
332
333                //printf( "first = %s last = %s\n", $first, $last );
334
335                foreach( $dirlist as $dir ) {
336
337                        //printf( "dir %s ", $dir );
338
339                        if( $dir >= $first and $dir <= $last and !array_key_exists( $dir, $times ) ) {
340                       
341                                $times[] = $dir;
342                                //printf("newtime %s ", $dir );
343
344                        }
345                }
346
347                //print_r( $times );
348
349                sort( $times );
350
351                //print_r( $times );
352
353                return $times;
354        }
355
356        function getRrdDirs( $start, $stop ) {
357
358                //printf( "tarchdir = %s\n", $this->tarchdir );
359                $timess = $this->getTimePeriods( $start, $stop );
360                //print_r( $timess );
361
362                $rrd_files = array();
363
364                foreach( $timess as $time ) {
365
366                        $rrd_files[] = $this->tarchdir . '/' . $this->clustername . '/' . $this->hostname. '/'.$time;
367                }
368
369                return $rrd_files;
370        }
371
372        function getRrdFiles( $metric, $start, $stop ) {
373
374                $times = $this->getTimePeriods( $start, $stop );
375
376                $rrd_files = array();
377
378                foreach( $times as $time ) {
379
380                        $rrd_files[] = $this->tarchdir . '/' . $this->clustername . '/' . $this->hostname . '/' .$time. '/' . $metric. '.rrd';
381                }
382
383                return $rrd_files;
384        }
385
386        function graph( $descr ) {
387//      monitor2:/data/toga/rrds/LISA Cluster/gb-r15n11.irc.sara.nl# rrdtool graph /var/www/ganglia/test1.png --start 1118683231 --end 1118750431 --width 300 --height 400 DEF:'1'='./1118647515/load_one.rrd':'sum':AVERAGE DEF:'2'='./1118690723/load_one.rrd':'sum':AVERAGE DEF:'3'='./1118733925/load_one.rrd':'sum':AVERAGE AREA:1#555555:"load_one" AREA:2#555555 AREA:3#555555
388//      380x461
389//      monitor2:/data/toga/rrds/LISA Cluster/gb-r15n11.irc.sara.nl#
390                //$command = $this->rrdbin . " graph - --start $start --end $end ".
391                        "--width $width --height $height $upper_limit $lower_limit ".
392                        "--title '$title' $vertical_label $extras $background ". $series;
393
394                //$graph = $this->doCmd( $command );
395
396                //return $graph;
397                return 0;
398        }
399}
400
401class DataSource {
402
403        var $data, $ip, $port;
404
405        function DataSource( $ip = '127.0.0.1', $port = 8649 ) {
406                $this->ip = $ip;
407                $this->port = $port;
408        }
409
410        function getData() {
411
412                $errstr;
413                $errno = 0;
414                $timeout = 3;
415
416                $fp = fsockopen( $this->ip, $this->port, &$errno, &$errstr, $timeout );
417
418                if( !$fp ) {
419                        echo 'Unable to connect to '.$this->ip.':'.$this->port; // printf( 'Unable to connect to [%s:%.0f]', $this->ip, $this->port );
420                        return;
421                }
422
423                stream_set_timeout( $fp, 30 );
424
425                while ( !feof( $fp ) ) {
426                       
427                        $data .= fread( $fp, 16384 );
428                }
429
430                fclose( $fp );
431
432                return $data;
433        }
434}
435
436class DataGatherer {
437
438        var $xmlhandler, $data, $httpvars;
439
440        function DataGatherer( $cluster ) {
441
442                global $DATA_SOURCE;
443       
444                //printf("dg cluster = %s\n", $cluster );
445                $ds_fields = explode( ':', $DATA_SOURCE );
446                $ds_ip = $ds_fields[0];
447                $ds_port = $ds_fields[1];
448
449                $this->source = new DataSource( $ds_ip, $ds_port );
450
451                $this->parser = xml_parser_create();
452                $this->httpvars = $httpvars;
453                $this->xmlhandler = new TorqueXMLHandler( $cluster );
454                xml_set_element_handler( $this->parser, array( &$this->xmlhandler, 'startElement' ), array( &$this->xmlhandler, 'stopElement' ) );
455        }
456
457        function parseXML() {
458
459                $src = &$this->source;
460                $this->data = $src->getData();
461
462                if ( !xml_parse( &$this->parser, $this->data ) )
463                        $error = sprintf( 'XML error: %s at %d', xml_error_string( xml_get_error_code( &$this->parser ) ), xml_get_current_line_number( &$this->parser ) );
464        }
465
466        function printInfo() {
467                $handler = $this->xmlhandler;
468                $handler->printInfo();
469        }
470
471        function getNodes() {
472                $handler = $this->xmlhandler;
473                return $handler->getNodes();
474        }
475
476        function getCpus() {
477                $handler = $this->xmlhandler;
478                return $handler->getCpus();
479        }
480
481        function getJobs() {
482                $handler = $this->xmlhandler;
483                return $handler->getJobs();
484        }
485
486        function getHeartbeat() {
487                $handler = $this->xmlhandler;
488                return $handler->getHeartbeat();
489        }
490}
491
492class TorqueXMLHandler {
493
494        var $clusters, $heartbeat, $nodes, $jobs, $clustername, $proc_cluster;
495
496        function TorqueXMLHandler( $clustername ) {
497                $jobs = array();
498                $clusters = array();
499                $this->nodes = array();
500                $heartbeat = array();
501                $this->clustername = $clustername;
502                //printf(" cluster set to %s \n", $this->clustername );
503        }
504
505        function getCpus() {
506
507                $cpus = 0;
508
509                foreach( $this->jobs as $jobid=>$jobattrs ) {
510
511                        $nodes = count( $jobattrs[nodes] );
512                        $ppn = (int) $jobattrs[ppn] ? $jobattrs[ppn] : 1;
513                        $mycpus = $nodes * $ppn;
514
515                        $cpus = $cpus + $mycpus;
516                }
517        }
518
519        function startElement( $parser, $name, $attrs ) {
520
521                $jobs = &$this->jobs;
522                $nodes = &$this->nodes;
523
524                if ( $attrs[TN] ) {
525
526                        // Ignore dead metrics. Detect and mask failures.
527                        if ( $attrs[TN] > $attrs[TMAX] * 4 )
528                                return;
529                }
530
531                $jobid = null;
532
533                //printf( '%s=%s', $attrs[NAME], $attrs[VAL] );
534
535                //printf( "clustername = %s proc_cluster = %s\n", $this->clustername, $this->proc_cluster );
536
537                if( $name == 'CLUSTER' ) {
538
539                        $this->proc_cluster = $attrs[NAME];
540                        //printf( "Found cluster %s\n", $attrs[NAME] );
541                        //print_r( $attrs );
542
543                        //if( !isset( $clusters[$clustername] ) )
544                        //      $clusters[$clustername] = array();
545
546                } else if( $name == 'HOST' and $this->proc_cluster == $this->clustername) {
547
548                        $hostname = $attrs[NAME];
549                        $location = $attrs[LOCATION];
550                        //printf( "Found node %s\n", $hostname );
551
552                        if( !isset( $nodes[$hostname] ) )
553                                $nodes[$hostname] = new NodeImage( $hostname );
554
555                } else if( $name == 'METRIC' and strstr( $attrs[NAME], 'MONARCH' ) and $this->proc_cluster == $this->clustername ) {
556
557                        if( strstr( $attrs[NAME], 'MONARCH-HEARTBEAT' ) ) {
558
559                                $this->heartbeat['time'] = $attrs[VAL];
560                                //printf( "heartbeat %s\n", $heartbeat['time'] );
561
562                        } else if( strstr( $attrs[NAME], 'MONARCH-JOB' ) ) {
563
564                                sscanf( $attrs[NAME], 'MONARCH-JOB-%d', $jobid );
565
566                                //printf( "jobid %s\n", $jobid );
567
568                                if( !isset( $jobs[$jobid] ) )
569                                        $jobs[$jobid] = array();
570
571                                $fields = explode( ' ', $attrs[VAL] );
572
573                                foreach( $fields as $f ) {
574                                        $togavalues = explode( '=', $f );
575
576                                        $toganame = $togavalues[0];
577                                        $togavalue = $togavalues[1];
578
579                                        //printf( "\t%s\t= %s\n", $toganame, $togavalue );
580
581                                        if( $toganame == 'nodes' ) {
582
583                                                if( $jobs[$jobid][status] == 'R' ) {
584                                               
585                                                        if( !isset( $jobs[$jobid][$toganame] ) )
586                                                                $jobs[$jobid][$toganame] = array();
587
588                                                        $mynodes = explode( ';', $togavalue );
589
590                                                        foreach( $mynodes as $node )
591
592                                                                $jobs[$jobid][$toganame][] = $node;
593
594                                                } else if( $jobs[$jobid][status] == 'Q' ) {
595
596                                                        $jobs[$jobid][$toganame] = $togavalue;
597                                                }
598                                               
599                                        } else {
600
601                                                $jobs[$jobid][$toganame] = $togavalue;
602                                        }
603                                }
604
605                                if( isset( $jobs[$jobid][domain] ) and isset( $jobs[$jobid][nodes] ) ) {
606                       
607                                        $nr_nodes = count( $jobs[$jobid][nodes] );
608                       
609                                        foreach( $jobs[$jobid][nodes] as $node ) {
610
611                                                $domain = $jobs[$jobid][domain];
612                                                $domain_len = 0 - strlen( $domain );
613
614                                                if( substr( $node, $domain_len ) != $domain ) {
615                                                        $host = $node. '.'.$domain;
616                                                } else {
617                                                        $host = $node;
618                                                }
619
620                                                //$host = $node.'.'.$jobs[$jobid][domain];
621                               
622                                                if( !isset( $nodes[$host] ) )
623                                                        $my_node = new NodeImage( $host );
624                                                else
625                                                        $my_node = $nodes[$host];
626
627                                                if( !$my_node->hasJob( $jobid ) )
628
629                                                        if( isset( $jobs[$jobid][ppn] ) )
630                                                                $my_node->addJob( $jobid, ((int) $jobs[$jobid][ppn]) );
631                                                        else
632                                                                $my_node->addJob( $jobid, 1 );
633
634                                                $nodes[$host] = $my_node;
635                                        }
636                                }
637                        }
638                }
639                $this->jobs = $jobs;
640                //print_r( $nodes );
641                $this->nodes = $nodes;
642                //print_r( $this->nodes );
643        }
644
645        function stopElement( $parser, $name ) {
646        }
647
648        function printInfo() {
649
650                $jobs = &$this->jobs;
651
652                printf( "---jobs---\n" );
653
654                foreach( $jobs as $jobid => $job ) {
655
656                        printf( "job %s\n", $jobid );
657
658                        if( isset( $job[nodes] ) ) {
659
660                                foreach( $job[nodes] as $node ) {
661
662                                        $mynode = $this->nodes[$node];
663                                        $hostname = $mynode->getHostname();
664                                        $location = $mynode->getLocation();
665
666                                        printf( "\t- node %s\tlocation %s\n", $hostname, $location );
667                                        //$this->nodes[$hostname]->setLocation( "hier draait job ".$jobid );
668                                }
669                        }
670                }
671
672                printf( "---nodes---\n" );
673
674                $nodes = &$this->nodes;
675
676                foreach( $nodes as $node ) {
677
678                        $hostname = $node->getHostname();
679                        $location = $node->getLocation();
680                        $jobs = implode( ' ', $node->getJobs() );
681                        printf( "* node %s\tlocation %s\tjobs %s\n", $hostname, $location, $jobs );
682                }
683        }
684
685        function getNodes() {
686                //print_r( $this->nodes );
687                return $this->nodes;
688        }
689
690        function getJobs() {
691                return $this->jobs;
692        }
693
694        function getHeartbeat() {
695                return $this->heartbeat['time'];
696        }
697}
698
699class NodeImage {
700
701        var $image, $x, $y, $hostname, $jobs, $tasks, $showinfo;
702
703        function NodeImage( $hostname ) {
704
705                $this->jobs = array();
706                //$this->image = $image;
707                //$this->x = $x;
708                //$this->y = $y;
709                $this->tasks = 0;
710                $this->hostname = $hostname;
711                $this->cpus = $this->determineCpus();
712                $this->showinfo = 1;
713        }
714
715        function addJob( $jobid, $cpus ) {
716                $jobs = &$this->jobs;
717
718                $jobs[] = $jobid;
719                $this->jobs = $jobs;
720
721                $this->addTask( $cpus );
722        }
723
724        function hasJob( $jobid ) {
725
726                $jobfound = 0;
727
728                if( count( $this->jobs ) > 0 )
729                        foreach( $this->jobs as $job )
730
731                                if( $job == $jobid )
732                                        $jobfound = 1;
733
734                return $jobfound;
735        }
736
737        function addTask( $cpus ) {
738
739                $this->tasks = $this->tasks + $cpus;
740        }
741
742        function setImage( $image ) {
743
744                $this->image = $image;
745        }
746
747        function setCoords( $x, $y ) {
748
749                $this->x = $x;
750                $this->y = $y;
751        }
752
753        function colorHex( $color ) {
754       
755                $my_color = imageColorAllocate( $this->image, hexdec( substr( $color, 0, 2 )), hexdec( substr( $color, 2, 2 )), hexdec( substr( $color, 4, 2 )) );
756
757                return $my_color;
758        }
759
760        function setLoad( $load ) {
761                $this->load = $load;
762        }
763
764        function setHostname( $hostname ) {
765                $this->hostname = $hostname;
766        }
767
768        function getHostname() {
769                return $this->hostname;
770        }
771
772        function getJobs() {
773                return $this->jobs;
774        }
775
776        function setShowinfo( $showinfo ) {
777                $this->showinfo = $showinfo;
778        }
779
780        function draw() {
781
782                $this->drawSmall();
783        }
784
785        function drawBig() {
786
787        }
788
789        function drawSmall() {
790
791                global $SMALL_CLUSTERIMAGE_NODEWIDTH;
792                global $JOB_NODE_MARKING;
793
794                $black_color = imageColorAllocate( $this->image, 0, 0, 0 );
795                $size = $SMALL_CLUSTERIMAGE_NODEWIDTH;
796
797                imageFilledRectangle( $this->image, $this->x, $this->y, $this->x+($size), $this->y+($size), $black_color );
798
799                if( $this->showinfo) {
800               
801                        $this->load = $this->determineLoad();
802
803                        if( !isset( $this->image ) or !isset( $this->x ) or !isset( $this->y ) ) {
804                                printf( "aborting\n" );
805                                printf( "x %d y %d load %f\n", $this->x, $this->y, $load );
806                                return;
807                        }
808
809
810                        // Convert Ganglias Hexadecimal load color to a Decimal one
811                        //
812                        $load = $this->determineLoad(); 
813                        $usecolor = $this->colorHex( load_color($load) );
814                        imageFilledRectangle( $this->image, $this->x+1, $this->y+1, $this->x+($size-1), $this->y+($size-1), $usecolor );
815                        if( count( $this->jobs ) > 0 )
816                                imageString( $this->image, 1, $this->x+(($size/2)-2), $this->y+(($size/2)-3), $JOB_NODE_MARKING, $black_color );
817
818                } else {
819
820                        // White
821                        $usecolor = imageColorAllocate( $this->image, 255, 255, 255 );
822                        imageFilledRectangle( $this->image, $this->x+1, $this->y+1, $this->x+($size-1), $this->y+($size-1), $usecolor );
823                }
824
825
826        }
827
828        function determineCpus() {
829
830                global $metrics;
831
832                $cpus = $metrics[$this->hostname][cpu_num][VAL];
833                if (!$cpus) $cpus=1;
834
835                return $cpus;
836        }
837
838        function determineLoad() {
839
840                global $metrics;
841
842                $load_one = $metrics[$this->hostname][load_one][VAL];
843                $load = ((float) $load_one)/$this->cpus;
844
845                return $load;
846        }
847}
848
849class ClusterImage {
850
851        var $dataget, $image, $clustername;
852        var $filtername, $filters;
853
854        function ClusterImage( $clustername ) {
855
856                //printf( "image cluster = %s\n", $clustername );
857                $this->dataget = new DataGatherer( $clustername );
858                $this->clustername = $clustername;
859                $this->filters = array();
860        }
861
862        function setFilter( $filtername, $filtervalue ) {
863
864                //printf("filter %s = %s\n", $filtername, $filtervalue );
865                //printf( "filter set to %s = %s\n", $filtername, $filtervalue );
866                $this->filters[$filtername] = $filtervalue;
867                //print_r($this->filters);
868        }
869
870        function filterNodes( $jobs, $nodes ) {
871
872                $filtered_nodes = array();
873
874                foreach( $nodes as $node ) {
875
876                        $hostname = $node->getHostname();
877
878                        $addhost = 1;
879
880                        if( count( $this->filters ) > 0 ) {
881
882                                $mynjobs = $node->getJobs();
883
884                                if( count( $mynjobs ) > 0 ) {
885
886                                        foreach( $mynjobs as $myjob ) {
887
888                                                foreach( $this->filters as $filtername => $filtervalue ) {
889
890                                                        //printf("filter bla %s = %s\n", $filtername,$filtervalue );
891
892                                                        if( $filtername!=null && $filtername!='' ) {
893
894                                                                if( $filtername == 'jobid' && !$node->hasJob( $filtervalue) ) {
895                                                                        $addhost = 0;
896                                                                        //printf("host %s has no job %s\n", $hostname, $filtervalue);
897                                                                } else if( $filtername != 'jobid' ) {
898                                                                        //printf("myjob is %s\n", $myjob );
899                                                                        if( $jobs[$myjob][$filtername] != $filtervalue ) {
900                                                                                //printf("host %s has no job with %s=%s\n", $hostname, $filtername, $filtervalue);
901                                                                                $addhost = 0;
902                                                                        }
903                                                                }
904                                                        }
905                                                }
906                                        }
907                                } else
908                                        $addhost = 0;
909                        }
910
911                        if( $addhost )
912                                $filtered_nodes[] = $hostname;
913                }
914
915                return $filtered_nodes;
916        }
917
918        function draw() {
919
920                //printf("stopt met uitvoer");
921                //return;
922
923                global $SMALL_CLUSTERIMAGE_MAXWIDTH, $SMALL_CLUSTERIMAGE_NODEWIDTH;
924       
925                $mydatag = $this->dataget;
926                $mydatag->parseXML();
927
928                //$max_width = 250;
929                //$node_width = 11;
930
931                $max_width = $SMALL_CLUSTERIMAGE_MAXWIDTH;
932                $node_width = $SMALL_CLUSTERIMAGE_NODEWIDTH;
933
934                //printf( "cmaxw %s nmaxw %s", $SMALL_CLUSTERIMAGE_MAXWIDTH, $SMALL_CLUSTERIMAGE_NODEWIDTH );
935
936                $nodes = $mydatag->getNodes();
937                $nodes_hosts = array_keys( $nodes );
938
939                $nodes_nr = count( $nodes );
940
941                $nodes_size = $nodes_nr*$node_width;
942                $node_rows = 0;
943
944                if( $nodes_size > $max_width ) {
945                        $nodes_per_row = ( (int) ($max_width/$node_width) );
946                } else {
947                        $nodes_per_row = $nodes_size;
948                        $node_rows = 1;
949                }
950
951                if( $nodes_per_row < $nodes_nr ) {
952                        $node_rows = ( (int) ($nodes_nr/$nodes_per_row) );
953                        $node_rest = fmod( $nodes_nr, $nodes_per_row );
954                        //printf( "nodesnr %d noderest %f\n", $nodes_nr, $node_rest );
955                        if( $node_rest > 0 ) {
956                                $node_rows++;
957                                //printf( "noderows %d\n", $node_rows );
958                        }
959                }
960
961                //printf( "imagecreate: %dx%d", ($nodes_per_row*$node_width), ($node_rows*$node_width) );
962                //$image = imageCreateTrueColor( ($nodes_per_row*$node_width)+1, ($node_rows*$node_width)+1 );
963                $image = imageCreateTrueColor( $max_width, ($node_rows*$node_width)+1 );
964                $colorwhite = imageColorAllocate( $image, 255, 255, 255 );
965                imageFill( $image, 0, 0, $colorwhite );
966
967                $jobs = $mydatag->getJobs();
968                //printf("filtername = %s\n", $filtername );
969                $filtered_nodes = $this->filterNodes( $jobs, $nodes );
970
971                //print_r($filtered_nodes);
972
973                for( $n = 0; $n < $node_rows; $n++ ) {
974                       
975                        for( $m = 0; $m < $nodes_per_row; $m++ ) {
976                       
977                                $x = ($m * $node_width);
978                                $y = ($n * $node_width);
979
980                                $cur_node = ($n * $nodes_per_row) + ($m);
981                                $host = $nodes_hosts[$cur_node];
982
983
984                                if( isset( $nodes[$host] ) ) {
985
986                                        $nodes[$host]->setCoords( $x, $y );
987                                        $nodes[$host]->setImage( $image );
988
989                                        if( !in_array( $host, $filtered_nodes ) )
990                                                $nodes[$host]->setShowinfo( 0 );
991
992                                        $nodes[$host]->draw();
993                                }
994                        }
995                }
996               
997                header( 'Content-type: image/png' );
998                imagePNG( $image );
999                imageDestroy( $image );
1000        }
1001}
1002
1003//$my_data = new DataGatherer();
1004//$my_data->parseXML();
1005//$my_data->printInfo();
1006
1007//$ic = new ClusterImage( "LISA Cluster" );
1008//$ic->draw();
1009?>
Note: See TracBrowser for help on using the repository browser.