Context Navigation

source: trunk/gridctl.php@ 27

Last change on this file since 27 was 27, checked in by gegorbet, 8 years ago
fixes for ssh-airavata to jureca
File size: 29.5 KB

Rev	Line
[1]	1	<?php
	2
[25]	3	$us3bin = exec( "ls -d ~us3/lims/bin" );
	4	include_once "$us3bin/listen-config.php";
	5	//include "$us3bin/cleanup_aira.php";
	6	//include "$us3bin/cleanup_gfac.php";
	7
[1]	8	// Global variables
	9	$gfac_message = "";
	10	$updateTime = 0;
	11	$submittime = 0;
	12	$cluster = '';
	13
[6]	14	//global $self;
[18]	15	global $status_ex, $status_gw;
[6]	16
[1]	17	// Produce some output temporarily, so cron will send me message
	18	$now = time();
[6]	19	echo "Time started: " . date( 'Y-m-d H:i:s', $now ) . "\n";
[1]	20
	21	// Get data from global GFAC DB
	22	$gLink = mysql_connect( $dbhost, $guser, $gpasswd );
	23
	24	if ( ! mysql_select_db( $gDB, $gLink ) )
	25	{
[3]	26	write_log( "$self: Could not select DB $gDB - " . mysql_error() );
[1]	27	mail_to_admin( "fail", "Internal Error: Could not select DB $gDB" );
	28	exit();
	29	}
	30
	31	$query = "SELECT gfacID, us3_db, cluster, status, queue_msg, " .
	32	"UNIX_TIMESTAMP(time), time from analysis";
	33	$result = mysql_query( $query, $gLink );
	34
	35	if ( ! $result )
	36	{
	37	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	38	mail_to_admin( "fail", "Query failed $query\n" . mysql_error( $gLink ) );
	39	exit();
	40	}
	41
	42	if ( mysql_num_rows( $result ) == 0 )
[6]	43	{
	44	//write_log( "$self: analysis read got numrows==0" );
[1]	45	exit(); // Nothing to do
[6]	46	}
[1]	47
[14]	48	$me_devel = preg_match( "/class_devel/", $class_dir );
	49
[1]	50	while ( list( $gfacID, $us3_db, $cluster, $status, $queue_msg, $time, $updateTime )
	51	= mysql_fetch_array( $result ) )
	52	{
[14]	53	// If this entry does not match class/class_devel, skip processing
	54
	55	if ( preg_match( "/US3-A/i", $gfacID ) )
	56	{ // For thrift, job and gridctl must match
	57	$job_devel = preg_match( "/US3-ADEV/i", $gfacID );
	58	if ( ( $me_devel && !$job_devel ) \|\|
	59	( !$me_devel && $job_devel ) )
[25]	60	{ // Job type and Airavata server mismatch: skip processing
[14]	61	continue;
	62	}
	63	}
	64
[1]	65	// Checking we need to do for each entry
[6]	66	echo "us3db=$us3_db gfid=$gfacID\n";
	67	switch ( $us3_db )
	68	{
	69	case 'Xuslims3_cauma3' :
	70	case 'Xuslims3_cauma3d' :
	71	case 'Xuslims3_HHU' :
	72	case 'Xuslims3_Uni_KN' :
	73	$serviceURL = "http://gridfarm005.ucs.indiana.edu:9090/ogce-rest/job";
	74	break;
[1]	75
[6]	76	default :
	77	// $serviceURL = "http://gridfarm005.ucs.indiana.edu:8080/ogce-rest/job";
	78	break;
	79	}
	80
[25]	81	// $awork = array();
	82	// $awork = explode( "-", $gfacID );
	83	// $gfacLabl = $awork[0] . "-" . $awork[1] . "-" . $awork[2];
	84	$gfacLabl = $gfacID;
[6]	85	$loghdr = $self . ":" . $gfacLabl . "...:";
[17]	86	$status_ex = $status;
[6]	87
	88	// If entry is for Airvata/Thrift, get the true current status
	89
	90	if ( is_aira_job( $gfacID ) )
	91	{
	92	$status_in = $status;
[25]	93	//write_log( "$loghdr status_in=$status_in" );
[6]	94	$status = aira_status( $gfacID, $status_in );
	95	if($status != $status_in )
	96	write_log( "$loghdr Set to $status from $status_in" );
	97	}
[25]	98	else if ( is_gfac_job( $gfacID ) )
[6]	99	{
	100	$status_gw = $status;
	101	$status = get_gfac_status( $gfacID );
	102	//if ( $status == 'FINISHED' )
	103	if ( $status_gw == 'COMPLETE' )
	104	$status = $status_gw;
[25]	105	//write_log( "$loghdr non-AThrift status=$status status_gw=$status_gw" );
[6]	106	}
[25]	107	else
	108	{
	109	$status_gw = $status;
	110	$status = get_local_status( $gfacID );
	111	if ( $status_gw == 'COMPLETE' \|\| $status == 'UNKNOWN' )
	112	$status = $status_gw;
	113	//write_log( "$loghdr Local status=$status status_gw=$status_gw" );
	114	}
[6]	115
[1]	116	// Sometimes during testing, the us3_db entry is not set
	117	// If $status == 'ERROR' then the condition has been processed before
	118	if ( strlen( $us3_db ) == 0 && $status != 'ERROR' )
	119	{
[6]	120	write_log( "$loghdr GFAC DB is NULL - $gfacID" );
[1]	121	mail_to_admin( "fail", "GFAC DB is NULL\n$gfacID" );
	122
	123	$query2 = "UPDATE analysis SET status='ERROR' WHERE gfacID='$gfacID'";
	124	$result2 = mysql_query( $query2, $gLink );
	125	$status = 'ERROR';
	126
	127	if ( ! $result2 )
[6]	128	write_log( "$loghdr Query failed $query2 - " . mysql_error( $gLink ) );
[1]	129
	130	}
	131
[6]	132	//echo " st=$status\n";
[1]	133	switch ( $status )
	134	{
	135	// Already been handled
	136	// Later update this condition to search for gfacID?
	137	case "ERROR":
	138	cleanup();
	139	break;
	140
	141	case "SUBMITTED":
	142	submitted( $time );
	143	break;
	144
	145	case "SUBMIT_TIMEOUT":
	146	submit_timeout( $time );
	147	break;
	148
	149	case "RUNNING":
[6]	150	case "STARTED":
	151	case "STAGING":
	152	case "ACTIVE":
[1]	153	running( $time );
	154	break;
	155
	156	case "RUN_TIMEOUT":
	157	run_timeout($time );
	158	break;
	159
	160	case "DATA":
[6]	161	case "RESULTS_GEN":
[1]	162	wait_data( $time );
	163	break;
	164
	165	case "DATA_TIMEOUT":
	166	data_timeout( $time );
	167	break;
	168
[6]	169	case "COMPLETED":
[1]	170	case "COMPLETE":
[25]	171	write_log( "$loghdr COMPLETE gfacID=$gfacID" );
[1]	172	complete();
	173	break;
	174
	175	case "CANCELLED":
	176	case "CANCELED":
	177	case "FAILED":
	178	failed();
	179	break;
	180
[6]	181	case "FINISHED":
	182	case "DONE":
[26]	183	if ( ! is_aira_job( $gfacID ) )
[17]	184	{
[25]	185	complete();
[17]	186	}
[25]	187	write_log( "$loghdr FINISHED gfacID=$gfacID" );
[6]	188	case "PROCESSING":
[1]	189	default:
	190	break;
	191	}
	192	}
	193
	194	exit();
	195
	196	function submitted( $updatetime )
	197	{
	198	global $self;
	199	global $gLink;
	200	global $gfacID;
[6]	201	global $loghdr;
[1]	202
	203	$now = time();
	204
	205	if ( $updatetime + 600 > $now ) return; // < 10 minutes ago
	206
	207	if ( $updatetime + 86400 > $now ) // Within the first 24 hours
	208	{
	209	if ( ( $job_status = get_gfac_status( $gfacID ) ) === false )
	210	$job_status = get_local_status( $gfacID );
	211
	212	if ( $job_status == 'GFAC_STATUS_UNAVAILABLE' )
	213	return;
	214
	215	if ( ! in_array( $job_status, array( 'SUBMITTED', 'INITIALIZED', 'PENDING' ) ) )
[6]	216	{
[25]	217	write_log( "$loghdr submitted:job_status=$job_status" );
[1]	218	update_job_status( $job_status, $gfacID );
[6]	219	}
[1]	220
	221	return;
	222	}
	223
	224	$message = "Job listed submitted longer than 24 hours";
	225	write_log( "$self: $message - id: $gfacID" );
	226	mail_to_admin( "hang", "$message - id: $gfacID" );
	227	$query = "UPDATE analysis SET status='SUBMIT_TIMEOUT' WHERE gfacID='$gfacID'";
	228	$result = mysql_query( $query, $gLink );
	229
	230	if ( ! $result )
	231	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	232
	233	update_queue_messages( $message );
	234	update_db( $message );
	235	}
	236
	237	function submit_timeout( $updatetime )
	238	{
	239	global $self;
	240	global $gLink;
	241	global $gfacID;
[6]	242	global $loghdr;
[1]	243
	244	if ( ( $job_status = get_gfac_status( $gfacID ) ) === false )
	245	$job_status = get_local_status( $gfacID );
	246
	247	if ( $job_status == 'GFAC_STATUS_UNAVAILABLE' )
	248	return;
	249
	250	if ( ! in_array( $job_status, array( 'SUBMITTED', 'INITIALIZED', 'PENDING' ) ) )
	251	{
	252	update_job_status( $job_status, $gfacID );
	253	return;
	254	}
	255
	256	$now = time();
	257
	258	if ( $updatetime + 86400 > $now ) return; // < 24 hours ago ( 48 total submitted )
	259
	260	$message = "Job listed submitted longer than 48 hours";
	261	write_log( "$self: $message - id: $gfacID" );
	262	mail_to_admin( "hang", "$message - id: $gfacID" );
	263	$query = "UPDATE analysis SET status='FAILED' WHERE gfacID='$gfacID'";
	264	$result = mysql_query( $query, $gLink );
	265
	266	if ( ! $result )
	267	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	268
	269	update_queue_messages( $message );
	270	update_db( $message );
	271	}
	272
	273	function running( $updatetime )
	274	{
	275	global $self;
	276	global $gLink;
	277	global $gfacID;
[6]	278	global $loghdr;
[1]	279
	280	$now = time();
	281
	282	get_us3_data();
	283
	284	if ( $updatetime + 600 > $now ) return; // message received < 10 minutes ago
	285
	286	if ( $updatetime + 86400 > $now ) // Within the first 24 hours
	287	{
	288	if ( ( $job_status = get_gfac_status( $gfacID ) ) === false )
	289	$job_status = get_local_status( $gfacID );
	290
	291	if ( $job_status == 'GFAC_STATUS_UNAVAILABLE' )
	292	return;
	293
[6]	294	if ( ! in_array( $job_status, array( 'ACTIVE', 'RUNNING', 'STARTED' ) ) )
[1]	295	update_job_status( $job_status, $gfacID );
	296
	297	return;
	298	}
	299
	300	$message = "Job listed running longer than 24 hours";
	301	write_log( "$self: $message - id: $gfacID" );
	302	mail_to_admin( "hang", "$message - id: $gfacID" );
	303	$query = "UPDATE analysis SET status='RUN_TIMEOUT' WHERE gfacID='$gfacID'";
	304	$result = mysql_query( $query, $gLink );
	305
	306	if ( ! $result )
	307	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	308
	309	update_queue_messages( $message );
	310	update_db( $message );
	311	}
	312
	313	function run_timeout( $updatetime )
	314	{
	315	global $self;
	316	global $gLink;
	317	global $gfacID;
[6]	318	global $loghdr;
[1]	319
	320	if ( ( $job_status = get_gfac_status( $gfacID ) ) === false )
	321	$job_status = get_local_status( $gfacID );
	322
	323	if ( $job_status == 'GFAC_STATUS_UNAVAILABLE' )
	324	return;
	325
[6]	326	if ( ! in_array( $job_status, array( 'ACTIVE', 'RUNNING', 'STARTED' ) ) )
[1]	327	{
	328	update_job_status( $job_status, $gfacID );
	329	return;
	330	}
	331
	332	$now = time();
	333
	334	get_us3_data();
	335
	336	if ( $updatetime + 172800 > $now ) return; // < 48 hours ago
	337
	338	$message = "Job listed running longer than 48 hours";
	339	write_log( "$self: $message - id: $gfacID" );
	340	mail_to_admin( "hang", "$message - id: $gfacID" );
	341	$query = "UPDATE analysis SET status='FAILED' WHERE gfacID='$gfacID'";
	342	$result = mysql_query( $query, $gLink );
	343
	344	if ( ! $result )
	345	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	346
	347	update_queue_messages( $message );
	348	update_db( $message );
	349	}
	350
	351	function wait_data( $updatetime )
	352	{
	353	global $self;
	354	global $gLink;
	355	global $gfacID;
[6]	356	global $loghdr;
[1]	357
	358	$now = time();
	359
	360	if ( $updatetime + 3600 > $now ) // < Within the first hour
	361	{
	362	if ( ( $job_status = get_gfac_status( $gfacID ) ) === false )
	363	$job_status = get_local_status( $gfacID );
	364
	365	if ( $job_status == 'GFAC_STATUS_UNAVAILABLE' )
	366	return;
	367
	368	if ( $job_status != 'DATA' )
	369	{
	370	update_job_status( $job_status, $gfacID );
	371	return;
	372	}
	373
	374	// Request to resend data, but only request every 5 minutes
	375	$minute = date( 'i' ) * 1; // Makes it an int
	376	if ( $minute % 5 ) return;
	377
	378	$output_status = get_gfac_outputs( $gfacID );
	379
	380	if ( $output_status !== false )
	381	mail_to_admin( "debug", "wait_data/$gfacID/$output_status" );
	382
	383	return;
	384	}
	385
	386	$message = "Waiting for data longer than 1 hour";
	387	write_log( "$self: $message - id: $gfacID" );
	388	mail_to_admin( "hang", "$message - id: $gfacID" );
	389	$query = "UPDATE analysis SET status='DATA_TIMEOUT' WHERE gfacID='$gfacID'";
	390	$result = mysql_query( $query, $gLink );
	391
	392	if ( ! $result )
	393	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	394
	395	update_queue_messages( $message );
	396	update_db( $message );
	397	}
	398
	399	function data_timeout( $updatetime )
	400	{
	401	global $self;
	402	global $gLink;
	403	global $gfacID;
[6]	404	global $loghdr;
[1]	405
	406	if ( ( $job_status = get_gfac_status( $gfacID ) ) === false )
	407	$job_status = get_local_status( $gfacID );
	408
	409	if ( $job_status == 'GFAC_STATUS_UNAVAILABLE' )
	410	return;
	411
	412	if ( $job_status != 'DATA' )
	413	{
	414	update_job_status( $job_status, $gfacID );
	415	return;
	416	}
	417
	418	$now = time();
	419
	420	if ( $updatetime + 86400 > $now ) // < 24 hours ago
	421	{
	422	// Request to resend data, but only request every 15 minutes
	423	$minute = date( 'i' ) * 1; // Makes it an int
	424	if ( $minute % 15 ) return;
	425
	426	$output_status = get_gfac_outputs( $gfacID );
	427
	428	if ( $output_status !== false )
	429	mail_to_admin( "debug", "data_timeout/$gfacID/$output_status" );
	430
	431	return;
	432	}
	433
	434	$message = "Waiting for data longer than 24 hours";
	435	write_log( "$self: $message - id: $gfacID" );
	436	mail_to_admin( "hang", "$message - id: $gfacID" );
	437	$query = "UPDATE analysis SET status='FAILED' WHERE gfacID='$gfacID'";
	438	$result = mysql_query( $query, $gLink );
	439
	440	if ( ! $result )
	441	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	442
	443	update_queue_messages( $message );
	444	update_db( $message );
	445	}
	446
	447	function complete()
	448	{
	449	// Just cleanup
	450	cleanup();
	451	}
	452
	453	function failed()
	454	{
	455	// Just cleanup
	456	cleanup();
	457	}
	458
	459	function cleanup()
	460	{
	461	global $self;
	462	global $gLink;
	463	global $gfacID;
	464	global $us3_db;
[6]	465	global $loghdr;
[26]	466	global $class_dir;
[1]	467
	468	// Double check that the gfacID exists
	469	$query = "SELECT count(*) FROM analysis WHERE gfacID='$gfacID'";
	470	$result = mysql_query( $query, $gLink );
	471
	472	if ( ! $result )
	473	{
	474	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	475	mail_to_admin( "fail", "Query failed $query\n" . mysql_error( $gLink ) );
	476	return;
	477	}
	478
	479	list( $count ) = mysql_fetch_array( $result );
	480
[6]	481	if ($count==0)
	482	write_log( "$loghdr count = $count gfacID = $gfacID" );
[1]	483	if ( $count == 0 ) return;
	484
	485	// Now check the us3 instance
	486	$requestID = get_us3_data();
[6]	487	//write_log( "$loghdr requestID = $requestID gfacID = $gfacID" );
[1]	488	if ( $requestID == 0 ) return;
	489
[14]	490	$me_devel = preg_match( "/class_devel/", $class_dir );
[25]	491	$me_local = preg_match( "/class_local/", $class_dir );
[14]	492
[10]	493	if ( preg_match( "/US3-A/i", $gfacID ) )
[6]	494	{
[10]	495	$job_devel = preg_match( "/US3-ADEV/i", $gfacID );
	496	if ( ( !$me_devel && !$job_devel ) \|\|
	497	( $me_devel && $job_devel ) )
[25]	498	{ // Job is of same type (prod/devel) as Server: process it
[6]	499	//write_log( "$loghdr CALLING aira_cleanup()" );
[10]	500	aira_cleanup( $us3_db, $requestID, $gLink );
	501	}
[6]	502	//write_log( "$loghdr RTN FR aira_cleanup()" );
	503	}
[25]	504	else if ( ! $me_local )
	505	{
	506	write_log( "$loghdr CALLING gfac_cleanup() reqID=$requestID" );
[6]	507	gfac_cleanup( $us3_db, $requestID, $gLink );
	508	}
[1]	509	}
	510
	511	// Function to update status of job
	512	function update_job_status( $job_status, $gfacID )
	513	{
	514	global $gLink;
[6]	515	global $query;
	516	global $self;
	517	global $loghdr;
[1]	518
	519	switch ( $job_status )
	520	{
	521	case 'SUBMITTED' :
	522	case 'SUBMITED' :
	523	case 'INITIALIZED' :
[25]	524	case 'UPDATING' :
	525	case 'PENDING' :
[1]	526	$query = "UPDATE analysis SET status='SUBMITTED' WHERE gfacID='$gfacID'";
[25]	527	$message = "Job status request reports job is SUBMITTED";
[1]	528	break;
	529
[6]	530	case 'STARTED' :
	531	case 'RUNNING' :
[1]	532	case 'ACTIVE' :
	533	$query = "UPDATE analysis SET status='RUNNING' WHERE gfacID='$gfacID'";
	534	$message = "Job status request reports job is RUNNING";
	535	break;
	536
[6]	537	case 'FINISHED' :
	538	$query = "UPDATE analysis SET status='FINISHED' WHERE gfacID='$gfacID'";
	539	$message = "NONE";
	540	break;
	541
	542	case 'DONE' :
	543	$query = "UPDATE analysis SET status='DONE' WHERE gfacID='$gfacID'";
	544	$message = "NONE";
	545	break;
	546
[1]	547	case 'COMPLETED' :
[6]	548	case 'COMPLETE' :
[1]	549	$query = "UPDATE analysis SET status='COMPLETE' WHERE gfacID='$gfacID'";
[6]	550	$message = "Job status request reports job is COMPLETED";
[1]	551	break;
	552
[6]	553	case 'DATA' :
[1]	554	$query = "UPDATE analysis SET status='DATA' WHERE gfacID='$gfacID'";
	555	$message = "Job status request reports job is COMPLETE, waiting for data";
	556	break;
	557
	558	case 'CANCELED' :
[6]	559	case 'CANCELLED' :
[1]	560	$query = "UPDATE analysis SET status='CANCELED' WHERE gfacID='$gfacID'";
	561	$message = "Job status request reports job is CANCELED";
	562	break;
	563
	564	case 'FAILED' :
	565	$query = "UPDATE analysis SET status='FAILED' WHERE gfacID='$gfacID'";
	566	$message = "Job status request reports job is FAILED";
	567	break;
	568
	569	case 'UNKNOWN' :
[6]	570	write_log( "$loghdr job_status='UNKNOWN', reset to 'ERROR' " );
	571	$query = "UPDATE analysis SET status='ERROR' WHERE gfacID='$gfacID'";
[1]	572	$message = "Job status request reports job is not in the queue";
	573	break;
	574
	575	default :
[3]	576	// We shouldn't ever get here
[6]	577	$query = "UPDATE analysis SET status='ERROR' WHERE gfacID='$gfacID'";
[1]	578	$message = "Job status was not recognized - $job_status";
[6]	579	write_log( "$loghdr update_job_status: " .
[3]	580	"Job status was not recognized - $job_status\n" .
	581	"gfacID = $gfacID\n" );
[1]	582	break;
	583
	584	}
	585
	586	$result = mysql_query( $query, $gLink );
	587	if ( ! $result )
[6]	588	write_log( "$loghdr Query failed $query - " . mysql_error( $gLink ) );
[1]	589
[6]	590	if ( $message != 'NONE' )
	591	{
	592	update_queue_messages( $message );
	593	update_db( $message );
	594	}
[1]	595	}
	596
	597	function get_us3_data()
	598	{
	599	global $self;
	600	global $gfacID;
	601	global $dbhost;
	602	global $user;
	603	global $passwd;
	604	global $us3_db;
	605	global $updateTime;
[6]	606	global $loghdr;
[1]	607
	608	$us3_link = mysql_connect( $dbhost, $user, $passwd );
	609
	610	if ( ! $us3_link )
	611	{
[6]	612	write_log( "$loghdr could not connect: $dbhost, $user, $passwd" );
[1]	613	mail_to_admin( "fail", "Could not connect to $dbhost" );
	614	return 0;
	615	}
	616
	617
	618	$result = mysql_select_db( $us3_db, $us3_link );
	619
	620	if ( ! $result )
	621	{
[6]	622	write_log( "$loghdr could not select DB $us3_db" );
[1]	623	mail_to_admin( "fail", "Could not select DB $us3_db, $dbhost, $user, $passwd" );
	624	return 0;
	625	}
	626
	627	$query = "SELECT HPCAnalysisRequestID, UNIX_TIMESTAMP(updateTime) " .
	628	"FROM HPCAnalysisResult WHERE gfacID='$gfacID'";
	629	$result = mysql_query( $query, $us3_link );
	630
	631	if ( ! $result )
	632	{
	633	write_log( "$self: Query failed $query - " . mysql_error( $us3_link ) );
	634	mail_to_admin( "fail", "Query failed $query\n" . mysql_error( $us3_link ) );
	635	return 0;
	636	}
	637
	638	list( $requestID, $updateTime ) = mysql_fetch_array( $result );
	639	mysql_close( $us3_link );
	640
	641	return $requestID;
	642	}
	643
[6]	644	// Function to determine if this is a gfac job or not
[1]	645	function is_gfac_job( $gfacID )
	646	{
	647	$hex = "[0-9a-fA-F]";
	648	if ( ! preg_match( "/^US3-Experiment/i", $gfacID ) &&
	649	! preg_match( "/^US3-$hex{8}-$hex{4}-$hex{4}-$hex{4}-$hex{12}$/", $gfacID ) )
	650	{
	651	// Then it's not a GFAC job
	652	return false;
	653	}
	654
	655	return true;
	656	}
	657
[6]	658	// Function to determine if this is an airavata/thrift job or not
	659	function is_aira_job( $gfacID )
	660	{
	661	global $cluster;
	662
[15]	663	if ( preg_match( "/US3-A/i", $gfacID ) )
[6]	664	{
	665	// Then it's an Airavata/Thrift job
	666	return true;
	667	}
	668
	669	return false;
	670	}
	671
[1]	672	// Function to get the current job status from GFAC
	673	function get_gfac_status( $gfacID )
	674	{
	675	global $serviceURL;
[6]	676	global $self;
	677	global $loghdr;
	678	global $cluster;
[18]	679	global $status_ex, $status_gw;
[1]	680
[6]	681	if ( is_aira_job( $gfacID ) )
	682	{
	683	$status_ex = getExperimentStatus( $gfacID );
[17]	684
	685	if ( $status_ex == 'EXECUTING' )
	686	{
[18]	687	if ( $status_gw == 'RUNNING' )
[17]	688	$status_ex = 'ACTIVE';
[22]	689	else
	690	$status_ex = 'QUEUED';
[17]	691	}
	692
[6]	693	$gfac_status = standard_status( $status_ex );
	694	return $gfac_status;
	695	}
	696
	697	else if ( ! is_gfac_job( $gfacID ) )
[25]	698	{
[1]	699	return false;
[25]	700	}
[1]	701
	702	$url = "$serviceURL/jobstatus/$gfacID";
	703	try
	704	{
	705	$post = new HttpRequest( $url, HttpRequest::METH_GET );
	706	$http = $post->send();
	707	$xml = $post->getResponseBody();
	708	}
	709	catch ( HttpException $e )
	710	{
[6]	711	write_log( "$loghdr Status not available - marking failed - $gfacID" );
[1]	712	return 'GFAC_STATUS_UNAVAILABLE';
	713	}
	714
	715	// Parse the result
	716	$gfac_status = parse_response( $xml );
	717
[3]	718	// This may not seem like the best place to do this, but here we have
	719	// the xml straight from GFAC
	720	$status_types = array('SUBMITTED',
	721	'SUBMITED',
	722	'INITIALIZED',
	723	'PENDING',
[6]	724	'RUNNING',
[3]	725	'ACTIVE',
[6]	726	'STARTED',
[3]	727	'COMPLETED',
[6]	728	'FINISHED',
[3]	729	'DONE',
	730	'DATA',
[6]	731	'RESULTS_GEN',
[3]	732	'CANCELED',
	733	'CANCELLED',
	734	'FAILED',
[6]	735	'STAGING',
[3]	736	'UNKNOWN');
	737	if ( ! in_array( $gfac_status, $status_types ) )
	738	mail_to_admin( 'debug', "gfacID: /$gfacID/\n" .
	739	"XML: /$xml/\n" .
	740	"Status: /$gfac_status/\n" );
	741
[6]	742	if ( in_array( $gfac_status, array( 'DONE', 'DATA', 'RESULTS_GEN' ) ) )
	743	$gfac_status = 'DATA';
	744
[1]	745	return $gfac_status;
	746	}
	747
	748	// Function to request data outputs from GFAC
	749	function get_gfac_outputs( $gfacID )
	750	{
	751	global $serviceURL;
[6]	752	global $self;
[1]	753
	754	// Make sure it's a GFAC job and status is appropriate for this call
	755	if ( ( $job_status = get_gfac_status( $gfacID ) ) === false )
	756	{
	757	// Then it's not a GFAC job
[25]	758	$job_status = get_local_status( $gfacID );
	759	return $job_status;
[1]	760	}
	761
[6]	762	if ( ! in_array( $job_status, array( 'DONE', 'FAILED', 'COMPLETE', 'FINISHED' ) ) )
[1]	763	{
	764	// Then it's not appropriate to request data
	765	return false;
	766	}
	767
	768	$url = "$serviceURL/registeroutput/$gfacID";
	769	try
	770	{
	771	$post = new HttpRequest( $url, HttpRequest::METH_GET );
	772	$http = $post->send();
	773	$xml = $post->getResponseBody();
	774	}
	775	catch ( HttpException $e )
	776	{
	777	write_log( "$self: Data not available - request failed - $gfacID" );
	778	return false;
	779	}
	780
	781	mail_to_admin( "debug", "get_gfac_outputs/\n$xml/" ); // Temporary, to see what the xml looks like,
	782	// if we ever get one
	783
	784	// Parse the result
	785	$gfac_status = parse_response( $xml );
	786
	787	return $gfac_status;
	788	}
	789
	790	function parse_response( $xml )
	791	{
	792	global $gfac_message;
	793
	794	$status = "";
	795	$gfac_message = "";
	796
	797	$parser = new XMLReader();
	798	$parser->xml( $xml );
	799
	800	while( $parser->read() )
	801	{
	802	$type = $parser->nodeType;
	803
	804	if ( $type == XMLReader::ELEMENT )
	805	$name = $parser->name;
	806
	807	else if ( $type == XMLReader::TEXT )
	808	{
	809	if ( $name == "status" )
	810	$status = $parser->value;
	811	else
	812	$gfac_message = $parser->value;
	813	}
	814	}
	815
	816	$parser->close();
	817	return $status;
	818	}
	819
	820	// Function to get status from local cluster
	821	function get_local_status( $gfacID )
	822	{
	823	global $cluster;
[6]	824	global $self;
[1]	825
[25]	826	$cmd = "/usr/bin/qstat -a $gfacID 2>&1\|tail -n 1";
	827	if ( ! preg_match( "/us3iab/", $cluster ) )
	828	{
	829	$system = "$cluster.uthscsa.edu";
	830	$system = preg_replace( "/\-local/", "", $system );
	831	$cmd = "/usr/bin/ssh -x us3@$system " . $cmd;
	832	}
[1]	833
	834	$result = exec( $cmd );
	835
	836	if ( $result == "" \|\| preg_match( "/^qstat: Unknown/", $result ) )
	837	{
	838	write_log( "$self get_local_status: Local job $gfacID unknown" );
[25]	839	write_log( "$self get_local_status: result=$result" );
[1]	840	return 'UNKNOWN';
	841	}
	842
	843	$values = preg_split( "/\s+/", $result );
[25]	844	//write_log( "$self: get_local_status: job status = /{$values[9]}/");
[1]	845	switch ( $values[ 9 ] )
	846	{
	847	case "W" : // Waiting for execution time to be reached
	848	case "E" : // Job is exiting after having run
	849	case "R" : // Still running
	850	$status = 'ACTIVE';
	851	break;
	852
	853	case "C" : // Job has completed
[27]	854	case "" :
[1]	855	$status = 'COMPLETED';
	856	break;
	857
	858	case "T" : // Job is being moved
	859	case "H" : // Held
	860	case "Q" : // Queued
	861	$status = 'SUBMITTED';
	862	break;
	863
	864	default :
	865	$status = 'UNKNOWN'; // This should not occur
	866	break;
	867	}
	868
	869	return $status;
	870	}
	871
	872	function update_queue_messages( $message )
	873	{
	874	global $self;
	875	global $gLink;
	876	global $gfacID;
	877
	878	// Get analysis table ID
	879	$query = "SELECT id FROM analysis " .
	880	"WHERE gfacID = '$gfacID' ";
	881	$result = mysql_query( $query, $gLink );
	882	if ( ! $result )
	883	{
	884	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	885	return;
	886	}
	887	list( $analysisID ) = mysql_fetch_array( $result );
	888
	889	// Insert message into queue_message table
	890	$query = "INSERT INTO queue_messages SET " .
[6]	891	"message = '" . mysql_real_escape_string( $message, $gLink ) . "', " .
	892	"analysisID = '$analysisID' ";
[1]	893	$result = mysql_query( $query, $gLink );
	894	if ( ! $result )
	895	{
	896	write_log( "$self: Query failed $query - " . mysql_error( $gLink ) );
	897	return;
	898	}
	899	}
	900
	901	function update_db( $message )
	902	{
	903	global $self;
	904	global $gfacID;
	905	global $dbhost;
	906	global $user;
	907	global $passwd;
	908	global $us3_db;
	909
	910	$us3_link = mysql_connect( $dbhost, $user, $passwd );
	911
	912	if ( ! $us3_link )
	913	{
	914	write_log( "$self: could not connect: $dbhost, $user, $passwd" );
	915	mail_to_admin( "fail", "Could not connect to $dbhost" );
	916	return 0;
	917	}
	918
	919
	920	$result = mysql_select_db( $us3_db, $us3_link );
	921
	922	if ( ! $result )
	923	{
	924	write_log( "$self: could not select DB $us3_db" );
	925	mail_to_admin( "fail", "Could not select DB $us3_db, $dbhost, $user, $passwd" );
	926	return 0;
	927	}
	928
	929	$query = "UPDATE HPCAnalysisResult SET " .
	930	"lastMessage='" . mysql_real_escape_string( $message, $us3_link ) . "'" .
	931	"WHERE gfacID = '$gfacID' ";
	932
	933	mysql_query( $query, $us3_link );
	934	mysql_close( $us3_link );
	935	}
	936
	937	function mail_to_admin( $type, $msg )
	938	{
	939	global $updateTime;
	940	global $status;
	941	global $cluster;
	942	global $org_name;
	943	global $admin_email;
	944	global $dbhost;
	945	global $requestID;
	946
	947	$headers = "From: $org_name Admin<$admin_email>" . "\n";
	948	$headers .= "Cc: $org_name Admin<$admin_email>" . "\n";
[6]	949	$headers .= "Bcc: Gary Gorbet<gegorbet@gmail.com>" . "\n"; // make sure
[1]	950
	951	// Set the reply address
	952	$headers .= "Reply-To: $org_name<$admin_email>" . "\n";
	953	$headers .= "Return-Path: $org_name<$admin_email>" . "\n";
	954
	955	// Try to avoid spam filters
	956	$now = time();
	957	$headers .= "Message-ID: <" . $now . "gridctl@$dbhost>$requestID\n";
	958	$headers .= "X-Mailer: PHP v" . phpversion() . "\n";
	959	$headers .= "MIME-Version: 1.0" . "\n";
	960	$headers .= "Content-Transfer-Encoding: 8bit" . "\n";
	961
	962	$subject = "US3 Error Notification";
	963	$message = "
	964	UltraScan job error notification from gridctl.php:
	965
	966	Update Time : $updateTime
	967	GFAC Status : $status
	968	Cluster : $cluster
	969	";
	970
	971	$message .= "Error Message : $msg\n";
	972
	973	mail( $admin_email, $subject, $message, $headers );
	974	}
[6]	975
	976	// Convert a status string to one of the standard DB status strings
	977	function standard_status( $status_in )
	978	{
	979	switch ( $status_in )
	980	{ // Map variations to standard gateway status values
	981	case 'QUEUED' :
	982	case 'LAUNCHED' :
	983	case 'CREATED' :
	984	case 'VALIDATED' :
	985	case 'SCHEDULED' :
	986	case 'submitted' :
	987	case '' :
	988	$status = 'SUBMITTED';
	989	break;
	990
	991	case 'EXECUTING' :
	992	case 'ACTIVE' :
	993	case 'running' :
	994	case 'executing' :
	995	$status = 'RUNNING';
	996	break;
	997
	998	case 'PENDING' :
	999	case 'CANCELING' :
	1000	$status = 'UPDATING';
	1001	break;
	1002
	1003	case 'CANCELLED' :
	1004	case 'canceled' :
	1005	$status = 'CANCELED';
	1006	break;
	1007
[25]	1008	$status = 'DATA';
	1009	break;
	1010
[6]	1011	case 'COMPLETED' :
	1012	case 'completed' :
	1013	$status = 'COMPLETE';
	1014	break;
	1015
	1016	case 'FAILED_DATA' :
	1017	case 'SUBMIT_TIMEOUT' :
	1018	case 'RUN_TIMEOUT' :
	1019	case 'DATA_TIMEOUT' :
	1020	$status = 'FAILED';
	1021	break;
	1022
	1023	case 'COMPLETE' :
	1024	$status = 'DONE';
	1025	break;
	1026
	1027	case 'UNKNOWN' :
	1028	$status = 'ERROR';
	1029	break;
	1030
	1031	// Where already standard value, retain value
	1032	case 'ERROR' :
	1033	case 'RUNNING' :
	1034	case 'SUBMITTED' :
	1035	case 'UPDATING' :
	1036	case 'CANCELED' :
	1037	case 'DATA' :
	1038	case 'FAILED' :
	1039	case 'DONE' :
	1040	case 'FINISHED' :
	1041	default :
	1042	$status = $status_in;
	1043	break;
	1044	}
	1045
	1046	return $status;
	1047	}
	1048
	1049	function aira_status( $gfacID, $status_in )
	1050	{
	1051	global $self;
	1052	global $loghdr;
[26]	1053	global $class_dir;
[6]	1054	//echo "a_st: st_in$status_in : $gfacID\n";
	1055	//$status_gw = standard_status( $status_in );
	1056	$status_gw = $status_in;
	1057	//echo "a_st: st_db=$status_gw\n";
	1058	$status = $status_gw;
[10]	1059	$me_devel = preg_match( "/class_devel/", $class_dir );
	1060	$job_devel = preg_match( "/US3-ADEV/i", $gfacID );
	1061	$devmatch = ( ( !$me_devel && !$job_devel ) \|\|
	1062	( $me_devel && $job_devel ) );
[6]	1063
[10]	1064	if ( preg_match( "/US3-A/i", $gfacID ) && $devmatch )
[25]	1065	{
[6]	1066	$status_ex = getExperimentStatus( $gfacID );
	1067
	1068	if ( $status_ex == 'COMPLETED' )
	1069	{ // Experiment is COMPLETED: check for 'FINISHED' or 'DONE'
	1070	if ( $status_gw == 'FINISHED' \|\| $status_gw == 'DONE' )
	1071	{ // COMPLETED + FINISHED/DONE : gateway status is now COMPLETE
	1072	$status = 'COMPLETE';
	1073	}
	1074
	1075	else
	1076	{ // COMPLETED + NOT-FINISHED/DONE: gw status now DONE
	1077	$status = 'DONE';
	1078	}
	1079	}
	1080
	1081	else if ( $status_gw == 'FINISHED' \|\| $status_gw == 'DONE' )
	1082	{ // Gfac status == FINISHED/DONE: leave as is (unless FAILED)
	1083	$status = $status_gw;
	1084	if ( $status_ex == 'FAILED' )
	1085	{
	1086	sleep( 10 );
	1087	$status_ex = getExperimentStatus( $gfacID );
	1088	if ( $status_ex == 'FAILED' )
	1089	{
	1090	write_log( "$loghdr status still 'FAILED' after 10-second delay" );
	1091	sleep( 10 );
	1092	$status_ex = getExperimentStatus( $gfacID );
	1093	if ( $status_ex == 'FAILED' )
	1094	write_log( "$loghdr status still 'FAILED' after 20-second delay" );
	1095	else
	1096	write_log( "$loghdr status is $status_ex after 20-second delayed retry" );
	1097	}
	1098	write_log( "$loghdr status reset to 'COMPLETE'" );
	1099	$status = 'COMPLETE';
	1100	}
	1101	}
	1102
	1103	else
	1104	{ // Experiment not COMPLETED/FINISHED/DONE: use experiment status
	1105	$status = standard_status( $status_ex );
	1106	}
	1107
[10]	1108	//write_log( "$loghdr status/_in/_gw/_ex=$status/$status_in/$status_gw/$status_ex" );
[6]	1109	if ( $status != $status_gw )
	1110	{
	1111	update_job_status( $status, $gfacID );
	1112	}
	1113	}
	1114
	1115	return $status;
	1116	}
	1117
[1]	1118	?>

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

Download in other formats: