source: trunk/web2/addons/job_monarch/jobstore.php @ 536

<?php

$c                      = $_POST["c"];
$clustername            = $c;
$cluster                = $c;

global $c, $clustername, $cluster;

$HTTP_POST_VARS["c"]    = $c;
$_GET["c"]              = $c;

global $c, $clustername, $cluster;

include_once "./libtoga.php";

$ds             = new DataSource();
$myxml_data     = &$ds->getData();

//printf( "d %s\n", strlen( $myxml_data ) );
//return 0;

global $jobs;

$data_gatherer  = new DataGatherer( $clustername );
$data_gatherer->parseXML( &$myxml_data );

$heartbeat      = &$data_gatherer->getHeartbeat();
$jobs           = &$data_gatherer->getJobs();
//$gnodes         = $data_gatherer->getNodes();
$cpus           = &$data_gatherer->getCpus();
$use_fqdn       = &$data_gatherer->getUsingFQDN();

// The ext grid script will send  a task field which will specify what it wants to do
//$task = '';

if( isset($_POST['task']) )
{
        $task = $_POST['task'];
}
if( isset( $HTTP_POST_VARS['task' ] ) )
{
        $task = $HTTP_POST_VARS['task'];
}

//getList();

switch($task)
{
    case "LISTING":
        getList();
        break;          
    default:
        echo "{failure:true}";
        break;
}

function getList() 
{
        global $jobs, $hearbeat;

        $job_count      = count( $jobs );

        if( $job_count == 0 )
        {
                echo 'crap({"total":"0", "results":""})';
                return 0;
        }

        $jobresults     = array();

        foreach( $jobs as $jobid => $jobattrs )
        {
                //if( $jobattrs['reported'] != $heartbeat )
                //{
                //      continue;
                //}

                $jr['jid']              = strval( $jobid );
                $jr['status']           = $jobattrs['status'];
                $jr['owner']            = $jobattrs['owner'];
                $jr['queue']            = $jobattrs['queue'];
                $jr['name']             = $jobattrs['name'];
                $jr['requested_time']   = makeTime( timeToEpoch( $jobattrs['requested_time'] ) );

                if( $jr['status'] == 'R' )
                {
                        $nodes          = count( $jobattrs[nodes] );
                }
                else
                {
                        $nodes          = (int) $jobattrs[nodes];
                }

                $jr['ppn']              = strval( $jobattrs[ppn] ? $jobattrs[ppn] : 1 );
                $jr['nodect']           = strval( $nodes );

                if( $jr['status'] == 'R' )
                {
                        $jr['nodes']    = implode( ",", $jobattrs['nodes'] );
                }
                else
                {
                        $jr['nodes']    = "";
                }

                $jr['queued_timestamp'] = makeDate( $jobattrs['queued_timestamp'] );
                $jr['start_timestamp']  = ($jobattrs['start_timestamp'] ? makeDate( $jobattrs['start_timestamp'] ) : "");

                if( $jr['status'] == 'R' )
                {
                        $runningtime            = (int) $jobattrs['reported'] - (int) $jobattrs['start_timestamp'];
                        $jr['runningtime']      = makeTime( $runningtime );
                }
                else
                {
                        $jr['runningtime']      = "";
                }

                $jobresults[]           = $jr;
        }


        //$results      = array();

        //foreach( $jobresults as $resid => $jr )
        //{
        //      $jr_count       = 0;
        //      $job_record     = array();

        //      foreach( $jr as $atrname => $atrval )
        //      {
        //              $job_record[$jr_count]  = $atrval;
        //              $job_record[$atrname]   = $atrval;

        //              $jr_count               = $jr_count + 1;
        //      }

        //      $results[]      = $job_record;
        //}

        $jsonresults    = JEncode( $jobresults );

        echo '{"total":"'. count( $jobresults) .'","results":'. $jsonresults .'}';

        return 0;
}

// Encodes a SQL array into a JSON formated string
function JEncode( $arr )
{
        if (version_compare(PHP_VERSION,"5.2","<"))
        {    
                require_once("./JSON.php"); //if php<5.2 need JSON class

                $json   = new Services_JSON();//instantiate new json object
                $data   = $json->encode($arr);  //encode the data in json format
        } 
        else
        {
                $data   = json_encode($arr);  //encode the data in json format
        }

        return $data;
}

?>