Context Navigation

source: branches/0.4/web/addons/job_monarch/search.php @ 803

Last change on this file since 803 was 780, checked in by ramonb, 11 years ago
another change to search
Property svn:keywords set to `Id`
File size: 16.5 KB

Rev	Line
[130]	1	<?php
[225]	2	/*
	3	*
	4	* This file is part of Jobmonarch
	5	*
[713]	6	* Copyright (C) 2006-2013 Ramon Bastiaans
[225]	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: search.php 780 2013-03-29 21:05:27Z ramonb $
[225]	23	*/
[130]	24
[776]	25	include_once "./dwoo/dwooAutoload.php";
[130]	26
[776]	27	global $dwoo;
	28
	29	global $clustername, $m, $metric;
	30
[138]	31	function validateFormInput() {
[776]	32	global $clustername, $dwoo, $id, $owner, $name, $start_from_time, $start_to_time, $queue;
	33	global $end_from_time, $end_to_time, $period_start, $period_stop, $tpl_data;
[138]	34
[778]	35	$error = false;
[716]	36	$error_msg = "<FONT COLOR=\"red\"><B>";
	37	$show_msg = 0;
[138]	38
[716]	39	$none_set = 0;
[138]	40
[716]	41	if( $id == '' and $owner== '' and $name == '' and $start_from_time == '' and $start_to_time == '' and $queue == '' and $end_from_time == '' and $end_to_time == '') {
[778]	42	$error = true;
[716]	43	$show_msg = 1;
	44	$error_msg .= "No search criteria set!";
	45	}
[138]	46
[716]	47	if( !$error and $period_start != '' )
[713]	48	{
[716]	49	$pstart_epoch = datetimeToEpoch( $period_start );
	50	if( $period_stop != '' )
[713]	51	{
[157]	52
[716]	53	$pstop_epoch = datetimeToEpoch( $period_stop );
[157]	54
[716]	55	if( $pstart_epoch > $pstop_epoch ) {
[157]	56
[716]	57	$show_msg = 1;
[778]	58	$error = true;
[716]	59	$error_msg .= "Graph timeperiod reset: start date/time can't be later than end";
	60	$period_stop = '';
	61	$period_start = '';
	62	} else if( $pstop_epoch == $pstart_epoch ) {
[157]	63
[716]	64	$show_msg = 1;
[778]	65	$error = true;
[716]	66	$error_msg .= "Graph timeperiod reset: start and end date/time can't be the same";
	67	$period_stop = '';
	68	$period_start = '';
	69	}
	70	}
	71	}
[157]	72
[716]	73	$error_msg .= "</B></FONT>";
[138]	74
[778]	75	return array( $error_msg, $error);
[138]	76	}
	77
[142]	78	function datetimeToEpoch( $datetime ) {
	79
[716]	80	$datetime_fields = explode( ' ', $datetime );
[142]	81
[716]	82	$date = $datetime_fields[0];
	83	$time = $datetime_fields[1];
[142]	84
[716]	85	$date_fields = explode( '-', $date );
[142]	86
[716]	87	$days = $date_fields[0];
	88	$months = $date_fields[1];
	89	$years = $date_fields[2];
[142]	90
[716]	91	$time_fields = explode( ':', $time );
[142]	92
[716]	93	$hours = $time_fields[0];
	94	$minutes = $time_fields[1];
	95	$seconds = $time_fields[2];
[142]	96
[716]	97	$timestamp = mktime( $hours, $minutes, $seconds, $months, $days, $years );
[142]	98
[716]	99	return $timestamp;
[142]	100	}
	101
[141]	102	function timeToEpoch( $time ) {
	103
	104	$time_fields = explode( ':', $time );
	105
	106	if( count($time_fields) == 3 ) {
	107
	108	$hours = $time_fields[0];
	109	$minutes = $time_fields[1];
	110	$seconds = $time_fields[2];
	111
	112	} else if( count($time_fields) == 2 ) {
	113
	114	$hours = 0;
	115	$minutes = $time_fields[0];
	116	$seconds = $time_fields[1];
	117
	118	} else if( count($time_fields) == 1 ) {
	119
	120	$hours = 0;
	121	$minutes = 0;
	122	$seconds = $time_fields[0];
	123	}
	124
	125	$myepoch = intval( $seconds + (intval( $minutes * 60 )) + (intval( $hours * 3600 )) );
	126
	127	return $myepoch;
	128	}
	129
[180]	130	function sortJobs( $jobs, $nodes, $sortby, $sortorder ) {
	131
	132	$sorted = array();
	133
	134	$cmp = create_function( '$a, $b',
	135	"global \$sortby, \$sortorder;".
	136
	137	"if( \$a == \$b ) return 0;".
	138
	139	"if (\$sortorder==\"desc\")".
	140	"return ( \$a < \$b ) ? 1 : -1;".
	141	"else if (\$sortorder==\"asc\")".
	142	"return ( \$a > \$b ) ? 1 : -1;" );
	143
	144	foreach( $jobs as $jobid => $jobattrs ) {
	145
[712]	146	$state = $jobattrs['status'];
	147	$owner = $jobattrs['owner'];
	148	$queue = $jobattrs['queue'];
	149	$name = $jobattrs['name'];
	150	$req_cpu = $jobattrs['requested_time'];
	151	$req_memory = $jobattrs['requested_memory'];
[180]	152
[712]	153	$mynodes = count( $nodes[$jobid] );
[180]	154
[712]	155	$ppn = (int) $jobattrs['ppn'] ? $jobattrs['ppn'] : 1;
[180]	156	$cpus = $mynodes * $ppn;
[712]	157	$start_time = (int) $jobattrs['start_timestamp'];
	158	$stop_time = (int) $jobattrs['stop_timestamp'];
[180]	159	$runningtime = $stop_time - $start_time;
	160
	161	switch( $sortby ) {
	162	case "id":
	163	$sorted[$jobid] = $jobid;
	164	break;
	165
	166	case "state":
	167	$sorted[$jobid] = $state;
	168	break;
	169
[711]	170	case "owner":
	171	$sorted[$jobid] = $owner;
[180]	172	break;
	173
	174	case "queue":
	175	$sorted[$jobid] = $queue;
	176	break;
	177
	178	case "name":
	179	$sorted[$jobid] = $name;
	180	break;
	181
	182	case "req_cpu":
	183	$sorted[$jobid] = timeToEpoch( $req_cpu );
	184	break;
	185
	186	case "req_mem":
	187	$sorted[$jobid] = $req_memory;
	188	break;
	189
	190	case "nodes":
	191	$sorted[$jobid] = $mynodes;
	192	break;
	193
	194	case "cpus":
	195	$sorted[$jobid] = $cpus;
	196	break;
	197
	198	case "start":
	199	$sorted[$jobid] = $start_time;
	200	break;
	201
[716]	202	case "finished":
	203	$sorted[$jobid] = $stop_time;
	204	break;
[181]	205
[180]	206	case "runningtime":
	207	$sorted[$jobid] = $runningtime;
	208	break;
	209
	210	default:
	211	break;
	212
	213	}
	214	}
	215
	216	if( $sortorder == "asc" )
	217	arsort( $sorted );
	218	else if( $sortorder == "desc" )
	219	asort( $sorted );
	220
	221	return array_keys( $sorted );
	222	}
	223
[130]	224	function makeSearchPage() {
[776]	225	global $clustername, $dwoo, $id, $owner, $name, $start_from_time, $start_to_time, $queue;
[716]	226	global $end_from_time, $end_to_time, $filter, $default_showhosts, $m, $hosts_up, $hc;
	227	global $period_start, $period_stop, $sortby, $sortorder, $COLUMN_REQUESTED_MEMORY;
	228	global $SEARCH_RESULT_LIMIT, $COLUMN_NODES, $metricname;
[130]	229
[716]	230	$longtitle = "Batch Archive Search :: Powered by Job Monarch!";
	231	$title = "Batch Archive Search";
[410]	232
[716]	233	makeHeader( 'search', $title, $longtitle );
[410]	234
[776]	235	$tpl = new Dwoo_Template_File("templates/search.tpl");
	236	$tpl_data = new Dwoo_Data();
[138]	237
[776]	238	$tpl_data->assign( "cluster", $clustername );
	239	$tpl_data->assign( "id_value", $id );
	240	$tpl_data->assign( "owner_value", $owner);
	241	$tpl_data->assign( "queue_value", $queue );
	242	$tpl_data->assign( "name_value", $name );
	243	$tpl_data->assign( "start_from_value", rawurldecode( $start_from_time ) );
	244	$tpl_data->assign( "start_to_value", rawurldecode( $start_to_time ) );
	245	$tpl_data->assign( "end_from_value", rawurldecode( $end_from_time ) );
	246	$tpl_data->assign( "end_to_value", rawurldecode( $end_to_time ) );
	247
[778]	248	list( $form_error_msg, $form_error ) = validateFormInput();
[138]	249
[778]	250	if( $form_error == true )
	251	{
	252	$tpl_data->assign( "form_error_msg", $form_error_msg );
	253	}
	254	else if( $form_error == false )
	255	{
[776]	256	$tpl_data->assign( "search_results", "yes" );
	257	$tpl_data->assign( "sortby", $sortby);
	258	$tpl_data->assign( "sortorder", $sortorder);
[716]	259	$tdb = new TarchDbase( "127.0.0.1" );
	260	if( $start_from_time ) $start_from_time = datetimeToEpoch( $start_from_time );
	261	if( $start_to_time ) $start_to_time = datetimeToEpoch( $start_to_time );
	262	if( $end_from_time ) $end_from_time = datetimeToEpoch( $end_from_time );
	263	if( $end_to_time ) $end_to_time = datetimeToEpoch( $end_to_time );
	264	$search_ids = $tdb->searchDbase( $id, $queue, $owner, $name, $start_from_time, $start_to_time, $end_from_time, $end_to_time );
[138]	265
[778]	266	//print_r( $search_ids );
[716]	267	if( ($tdb->resultcount) > (int) $SEARCH_RESULT_LIMIT ) {
[778]	268
[776]	269	$tpl_data->assign( "form_error_msg", "Got " . $tdb->resultcount . " search results, output limited to last " . $SEARCH_RESULT_LIMIT . " jobs." );
[716]	270	}
[248]	271
[716]	272	$jobs = array();
	273	$nodes = array();
[140]	274
[716]	275	$even = 1;
[237]	276
[716]	277	foreach( $search_ids as $myid ) {
[180]	278
[716]	279	$jobs[$myid] = $tdb->getJobArray( $myid );
	280	$nodes[$myid] = $tdb->getNodesForJob( $myid );
	281	}
[180]	282
[716]	283	if( $COLUMN_REQUESTED_MEMORY ) {
[776]	284	$tpl_data->assign( "column_header_req_mem", "yes" );
[716]	285	}
	286	if( $COLUMN_NODES ) {
[776]	287	$tpl_data->assign( "column_header_nodes", "yes" );
[716]	288	}
[247]	289
[716]	290	$sorted_search = sortJobs( $jobs, $nodes, $sortby, $sortorder );
[180]	291
[776]	292	$node_loop = array();
[716]	293	foreach( $sorted_search as $sortid ) {
[180]	294
[716]	295	$job = $jobs[$sortid];
	296	$foundid = $job['id'];
[180]	297
[776]	298	$node_list = array();
	299	$node_list["id"]= $job['id'];
	300	$node_list["state"]= $job['status'];
	301	$node_list["owner"]= $job['owner'];
	302	$node_list["queue"]= $job['queue'];
	303	$node_list["name"]= $job['name'];
	304	$node_list["req_cpu"]= makeTime( TimeToEpoch( $job['requested_time'] ) );
[141]	305
[780]	306	if( $COLUMN_REQUESTED_MEMORY )
	307	{
[776]	308	$node_list["column_req_mem"] = "yes";
	309	$node_list["req_memory"]= $job['requested_memory'];
[716]	310	}
[780]	311	if( $COLUMN_NODES)
	312	{
[247]	313
[716]	314	$job_nodes = array();
[356]	315
[716]	316	foreach( $nodes[$foundid] as $mynode )
[780]	317	{
	318	if( strpos( $mynode['hostname'], "." ) !== false )
	319	{
	320	$shorthost = explode( '.', $mynode['hostname'] );
	321	$job_nodes[] = $shorthost[0];
	322	}
	323	else
	324	{
	325	$job_nodes[] = $mynode['hostname'];
	326	}
	327	}
[299]	328
[780]	329	$node_list["column_nodes_hostnames"] = "yes";
[716]	330	$nodes_hostnames = implode( " ", $job_nodes );
[776]	331	$node_list["nodes_hostnames"]= $nodes_hostnames;
[716]	332	}
[299]	333
[716]	334	$nodes_nr = count( $nodes[$foundid] );
[145]	335
[716]	336	if( $even ) {
[237]	337
[776]	338	$node_list["nodeclass"]= "even";
[716]	339	$even = 0;
	340	} else {
[237]	341
[776]	342	$node_list["nodeclass"]= "odd";
[716]	343	$even = 1;
	344	}
[237]	345
[716]	346	$ppn = (int) $job['ppn'] ? $job['ppn'] : 1;
	347	$cpus = $nodes_nr * $ppn;
[141]	348
[776]	349	$node_list["nodes"]= $nodes_nr;
	350	$node_list["cpus"]= $cpus;
[141]	351
[716]	352	$job_start = $job['start_timestamp'];
	353	$job_stop = $job['stop_timestamp'];
	354	$runningtime = intval( $job_stop - $job_start );
[776]	355	$node_list["started"]= makeDate( $job_start );
	356	$node_list["finished"]= makeDate( $job_stop );
	357	$node_list["runningtime"]= makeTime( $runningtime );
[716]	358
[776]	359	$node_loop[]=$node_list;
[716]	360	}
[778]	361	//print_r( $node_loop );
	362	$tpl_data->assign("node_list", $node_loop );
[140]	363
[716]	364	if( count( $search_ids ) == 1 ) {
[140]	365
[776]	366	$tpl_data->assign( "showhosts", "yes" );
[143]	367
[716]	368	$showhosts = isset($sh) ? $sh : $default_showhosts;
[776]	369	$tpl_data->assign("checked$showhosts", "checked");
[143]	370
[716]	371	if( $showhosts ) {
[143]	372
[716]	373	if( !$period_start ) // Add an extra 10% to graphstart
	374	$period_start = intval( $job_start - (intval( $runningtime * 0.10 ) ) );
	375	else
	376	$period_start = datetimeToEpoch( $period_start );
[143]	377
[716]	378	if( !$period_stop ) // Add an extra 10% to graphend
	379	$period_stop = intval( $job_stop + (intval( $runningtime * 0.10 ) ) );
	380	else
	381	$period_stop = datetimeToEpoch( $period_stop );
[143]	382
[780]	383	$tpl_data->assign( "timeperiod", "yes" );
[189]	384
[780]	385	$tpl_data->assign("period_start", epochToDatetime( $period_start ) );
	386	$tpl_data->assign("period_stop", epochToDatetime( $period_stop ) );
[143]	387
[716]	388	$hosts_up = array();
[145]	389
[716]	390	foreach( $nodes[$id] as $mynode )
	391	$hosts_up[] = $mynode['hostname'];
[145]	392
[716]	393	$sorted_hosts = array();
[145]	394
[716]	395	foreach ($hosts_up as $host ) {
	396	$cpus = $metrics[$host]["cpu_num"]['VAL'];
	397	if (!$cpus) $cpus=1;
	398	$load_one = $metrics[$host]["load_one"]['VAL'];
	399	$load = ((float) $load_one)/$cpus;
	400	$host_load[$host] = $load;
	401	$percent_hosts['load_color'.($load)] += 1;
	402	if ($metricname=="load_one")
	403	$sorted_hosts[$host] = $load;
	404	else
	405	$sorted_hosts[$host] = $metrics[$host][$metricname]['VAL'];
	406	}
	407	switch ($sort) {
	408	case "descending":
	409	arsort($sorted_hosts);
	410	break;
	411	case "by hostname":
	412	ksort($sorted_hosts);
	413	break;
	414	default:
	415	case "ascending":
	416	asort($sorted_hosts);
	417	break;
	418	}
[143]	419
[716]	420	# First pass to find the max value in all graphs for this
	421	# metric. The $start,$end variables comes from get_context.php,
	422	# included in index.php.
	423	list($min, $max) = find_limits($sorted_hosts, $metricname);
[143]	424
[776]	425	$sorted_loop = array();
[716]	426	# Second pass to output the graphs or metrics.
	427	$i = 1;
	428	foreach ( $sorted_hosts as $host=>$value ) {
[776]	429	$sorted_list = array();
[716]	430	$host_url = rawurlencode($host);
	431	$cluster_url = rawurlencode($clustername);
[143]	432
[716]	433	$textval = "";
	434	$val = $metrics[$host][$metricname];
	435	$class = "metric";
	436	$host_link="\"?j_view=host&c=$cluster_url&h=$host_url&job_start=$job_start&job_stop=$job_stop&period_start=$period_start&period_stop=$period_stop\"";
[143]	437
[716]	438	if ($val['TYPE']=="timestamp" or $always_timestamp[$metricname]) {
	439	$textval = date("r", $val['VAL']);
	440	} elseif ($val['TYPE']=="string" or $val['SLOPE']=="zero" or $always_constant[$metricname] or ($max_graphs > 0 and $i > $max_graphs )) {
[776]	441	$textval = $val['VAL']." ".$val['UNITS'];
[716]	442	} else {
[780]	443	$graphargs = "z=medium&c=$cluster_url&m=$metricname&h=$host_url&v=".$val['VAL']."&x=$max&n=$min&job_start=$job_start&job_stop=$job_stop&period_start=$period_start&period_stop=$period_stop&min=$min&max=$max";
[716]	444	}
	445	if ($textval) {
	446	$cell="<td class=$class>". "<b><a href=$host_link>$host</a></b><br>". "<i>$metricname:</i> <b>$textval</b></td>";
	447	} else {
	448	$cell="<td><a href=$host_link>". "<img src=\"./graph.php?$graphargs\" ". "alt=\"$host\" border=0></a></td>";
	449	}
[143]	450
[776]	451	$sorted_list["metric_image"]= $cell;
[716]	452	if (! ($i++ % $hostcols) )
[776]	453	$sorted_list["br"]= "</tr><tr>";
	454
	455	$sorted_loop[]=$sorted_list;
[716]	456	}
[778]	457	$tpl_data->assign("sorted_list", $sorted_loop );
[716]	458	}
	459	}
[140]	460
[716]	461	}
[776]	462	$dwoo->output($tpl, $tpl_data);
[130]	463	}
	464	?>

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

Download in other formats: