|
Viewing File bin/tester.sh of 0.01.2a
|
1: #!/usr/bin/php -q 2: <?php 3: if ((isset($argc))&&(isset($argv))) 4: { 5: if ($argc>1) 6: { 7: $nfilter=$argv[1]; 8: } 9: else $nfilter=""; 10: } 11: require("include.php"); 12: $dbt=""; 13: function db($txt,$nl=true) 14: { 15: global $dbt; 16: echo $txt; 17: $dbt.=$txt; 18: if ($nl) 19: { 20: echo "\n"; 21: $dbt.=" <br>\n"; 22: } 23: } 24: $NATS->Start(); 25: if ($nfilter!="") $st=": Node ".$nfilter; 26: else $st=""; 27: db("NATS Tester Script Starting".$st); 28: 29: $highalertlevel=-1; 30: $talertc=0; 31: 32: // check if already running 33: $cq="SELECT startx FROM fntestrun WHERE fnode=\"".ss($nfilter)."\" AND finishx=0"; 34: $cr=$NATS->DB->Query($cq); 35: if ($NATS->DB->Num_Rows($cr)>0) 36: { 37: $NATS->Event("Tester Already Running: Aborted",1,"Tester","Error"); 38: db("Tester Already Running: Aborted"); 39: $NATS->Stop(); 40: exit(); 41: } 42: 43: $gq="INSERT INTO fntestrun(startx,fnode) VALUES(".time().",\"".ss($nfilter)."\")"; 44: $NATS->DB->Query($gq); 45: $trid=$NATS->DB->Insert_Id(); 46: db("Test ID: ".$trid." (Started at ".nicedt(time()).")"); 47: $NATS->Event("Tester ".$trid." Started",5,"Tester","Start"); 48: 49: db(" "); 50: 51: if ($nfilter=="") $q="SELECT * FROM fnnode WHERE nodeenabled=1"; 52: else 53: { 54: $q="SELECT * FROM fnnode WHERE nodeid=\"".ss($nfilter)."\" AND nodeenabled=1"; 55: } 56: $r=$NATS->DB->Query($q); 57: 58: 59: while ($row=$NATS->DB->Fetch_Array($r)) 60: { 61: $alertlevel=0; 62: $alerts=array(); 63: $alertc=0; 64: db("NodeID: ".$row['nodeid']); 65: $NATS->Event("Tester ".$trid." Node ".$row['nodeid'],10,"Tester","Node"); 66: 67: $ptr=0; 68: $pal=0; 69: if ($row['pingtest']) 70: { 71: db(" Ping Test: Yes"); 72: $NATS->Event("Tester ".$trid." Pinging Node ".$row['nodeid'],10,"Tester","Ping"); 73: $ptr=PingTest($row['hostname']); 74: $NATS->Event("Tester ".$trid." Ping Node ".$row['nodeid']." Returned ".$ptr,10,"Tester","Ping"); 75: db(" Ping Returned: ".$ptr); 76: if ($ptr<=0) 77: { 78: $alertlevel=2; 79: db(" Ping Test: Failed"); 80: $alerts[$alertc++]="ping failed"; 81: $pal=2; 82: } 83: else db(" Ping Test: Passed"); 84: 85: // pingtest output bodge 86: // is there a test entry for ICMP 87: $fq="SELECT localtestid FROM fnlocaltest WHERE nodeid=\"".$row['nodeid']."\" AND testtype=\"ICMP\""; 88: $fr=$NATS->DB->Query($fq); 89: $ltid_icmp=""; 90: if ($irow=$NATS->DB->Fetch_Array($fr)) 91: { // exists 92: $uq="UPDATE fnlocaltest SET alertlevel=".$pal.",lastrunx=".time()." WHERE localtestid=".$irow['localtestid']; 93: $ltid_icmp=$irow['localtestid']; 94: //echo $uq; 95: $NATS->DB->Query($uq); 96: } 97: else 98: { // doesn't exist 99: $uq="INSERT INTO fnlocaltest(nodeid,testtype,alertlevel,lastrunx) VALUES(\"".$row['nodeid']."\",\"ICMP\",".$pal.",".time().")"; 100: //echo $uq; 101: $NATS->DB->Query($uq); 102: $ltid_icmp=$NATS->DB->Insert_Id(); 103: } 104: $NATS->DB->Free($fr); 105: 106: // record the ICMP bodge-test here 107: $rq="INSERT INTO fnrecord(testid,recordx,testvalue,alertlevel,nodeid) VALUES(\"L".$ltid_icmp."\",".time().",".$ptr.",".$pal.",\"".$row['nodeid']."\")"; 108: $NATS->DB->Query($rq); 109: //echo $rq." ".$NATS->DB->Affected_Rows()."\n"; 110: 111: } 112: else 113: { // further ICMP bodge - update to -1 or do nothing if the test doesn't exist 114: $uq="UPDATE fnlocaltest SET alertlevel=-1,lastrunx=".time()." WHERE nodeid=\"".$row['nodeid']."\" AND testtype=\"ICMP\""; 115: $NATS->DB->Query($uq); 116: } 117: 118: if (($row['pingfatal'])&&($ptr<=0)) 119: { 120: db(" Ping Fatal: Yes - Not Continuing"); 121: $NATS->Event("Tester ".$trid." Ping Fatal for Node ".$row['nodeid'],10,"Tester","Ping"); 122: } 123: else 124: { // do the tests 125: 126: db("Doing Local Tests"); 127: $NATS->Event("Tester ".$trid." Testing Node ".$row['nodeid'],10,"Tester","Test"); 128: $q="SELECT * FROM fnlocaltest WHERE nodeid=\"".$row['nodeid']."\" AND testtype!=\"ICMP\""; 129: $res=$NATS->DB->Query($q); 130: while ($lrow=$NATS->DB->Fetch_Array($res)) 131: { 132: db(" Test: ".$lrow['testtype']." (".$lrow['testparam'].")"); 133: $NATS->Event("Tester ".$trid." Node ".$row['nodeid']." Doing ".$lrow['testtype']."(".$lrow['testparam'].")",10,"Tester","Test"); 134: $result=DoTest($lrow['testtype'],$lrow['testparam'],$row['hostname']); 135: $NATS->Event("Tester ".$trid." Node ".$row['nodeid']." Result ".$result." from ".$lrow['testtype']."(".$lrow['testparam'].")",10,"Tester","Test"); 136: db(" Result: ".$result); 137: 138: // evaluation 139: if ($lrow['simpleeval']==1) $lvl=SimpleEval($lrow['testtype'],$result); 140: else $lvl=nats_eval("L".$lrow['localtestid'],$result); 141: 142: db(" Eval: ".$lvl); 143: if ($lvl>$alertlevel) $alertlevel=$lvl; 144: if ($lvl>0) 145: { 146: $s=$lrow['testtype']."/".substr($lrow['testparam'],0,5)." "; 147: if ($lvl>1) $s.="failed"; 148: else $s.="warning"; 149: $alerts[$alertc++]=$s; 150: } 151: 152: // record it 153: if ($lrow['testrecord']==1) 154: { 155: $tid="L".$lrow['localtestid']; 156: $iq="INSERT INTO fnrecord(testid,nodeid,alertlevel,testvalue,recordx) VALUES("; 157: $iq.="\"".$tid."\",\"".$row['nodeid']."\",".$lvl.",".$result.",".time().")"; 158: $NATS->DB->Query($iq); 159: db(" Recording Test"); 160: } 161: 162: // update localtest record 163: $uq="UPDATE fnlocaltest SET lastrunx=".time().",alertlevel=".$lvl." WHERE localtestid=".$lrow['localtestid']; 164: $NATS->DB->Query($uq); 165: } 166: $NATS->Event("Tester ".$trid." Finished Node ".$row['nodeid'],10,"Tester","Node"); 167: } 168: 169: db("Highest Alert Level: ".$alertlevel); 170: db("Alert Count : ".$alertc); 171: $als=""; 172: foreach($alerts as $al) $als.=$al.", "; 173: db("Alerts: ".$als); 174: 175: $NATS->SetAlerts($row['nodeid'],$alertlevel,$alerts); 176: 177: db(" "); 178: 179: if ($alertlevel>$highalertlevel) $highalertlevel=$alertlevel; 180: $talertc+=$alertc; 181: 182: } 183: 184: 185: 186: db("Finished Tests... Finishing Off"); 187: $uq="UPDATE fntestrun SET finishx=".time().",routput=\"".ss($dbt)."\" WHERE trid=".$trid; 188: $NATS->DB->Query($uq); 189: 190: db("Summary: Tester ".$trid." Highest Level ".$highalertlevel.", Alerts ".$talertc); 191: $NATS->Event("Tester ".$trid." Highest Level ".$highalertlevel.", Alerts ".$talertc,7,"Tester","Stat"); 192: $NATS->Event("Tester ".$trid." Finished",5,"Tester","Stop"); 193: 194: // in here for now... 195: $NATS->ActionFlush(); 196: 197: $NATS->Stop(); 198: db("NATS Stopped... Finished"); 199: ?> 200: 201: