Context Navigation

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

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

overview.php:

changed na_nodes/cpus counting to use nodes objects: shorter now

Property svn:keywords set to Id

File size: 24.1 KB

Rev	Line
[113]	1	<?php
[225]	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	*
[231]	22	* SVN $Id: overview.php 516 2008-03-08 20:32:55Z bastiaans $
[225]	23	*/
	24
[126]	25	global $GANGLIA_PATH, $clustername, $tpl, $filter, $cluster, $get_metric_string, $cluster_url, $sh;
[299]	26	global $hosts_up, $m, $start, $end, $filterorder, $COLUMN_REQUESTED_MEMORY, $COLUMN_QUEUED, $COLUMN_NODES, $hostname, $piefilter;
[409]	27	global $longtitle, $title, $range;
[114]	28
[116]	29	$tpl->assign( "clustername", $clustername );
	30
[206]	31	if( $JOB_ARCHIVE )
[328]	32	{
[129]	33	$tpl->assign( "cluster_url", rawurlencode($clustername) );
[328]	34	}
[129]	35
[328]	36	$ds = new DataSource();
	37	$myxml_data = $ds->getData();
	38
	39	$data_gatherer = new DataGatherer( $clustername );
[326]	40	$data_gatherer->parseXML( $myxml_data );
[117]	41
[328]	42	$heartbeat = $data_gatherer->getHeartbeat();
	43	$jobs = $data_gatherer->getJobs();
	44	$gnodes = $data_gatherer->getNodes();
	45	$cpus = $data_gatherer->getCpus();
[463]	46	$use_fqdn = $data_gatherer->getUsingFQDN();
[114]	47
[328]	48	function setupFilterSettings()
	49	{
	50
[456]	51	global $tpl, $filter, $clustername, $piefilter, $data_gatherer, $myxml_data, $filterorder;
[122]	52
[263]	53	$filter_image_url = "";
[119]	54
[263]	55	$tpl->gotoBlock( "_ROOT" );
[122]	56
[328]	57	foreach( $filter as $filtername => $filtervalue )
	58	{
[263]	59	$tpl->assign( "f_".$filtername, $filtervalue );
[328]	60
	61	$filter_image_url .= "&$filtername=$filtervalue";
[263]	62	}
[114]	63
[326]	64	session_start();
	65
[406]	66	unset( $_SESSION["data"] );
[328]	67	$_SESSION["data"] = &$myxml_data;
	68
	69	$ic = new ClusterImage( $myxml_data, $clustername );
	70
[326]	71	$ic->setBig();
	72	$ic->setNoimage();
	73	$ic->draw();
	74
	75	$tpl->assign( "clusterimage", "./image.php?". session_name() . "=" . session_id() ."&c=".rawurlencode($clustername)."&view=big-clusterimage".$filter_image_url );
	76
[330]	77	//$tpl->assign( "clusterimage_width", $ic->getWidth() );
	78	//$tpl->assign( "clusterimage_height", $ic->getHeight() );
[326]	79
	80	$tpl->newBlock( "node_clustermap" );
	81	$tpl->assign( "node_area_map", $ic->getImagemapArea() );
	82	$tpl->gotoBlock( "_ROOT" );
	83
[263]	84	$tpl->assign( "f_order", $filterorder );
[114]	85
[328]	86	if( array_key_exists( "id", $filter ) )
	87	{
[263]	88	$piefilter = 'id';
[328]	89	}
	90	else if( array_key_exists( "user", $filter ) )
	91	{
[263]	92	$piefilter = 'user';
[328]	93	}
	94	else if( array_key_exists( "queue", $filter ) )
	95	{
[263]	96	$piefilter = 'queue';
[328]	97	}
[122]	98
[328]	99	$pie = drawPie();
	100
[263]	101	$tpl->assign("pie", $pie );
	102	}
[122]	103
[328]	104	function timeToEpoch( $time )
	105	{
	106	$time_fields = explode( ':', $time );
[120]	107
[328]	108	if( count( $time_fields ) == 3 )
	109	{
	110	$hours = $time_fields[0];
	111	$minutes = $time_fields[1];
	112	$seconds = $time_fields[2];
[120]	113
[328]	114	}
	115	else if( count( $time_fields ) == 2 )
	116	{
	117	$hours = 0;
	118	$minutes = $time_fields[0];
	119	$seconds = $time_fields[1];
[120]	120
[328]	121	}
	122	else if( count( $time_fields ) == 1 )
	123	{
	124	$hours = 0;
	125	$minutes = 0;
	126	$seconds = $time_fields[0];
[120]	127	}
[128]	128
[328]	129	$myepoch = intval( $seconds + (intval( $minutes * 60 )) + (intval( $hours * 3600 )) );
[128]	130
	131	return $myepoch;
[120]	132	}
	133
[328]	134	function colorRed( $color )
	135	{
[114]	136	return substr( $color, 0, 2 );
	137	}
[328]	138
	139	function colorGreen( $color )
	140	{
[114]	141	return substr( $color, 2, 2 );
	142	}
[328]	143
	144	function colorBlue( $color )
	145	{
[114]	146	return substr( $color, 4, 2 );
	147	}
	148
[328]	149	function colorDiffer( $first, $second )
	150	{
[114]	151	// Make sure these two colors differ atleast 50 R/G/B
	152	$min_diff = 50;
	153
[328]	154	$c1r = hexDec( colorRed( $first ) );
	155	$c1g = hexDec( colorGreen( $first ) );
	156	$c1b = hexDec( colorBlue( $first ) );
[114]	157
[328]	158	$c2r = hexDec( colorRed( $second ) );
	159	$c2g = hexDec( colorGreen( $second ) );
	160	$c2b = hexDec( colorBlue( $second ) );
[114]	161
[328]	162	$rdiff = ($c1r >= $c2r) ? $c1r - $c2r : $c2r - $c1r;
	163	$gdiff = ($c1g >= $c2g) ? $c1g - $c2g : $c2g - $c1g;
	164	$bdiff = ($c1b >= $c2b) ? $c1b - $c2b : $c2b - $c1b;
[114]	165
[328]	166	if( $rdiff >= $min_diff or $gdiff >= $min_diff or $bdiff >= $min_diff )
	167	{
[114]	168	return TRUE;
[328]	169
	170	}
	171	else
	172	{
[114]	173	return FALSE;
[328]	174	}
[114]	175	}
	176
[328]	177	function randomColor( $known_colors )
	178	{
	179	// White (000000) would be invisible
	180	$start = "004E00";
[147]	181
[328]	182	$start_red = colorRed( $start );
	183	$start_green = colorGreen( $start );
	184	$start_blue = colorBlue( $start );
[147]	185
[328]	186	$end = "FFFFFF";
[114]	187
[328]	188	$end_red = colorRed( $end );
	189	$end_green = colorGreen( $end );
	190	$end_blue = colorBlue( $end );
[114]	191
[328]	192	$change_color = TRUE;
[114]	193
[328]	194	while( $change_color )
	195	{
	196	$change_color = FALSE;
[114]	197
[328]	198	$new_red = rand( hexDec( $start_red ), hexDec( $end_red ) );
	199	$new_green = rand( hexDec( $start_green ), hexDec( $end_green ) );
	200	$new_blue = rand( hexDec( $start_blue ), hexDec( $end_blue ) );
[114]	201
[328]	202	$new = decHex( $new_red ) . decHex( $new_green ) . decHex( $new_blue );
[114]	203
[147]	204	foreach( $known_colors as $old )
[328]	205	{
[147]	206	if( !colorDiffer( $new, $old ) )
[328]	207	{
[147]	208	$change_color = TRUE;
[328]	209	}
	210	}
[114]	211	}
	212
	213	// Whoa! Actually found a good color ;)
[147]	214	return $new;
[114]	215	}
	216
[328]	217	// Code these some day
	218	function drawJobPie() { }
[114]	219
[328]	220	function drawUserPie() { }
[124]	221
[328]	222	function drawQueuePie() { }
[126]	223
	224
[328]	225	function drawPie()
	226	{
[315]	227	global $jobs, $gnodes, $piefilter, $filter, $metrics;
[114]	228
[315]	229	$nodes = $gnodes;
[127]	230
	231	if( isset($piefilter) )
[328]	232	{
[315]	233	$pie_args = "title=" . rawurlencode("Cluster ".$piefilter." usage");
[328]	234	}
	235	else
	236	{
[315]	237	$pie_args = "title=" . rawurlencode("Cluster queue usage");
[328]	238	}
	239
[315]	240	$pie_args .= "&size=250x150";
[114]	241
[315]	242	$queues = array();
	243	$nr_jobs = count( $jobs );
	244	$nr_nodes = count( $nodes );
[114]	245
[315]	246	$nr_cpus = cluster_sum("cpu_num", $metrics);
[114]	247
[315]	248	$empty_cpus = 0;
	249	$used_cpus = 0;
[123]	250
[315]	251	$job_weight = array();
	252
[328]	253	foreach( $nodes as $node )
	254	{
[315]	255	$myjobs = $node->getJobs();
	256	$myhost = $node->getHostname();
	257	$node_cpus = $metrics[$myhost]["cpu_num"][VAL];
	258	$job_cpu = 0;
[114]	259
[328]	260	foreach( $myjobs as $myjob )
	261	{
[315]	262	$job_cpu += (int) $jobs[$myjob][ppn] ? $jobs[$myjob][ppn] : 1;
	263	}
	264
	265	$node_freecpu = $node_cpus - $job_cpu;
	266
	267	$empty_cpus += $node_freecpu;
[114]	268	}
	269
[491]	270	$empty_cpus = ( $empty_cpus >= 0 ) ? $empty_cpus : 0;
[315]	271	$used_cpus = $nr_cpus - $empty_cpus;
[114]	272
[315]	273	$empty_percentage = ($empty_cpus / $nr_cpus) * 100;
[114]	274
[315]	275	$qcolors = array();
	276	$color = randomColor( $qcolors );
	277	$qcolors[] = $color;
	278	$pie_args .= "&free=$empty_percentage,$color";
	279
[127]	280	if( isset( $piefilter ) )
[328]	281	{
[127]	282	$filterpie = array();
[328]	283	}
[127]	284
[328]	285	foreach( $nodes as $node )
	286	{
[315]	287	$node_jobs = $node->getJobs();
	288	$nr_node_jobs = count( $node_jobs );
	289	$myhost = $node->getHostname();
	290	$node_cpus = $metrics[$myhost]["cpu_num"][VAL];
[114]	291
[328]	292	foreach( $node_jobs as $myjob )
	293	{
[315]	294	$job_cpu = (int) $jobs[$myjob][ppn] ? $jobs[$myjob][ppn] : 1;
	295
	296	// Determine the weight of this job
	297	// - what percentage of the cpus is in use by this job
[123]	298	//
[315]	299	$job_weight[$myjob] = ( $job_cpu / $nr_cpus );
[123]	300
[315]	301
[328]	302	if( isset( $piefilter ) ) {
	303
[127]	304	$countjob = 1;
[328]	305
	306	if( $piefilter == 'id' )
	307	{
[127]	308	if( $myjob != $filter[$piefilter] )
[328]	309	{
[127]	310	$countjob = 0;
[328]	311	}
	312	}
	313	else if( $piefilter == 'user' )
	314	{
[127]	315	if( $jobs[$myjob][owner] != $filter[$piefilter] )
[328]	316	{
[127]	317	$countjob = 0;
[328]	318	}
	319	}
	320	else
	321	{
[127]	322	if( $jobs[$myjob][$piefilter] != $filter[$piefilter] )
[328]	323	{
[127]	324	$countjob = 0;
[328]	325	}
[127]	326	}
	327
[328]	328	if( $countjob )
	329	{
[127]	330
	331	if( !isset( $filterpie[$filter[$piefilter]] ) )
[328]	332	{
[127]	333	$filterpie[$filter[$piefilter]] = $job_weight[$myjob];
[328]	334	}
[127]	335	else
[328]	336	{
	337
[127]	338	$filterpie[$filter[$piefilter]] = $filterpie[$filter[$piefilter]] + $job_weight[$myjob];
[328]	339	}
	340	}
	341	else
	342	{
[127]	343	if( !isset( $filterpie["other"] ) )
[328]	344	{
[127]	345	$filterpie["other"] = $job_weight[$myjob];
[328]	346	}
[127]	347	else
[328]	348	{
[127]	349	$filterpie["other"] = $filterpie["other"] + $job_weight[$myjob];
[328]	350	}
[127]	351
	352	}
	353
[328]	354	}
	355	else
	356	{
[127]	357
[315]	358	$qname = $jobs[$myjob][queue];
	359
[127]	360	if( !isset( $queues[$qname] ) )
[328]	361	{
[127]	362	$queues[$qname] = $job_weight[$myjob];
[328]	363	}
[127]	364	else
[328]	365	{
[127]	366	$queues[$qname] = $queues[$qname] + $job_weight[$myjob];
[328]	367	}
[127]	368	}
[114]	369	}
	370	}
	371
[127]	372	if( isset( $piefilter ) )
[328]	373	{
[127]	374	$graphvals = $filterpie;
[328]	375	}
[127]	376	else
[328]	377	{
[127]	378	$graphvals = $queues;
[328]	379	}
[114]	380
[328]	381	foreach( $graphvals as $name => $totalweight)
	382	{
[315]	383	$percentage = ( $totalweight * 100 );
[123]	384
[315]	385	$color = randomColor( $qcolors );
	386	$qcolors[] = $color;
	387	$pie_args .= "&$name=$percentage,$color";
[114]	388	}
	389	$pie = "../../pie.php?$pie_args";
	390
	391	return $pie;
	392	}
	393
	394
[328]	395	function sortJobs( $jobs, $sortby, $sortorder )
	396	{
	397	$sorted = array();
[114]	398
[328]	399	$cmp = create_function( '$a, $b',
[117]	400	"global \$sortby, \$sortorder;".
[116]	401
[117]	402	"if( \$a == \$b ) return 0;".
[116]	403
[117]	404	"if (\$sortorder==\"desc\")".
	405	"return ( \$a < \$b ) ? 1 : -1;".
	406	"else if (\$sortorder==\"asc\")".
	407	"return ( \$a > \$b ) ? 1 : -1;" );
	408
[328]	409	if( isset( $jobs ) && count( $jobs ) > 0 )
	410	{
	411	foreach( $jobs as $jobid => $jobattrs )
	412	{
	413	$state = $jobattrs[status];
	414	$user = $jobattrs[owner];
	415	$queue = $jobattrs[queue];
	416	$name = $jobattrs[name];
	417	$req_cpu = $jobattrs[requested_time];
	418	$req_memory = $jobattrs[requested_memory];
[117]	419
[301]	420	if( $state == 'R' )
[328]	421	{
[301]	422	$nodes = count( $jobattrs[nodes] );
[328]	423	}
[301]	424	else
[328]	425	{
[301]	426	$nodes = $jobattrs[nodes];
[328]	427	}
[117]	428
[328]	429	$ppn = (int) $jobattrs[ppn] ? $jobattrs[ppn] : 1;
	430	$cpus = $nodes * $ppn;
	431	$queued_time = (int) $jobattrs[queued_timestamp];
	432	$start_time = (int) $jobattrs[start_timestamp];
	433	$runningtime = $report_time - $start_time;
[117]	434
[328]	435	switch( $sortby )
	436	{
[301]	437	case "id":
	438	$sorted[$jobid] = $jobid;
	439	break;
[117]	440
[301]	441	case "state":
	442	$sorted[$jobid] = $state;
	443	break;
[117]	444
[301]	445	case "user":
	446	$sorted[$jobid] = $user;
	447	break;
[117]	448
[301]	449	case "queue":
	450	$sorted[$jobid] = $queue;
	451	break;
[117]	452
[301]	453	case "name":
	454	$sorted[$jobid] = $name;
	455	break;
[117]	456
[301]	457	case "req_cpu":
	458	$sorted[$jobid] = timeToEpoch( $req_cpu );
	459	break;
[117]	460
[301]	461	case "req_mem":
	462	$sorted[$jobid] = $req_memory;
	463	break;
[117]	464
[301]	465	case "nodes":
	466	$sorted[$jobid] = $nodes;
	467	break;
[117]	468
[301]	469	case "cpus":
	470	$sorted[$jobid] = $cpus;
	471	break;
[245]	472
[301]	473	case "queued":
	474	$sorted[$jobid] = $queued_time;
	475	break;
[117]	476
[301]	477	case "start":
	478	$sorted[$jobid] = $start_time;
	479	break;
[117]	480
[301]	481	case "runningtime":
	482	$sorted[$jobid] = $runningtime;
	483	break;
[117]	484
[301]	485	default:
	486	break;
	487	}
	488	}
	489	}
	490
[128]	491	if( $sortorder == "asc" )
[328]	492	{
[128]	493	arsort( $sorted );
[328]	494	}
[128]	495	else if( $sortorder == "desc" )
[328]	496	{
[128]	497	asort( $sorted );
[328]	498	}
[117]	499
	500	return $sorted;
	501	}
	502
[328]	503	function makeOverview()
	504	{
[117]	505	global $jobs, $nodes, $heartbeat, $clustername, $tpl;
[409]	506	global $sortorder, $sortby, $filter, $sh, $hc, $m, $range;
[126]	507	global $cluster_url, $get_metric_string, $host_url, $metrics;
[129]	508	global $start, $end, $reports, $gnodes, $default_showhosts;
[299]	509	global $COLUMN_QUEUED, $COLUMN_REQUESTED_MEMORY, $COLUMN_NODES, $hostname;
[463]	510	global $cluster, $use_fqdn;
[126]	511
[328]	512	$metricname = $m;
	513
[117]	514	$tpl->assign("sortorder", $sortorder );
	515	$tpl->assign("sortby", $sortby );
	516
[328]	517	$sorted_jobs = sortJobs( $jobs, $sortby, $sortorder );
[117]	518
[328]	519	$even = 1;
[118]	520
[328]	521	$used_jobs = 0;
	522	$used_cpus = 0;
	523	$used_nodes = 0;
[124]	524
[328]	525	$queued_jobs = 0;
	526	$queued_nodes = 0;
	527	$queued_cpus = 0;
[208]	528
[512]	529	$na_nodes = 0;
	530	$na_cpus = 0;
	531
[328]	532	$total_nodes = 0;
	533	$total_cpus = 0;
	534	$total_jobs = 0;
[208]	535
[328]	536	$all_used_nodes = array();
	537	$total_used_nodes = array();
[124]	538
[328]	539	$running_name_nodes = array();
[208]	540
[328]	541	$running_nodes = 0;
	542	$running_jobs = 0;
	543	$running_cpus = 0;
[208]	544
[328]	545	$avail_nodes = count( $gnodes );
	546	$avail_cpus = cluster_sum("cpu_num", $metrics);
[135]	547
[328]	548	$view_cpus = 0;
	549	$view_jobs = 0;
	550	$view_nodes = 0;
[135]	551
[328]	552	$all_nodes = 0;
	553	$all_jobs = 0;
	554	$all_cpus = 0;
[135]	555
[328]	556	$view_name_nodes = array();
[208]	557
[463]	558	// Is the "requested memory" column enabled in the config
	559	//
[328]	560	if( $COLUMN_REQUESTED_MEMORY )
	561	{
[242]	562	$tpl->newBlock( "column_header_req_mem" );
[241]	563	}
	564
[463]	565	// Is the "nodes hostnames" column enabled in the config
	566	//
[328]	567	if( $COLUMN_NODES )
	568	{
[299]	569	$tpl->newBlock( "column_header_nodes" );
	570	}
	571
[463]	572	// Is the "queued time" column enabled in the config
	573	//
[328]	574	if( $COLUMN_QUEUED )
	575	{
[242]	576	$tpl->newBlock( "column_header_queued" );
	577	}
	578
[328]	579	$last_displayed_job = null;
[263]	580
[416]	581	$rjqj_host = null;
[406]	582
[516]	583	$na_nodes = 0;
	584	$na_cpus = 0;
[512]	585
[416]	586	foreach( $metrics as $bhost => $bmetric )
	587	{
	588	foreach( $bmetric as $mname => $mval )
	589	{
	590	if( ( $mname == 'MONARCH-RJ' ) \|\| ($mname == 'MONARCH-QJ') )
	591	{
	592	$rjqj_host = $bhost;
	593	}
	594	}
	595	}
[409]	596
[516]	597	foreach( $gnodes as $ghost => $gnode )
[512]	598	{
[516]	599	if( $gnode->isDown() \|\| $gnode->isOffline() )
[512]	600	{
[516]	601	$na_nodes += 1;
	602	$na_cpus += $metrics[$ghost]['cpu_num']['VAL'];
[512]	603	}
	604	}
[516]	605
[463]	606	// Running / queued amount jobs graph
	607	//
[416]	608	if( $rjqj_host != null )
	609	{
[409]	610
[509]	611	$rjqj_str = "<A HREF=\"./graph.php?z=large&c=$clustername&g=job_report&r=$range&st=$cluster[LOCALTIME]\">";
	612	$rjqj_str .= "<IMG BORDER=0 SRC=\"./graph.php?z=small&c=$clustername&g=job_report&r=$range&st=$cluster[LOCALTIME]\">";
	613	$rjqj_str .= "</A>";
[416]	614
	615	$tpl->gotoBlock( "_ROOT" );
	616
	617	$tpl->assign( "rjqj_graph", $rjqj_str );
	618	}
	619
[328]	620	foreach( $sorted_jobs as $jobid => $sortdec )
	621	{
	622	$report_time = $jobs[$jobid][reported];
[117]	623
[208]	624	if( $jobs[$jobid][status] == 'R' )
[328]	625	{
[208]	626	$nodes = count( $jobs[$jobid][nodes] );
[328]	627	}
[208]	628	else if( $jobs[$jobid][status] == 'Q' )
[328]	629	{
[208]	630	$nodes = $jobs[$jobid][nodes];
[328]	631	}
[208]	632
[328]	633	$ppn = (int) $jobs[$jobid][ppn] ? $jobs[$jobid][ppn] : 1;
	634	$cpus = $nodes * $ppn;
[124]	635
[328]	636	if( $report_time == $heartbeat )
	637	{
	638	$display_job = 1;
[124]	639
[328]	640	if( $jobs[$jobid][status] == 'R' )
	641	{
	642	foreach( $jobs[$jobid][nodes] as $tempnode )
	643	{
[300]	644	$all_used_nodes[] = $tempnode;
	645	}
	646	}
[208]	647
[135]	648	$used_cpus += $cpus;
	649
[328]	650	if( $jobs[$jobid][status] == 'R' )
	651	{
	652	$running_cpus += $cpus;
	653
[208]	654	$running_jobs++;
[117]	655
[328]	656	$found_node_job = 0;
[268]	657
[328]	658	foreach( $jobs[$jobid][nodes] as $tempnode )
	659	{
[208]	660	$running_name_nodes[] = $tempnode;
[263]	661
[328]	662	if( isset( $hostname ) && $hostname != '' )
	663	{
[263]	664	//$filter[host] = $hostname;
	665
[328]	666	$domain_len = 0 - strlen( $jobs[$jobid][domain] );
	667	$hostnode = $tempnode;
	668
[463]	669	if( $use_fqdn == 1)
	670	{
	671	if( substr( $hostnode, $domain_len ) != $jobs[$jobid][domain] )
	672	{
	673	$hostnode = $hostnode. '.'. $jobs[$jobid][domain];
	674	}
	675	}
[263]	676
[328]	677	if( $hostname == $hostnode )
	678	{
[268]	679	$found_node_job = 1;
	680	$display_job = 1;
[328]	681	}
	682	else if( !$found_node_job )
	683	{
[263]	684	$display_job = 0;
[268]	685	}
[297]	686	}
[263]	687	}
[208]	688	}
[117]	689
[328]	690	if( $jobs[$jobid][status] == 'Q' )
	691	{
[263]	692	if( isset( $hostname ) && $hostname != '' )
[328]	693	{
[263]	694	$display_job = 0;
[328]	695	}
[263]	696
[328]	697	$queued_cpus += $cpus;
	698	$queued_nodes += $nodes;
	699
[208]	700	$queued_jobs++;
	701	}
	702
[328]	703	foreach( $filter as $filtername=>$filtervalue )
	704	{
[124]	705	if( $filtername == 'id' && $jobid != $filtervalue )
[328]	706	{
[124]	707	$display_job = 0;
[328]	708	}
[124]	709	else if( $filtername == 'state' && $jobs[$jobid][status] != $filtervalue )
[328]	710	{
[124]	711	$display_job = 0;
[328]	712	}
[124]	713	else if( $filtername == 'queue' && $jobs[$jobid][queue] != $filtervalue )
[328]	714	{
[124]	715	$display_job = 0;
[328]	716	}
[124]	717	else if( $filtername == 'user' && $jobs[$jobid][owner] != $filtervalue )
[328]	718	{
[124]	719	$display_job = 0;
[328]	720	}
[118]	721	}
	722
[328]	723	if( $display_job )
	724	{
	725	$tpl->newBlock( "node" );
[119]	726	$tpl->assign( "clustername", $clustername );
[328]	727	$tpl->assign( "id", $jobid );
[263]	728
[328]	729	$last_displayed_job = $jobid;
[263]	730
[328]	731	$tpl->assign( "state", $jobs[$jobid][status] );
[240]	732
[328]	733	$fullstate = '';
	734
	735	if( $jobs[$jobid][status] == 'R' )
	736	{
	737	$fullstate = "Running";
	738	}
	739	else if( $jobs[$jobid][status] == 'Q' )
	740	{
	741	$fullstate = "Queued";
[240]	742	}
	743
[328]	744	$tpl->assign( "fullstate", $fullstate );
[240]	745
[328]	746	$tpl->assign( "user", $jobs[$jobid][owner] );
	747	$tpl->assign( "queue", $jobs[$jobid][queue] );
[240]	748
[328]	749	$fulljobname = $jobs[$jobid][name];
	750	$shortjobname = '';
[240]	751
[328]	752	$tpl->assign( "fulljobname", $fulljobname );
[240]	753
[311]	754	$fulljobname_fields = explode( ' ', $fulljobname );
	755
[328]	756	$capjobname = 0;
[311]	757
	758	if( strlen( $fulljobname_fields[0] ) > 10 )
[328]	759	{
[311]	760	$capjobname = 1;
[328]	761	}
[311]	762
[328]	763	if( $capjobname )
	764	{
	765	$tpl->newBlock( "jobname_hint_start" );
	766	$tpl->gotoBlock( "node" );
[240]	767
[328]	768	$shortjobname = substr( $fulljobname, 0, 10 ) . '..';
	769	}
	770	else
	771	{
	772	$shortjobname = $fulljobname;
[240]	773	}
	774
[328]	775	$tpl->assign( "name", $shortjobname );
[240]	776
[328]	777	if( $capjobname )
	778	{
	779	$tpl->newBlock( "jobname_hint_end" );
	780	$tpl->gotoBlock( "node" );
[240]	781	}
	782
[328]	783	$domain = $jobs[$jobid][domain];
[135]	784
[328]	785	$tpl->assign( "req_cpu", makeTime( timeToEpoch( $jobs[$jobid][requested_time] ) ) );
	786
	787	if( $COLUMN_REQUESTED_MEMORY )
	788	{
[241]	789	$tpl->newBlock( "column_req_mem" );
	790	$tpl->assign( "req_memory", $jobs[$jobid][requested_memory] );
	791	$tpl->gotoBlock( "node" );
	792	}
[135]	793
[299]	794
[328]	795	if( $COLUMN_QUEUED )
	796	{
[242]	797	$tpl->newBlock( "column_queued" );
[243]	798	$tpl->assign( "queued", makeDate( $jobs[$jobid][queued_timestamp] ) );
[242]	799	$tpl->gotoBlock( "node" );
	800	}
[328]	801	if( $COLUMN_NODES )
	802	{
[322]	803	$tpl->newBlock( "column_nodes" );
	804	$tpl->gotoBlock( "node" );
	805	}
[242]	806
[328]	807	$ppn = (int) $jobs[$jobid][ppn] ? $jobs[$jobid][ppn] : 1;
	808	$cpus = $nodes * $ppn;
[119]	809
[328]	810	$tpl->assign( "nodes", $nodes );
	811	$tpl->assign( "cpus", $cpus );
	812
	813	$start_time = (int) $jobs[$jobid][start_timestamp];
	814	$job_start = $start_time;
	815
	816	$view_cpus += $cpus;
	817
[135]	818	$view_jobs++;
[124]	819
[328]	820	if( $jobs[$jobid][status] == 'R' )
	821	{
[135]	822	foreach( $jobs[$jobid][nodes] as $tempnode )
[328]	823	{
	824	$view_name_nodes[] = $tempnode;
	825	}
[299]	826
[328]	827	if( $COLUMN_NODES )
	828	{
[322]	829	$tpl->gotoBlock( "column_nodes" );
[328]	830
	831	$mynodehosts = array();
	832
	833	foreach( $jobs[$jobid][nodes] as $mynode )
	834	{
[463]	835	if( $use_fqdn == 1)
	836	{
	837	$mynode = $mynode.".".$jobs[$jobid][domain];
	838	}
[462]	839	$myhost_href = "./?c=".$clustername."&h=".$mynode;
[328]	840	$mynodehosts[] = "<A HREF=\"".$myhost_href."\">".$mynode."</A>";
[302]	841	}
[328]	842
	843	$nodes_hostnames = implode( " ", $mynodehosts );
	844
[299]	845	$tpl->assign( "nodes_hostnames", $nodes_hostnames );
	846	$tpl->gotoBlock( "node" );
	847	}
[328]	848	}
	849	else if( $jobs[$jobid][status] == 'Q' )
	850	{
	851	$view_nodes += (int) $jobs[$jobid][nodes];
[299]	852	}
[135]	853
[328]	854	if( $even )
	855	{
	856	$tpl->assign( "nodeclass", "even" );
[119]	857
[328]	858	$even = 0;
	859	}
	860	else
	861	{
	862	$tpl->assign( "nodeclass", "odd" );
[119]	863
[328]	864	$even = 1;
[119]	865	}
	866
[328]	867	if( $start_time )
	868	{
	869	$runningtime = makeTime( $report_time - $start_time );
[402]	870	//$job_runningtime = $report_time - $start_time;
	871	$job_runningtime = $heartbeat - $start_time;
[119]	872
[328]	873	$tpl->assign( "started", makeDate( $start_time ) );
	874	$tpl->assign( "runningtime", $runningtime );
[119]	875	}
[117]	876	}
[116]	877	}
[114]	878	}
[208]	879
[328]	880	$all_used_nodes = array_unique( $all_used_nodes );
	881	$view_name_nodes = array_unique( $view_name_nodes );
	882	$running_name_nodes = array_unique( $running_name_nodes );
[124]	883
[328]	884	$used_nodes = count( $all_used_nodes );
	885	$view_nodes += count( $view_name_nodes );
	886	$running_nodes += count( $running_name_nodes );
[208]	887
[328]	888	$total_nodes = $queued_nodes + $running_nodes;
	889	$total_cpus = $queued_cpus + $running_cpus;
	890	$total_jobs = $queued_jobs + $running_jobs;
[135]	891
[512]	892	$free_nodes = $avail_nodes - $running_nodes - $na_nodes;
[457]	893	$free_nodes = ( $free_nodes >= 0 ) ? $free_nodes : 0;
[512]	894	$free_cpus = $avail_cpus - $running_cpus - $na_cpus;
[457]	895	$free_cpus = ( $free_cpus >= 0 ) ? $free_cpus : 0;
[208]	896
[328]	897	$tpl->assignGlobal( "avail_nodes", $avail_nodes );
	898	$tpl->assignGlobal( "avail_cpus", $avail_cpus );
[208]	899
[328]	900	$tpl->assignGlobal( "queued_nodes", $queued_nodes );
	901	$tpl->assignGlobal( "queued_jobs", $queued_jobs );
	902	$tpl->assignGlobal( "queued_cpus", $queued_cpus );
[208]	903
[512]	904	$tpl->assignGlobal( "na_nodes", $na_nodes );
	905	$tpl->assignGlobal( "na_cpus", $na_cpus );
	906
[328]	907	$tpl->assignGlobal( "total_nodes", $total_nodes );
	908	$tpl->assignGlobal( "total_jobs", $total_jobs );
	909	$tpl->assignGlobal( "total_cpus", $total_cpus );
[135]	910
[328]	911	$tpl->assignGlobal( "running_nodes", $running_nodes );
	912	$tpl->assignGlobal( "running_jobs", $running_jobs );
	913	$tpl->assignGlobal( "running_cpus", $running_cpus );
[208]	914
[328]	915	$tpl->assignGlobal( "used_nodes", $used_nodes );
	916	$tpl->assignGlobal( "used_jobs", $used_jobs );
	917	$tpl->assignGlobal( "used_cpus", $used_cpus );
[208]	918
[328]	919	$tpl->assignGlobal( "free_nodes", $free_nodes );
	920	$tpl->assignGlobal( "free_cpus", $free_cpus );
[135]	921
[328]	922	$tpl->assignGlobal( "view_nodes", $view_nodes );
	923	$tpl->assignGlobal( "view_jobs", $view_jobs );
	924	$tpl->assignGlobal( "view_cpus", $view_cpus );
[126]	925
[328]	926	$tpl->assignGlobal( "report_time", makeDate( $heartbeat) );
	927
[266]	928	if( intval($view_jobs) == 1 and $start_time )
[328]	929	{
[266]	930	if( $last_displayed_job != null )
[328]	931	{
[266]	932	$filter[id] = $last_displayed_job;
[328]	933	}
	934	}
[263]	935
[406]	936	//print_r( $metrics );
[328]	937
[406]	938	global $longtitle, $title;
	939
	940	$longtitle = "Batch Report :: Powered by Job Monarch!";
	941	$title = "Batch Report";
	942
	943	makeHeader( 'overview', $title, $longtitle );
	944
[263]	945	setupFilterSettings();
	946
[328]	947	if( intval($view_jobs) == 1 and $start_time )
	948	{
[126]	949	$tpl->newBlock( "showhosts" );
	950
	951	# Present a width list
[328]	952	$cols_menu = "<SELECT NAME=\"hc\" OnChange=\"toga_form.submit();\">\n";
[126]	953
[328]	954	$hostcols = ($hc) ? $hc : 4;
[263]	955
[328]	956	foreach( range( 1, 25 ) as $cols )
	957	{
	958	$cols_menu .= "<OPTION VALUE=$cols ";
[126]	959
	960	if ($cols == $hostcols)
[328]	961	{
	962	$cols_menu .= "SELECTED";
	963	}
	964	$cols_menu .= ">$cols\n";
[126]	965	}
[328]	966	$cols_menu .= "</SELECT>\n";
[126]	967
[328]	968	$tpl->assign( "metric","$metricname $units" );
	969	$tpl->assign( "id", $filter[id] );
	970
[126]	971	# Host columns menu defined in header.php
[328]	972	$tpl->assign( "cols_menu", $cols_menu );
[126]	973
[328]	974	$showhosts = isset($sh) ? $sh : $default_showhosts;
[126]	975
[328]	976	$tpl->assign( "checked$showhosts", "checked" );
[126]	977
[328]	978	if( $showhosts )
	979	{
	980	if( !isset( $start ) )
	981	{
	982	$start ="jobstart";
	983	}
	984	if( !isset( $stop ) )
	985	{
	986	$stop ="now";
	987	}
[126]	988
[328]	989	$sorted_hosts = array();
	990	$hosts_up = $jobs[$filter[id]][nodes];
[126]	991
[402]	992	//printf( "r %s\n", $job_runningtime );
[126]	993
[402]	994	$r = intval($job_runningtime * 1.2);
[126]	995
[402]	996	//$jobrange = ($job_runningtime < 3600) ? -3600 : -$r ;
	997	$jobrange = -$r ;
	998	//$jobstart = $report_time - $job_runningtime;
	999	$jobstart = $start_time;
	1000
	1001	//printf( "jr %s\n", $jobrange );
	1002	//printf( "js %s\n", $jobstart);
	1003
[328]	1004	if ( $reports[$metricname] )
	1005	{
	1006	$metricval = "g";
	1007	}
[126]	1008	else
[328]	1009	{
	1010	$metricval = "m";
	1011	}
[263]	1012
[328]	1013	foreach ( $hosts_up as $host )
	1014	{
[463]	1015	$domain_len = 0 - strlen( $domain );
[195]	1016
[463]	1017	if( $use_fqdn )
	1018	{
	1019	if( substr( $host, $domain_len ) != $domain )
	1020	{
	1021	$host = $host . '.' . $domain;
	1022	}
	1023	}
[328]	1024
	1025	$cpus = $metrics[$host]["cpu_num"]["VAL"];
	1026
	1027	if ( !$cpus )
	1028	{
	1029	$cpus = 1;
	1030	}
	1031
	1032	$load_one = $metrics[$host]["load_one"][VAL];
	1033	$load = ((float) $load_one) / $cpus;
	1034	$host_load[$host] = $load;
	1035
	1036	$percent_hosts[load_color($load)] ++;
	1037
[126]	1038	if ($metricname=="load_one")
[328]	1039	{
	1040	$sorted_hosts[$host] = $load;
	1041	}
[126]	1042	else
[328]	1043	{
	1044	$sorted_hosts[$host] = $metrics[$host][$metricname][VAL];
	1045	}
[126]	1046	}
[463]	1047
[328]	1048	switch ( $sort )
	1049	{
[126]	1050	case "descending":
[328]	1051	arsort( $sorted_hosts );
[126]	1052	break;
[328]	1053
[126]	1054	case "by hostname":
[328]	1055	ksort( $sorted_hosts );
[126]	1056	break;
[328]	1057
[126]	1058	case "ascending":
[328]	1059	asort( $sorted_hosts );
[126]	1060	break;
[328]	1061
	1062	default:
	1063	break;
[126]	1064	}
	1065
[328]	1066	// First pass to find the max value in all graphs for this
	1067	// metric. The $start,$end variables comes from get_context.php,
	1068	// included in index.php.
	1069	//
[126]	1070	list($min, $max) = find_limits($sorted_hosts, $metricname);
	1071
[328]	1072	// Second pass to output the graphs or metrics.
[126]	1073	$i = 1;
	1074
[328]	1075	foreach ( $sorted_hosts as $host=>$value )
	1076	{
	1077	$tpl->newBlock( "sorted_list" );
[126]	1078
[328]	1079	$host_url = rawurlencode( $host );
	1080	$cluster_url = rawurlencode( $clustername );
[193]	1081
[328]	1082	$textval = "";
	1083
	1084	$val = $metrics[$host][$metricname];
	1085	$class = "metric";
	1086	$host_link = "\"../../?c=$cluster_url&h=$host_url&r=job&jr=$jobrange&js=$jobstart\"";
	1087
	1088	if ( $val["TYPE"] == "timestamp" \|\| $always_timestamp[$metricname] )
	1089	{
	1090	$textval = date( "r", $val["VAL"] );
	1091	}
	1092	elseif ( $val["TYPE"] == "string" \|\| $val["SLOPE"] == "zero" \|\| $always_constant[$metricname] \|\| ($max_graphs > 0 and $i > $max_graphs ))
	1093	{
	1094	$textval = $val["VAL"] . " " . $val["UNITS"];
	1095	}
	1096	else
	1097	{
	1098	$load_color = load_color($host_load[$host]);
	1099	$graphargs = ($reports[$metricname]) ? "g=$metricname&" : "m=$metricname&";
	1100	$graphargs .= "z=small&c=$cluster_url&h=$host_url&l=$load_color" . "&v=$val[VAL]&r=job&jr=$jobrange&js=$jobstart";
	1101	if( $max > 0 )
	1102	{
	1103	$graphargs .= "&x=$max&n=$min";
[193]	1104	}
[126]	1105	}
[328]	1106	if ($textval)
	1107	{
	1108	$cell = "<td class=$class>". "<b><a href=$host_link>$host</a></b><br>". "<i>$metricname:</i> <b>$textval</b></td>";
[126]	1109	} else {
[328]	1110	$cell = "<td><a href=$host_link>" . "<img src=\"../../graph.php?$graphargs\" " . "alt=\"$host\" border=0></a></td>";
[126]	1111	}
	1112
[328]	1113	$tpl->assign( "metric_image", $cell );
	1114
	1115	if(! ($i++ % $hostcols) )
	1116	{
	1117	$tpl->assign( "br", "</tr><tr>" );
	1118	}
[126]	1119	}
	1120	}
	1121	}
[114]	1122	}
[113]	1123	?>

Note: See TracBrowser for help on using the repository browser.

Download in other formats: