Topic: OFFICIAL CGMINER mining software thread for linux/win/osx/mips/arm/r-pi 4.11.0 - page 282. (Read 5805537 times)

function cgminer($command, $parameter) {

	$command = array (
		"command"  => $command,
		"parameter" => $parameter
	);

	$jsonCmd = json_encode($command);

	$host = "127.0.0.1";
	$port = 4028;

	$client = stream_socket_client("tcp://$host:$port", $errno, $errorMessage);

	if ($client === false) {
		throw new UnexpectedValueException("Failed to connect: $errorMessage");
	}
	fwrite($client, $jsonCmd);
	$responce = stream_get_contents($client);
	fclose($client);
	$responce = preg_replace("/[^[:alnum:][:punct:]]/","",$responce);
	$responce = json_decode($responce, true);
	return $responce;

}

session_start();
#
include_once('tools.php');
#
global $icas;
#
$icas = array();	// Rigs with ICA's
#
function process()
{
 global $miner, $port;
 global $haderror, $error, $rigs;
 global $icas, $dis;

 if ($rigs == null or count($rigs) == 0)
	doabort("No rigs defined");

 foreach ($rigs as $rig)
 {
	$now = time();
	if (isset($dis[$rig]))
	{
		if (($now - $dis[$rig]) > 90)
		{
			unset($dis[$rig]);
			txtmsg("Reenabling $rig");
		}
		else
			continue;
	}

	$parts = explode(':', $rig, 3);
	if (count($parts) < 2)
		doabort("Invalid rig '$rig'");
	else
	{
		$miner = $parts[0];
		$port = $parts[1];

		$process0 = getapi($rig, 'summary');
		if ($process0 === false)
			continue;

		if (!isset($process0['SUMMARY']['Elapsed']))
		{
			handle($rig, "Error on '$rig'\n(Missing SUMMARY/Elapsed)");
			continue;
		}

		$el = $process0['SUMMARY']['Elapsed'];

		$process = getapi($rig, 'devs');
		if ($process === false)
			continue;

		$now = time();
		$when = $process['STATUS']['When'];

		if (isset($process['STATUS']['Description']))
			$des = $process['STATUS']['Description'];
		else
			$des = $rig;

		$gotone = false;
		foreach ($process as $dev => $details)
		{
			if (isset($details['Name']) && $details['Name'] == 'ICA')
			{
				$gotone = true;

				// force a message from each rig with an ICA
				if (!isset($icas[$rig]))
				{
					$icas[$rig] = 'on';
					msg("Monitoring: ICAs on $des");
				}

				if (isset($details['Last Valid Work']))
				{
					// Give it 60s
					if ($el > 60 && $el < 5184000) // 60days
					{
						$lst = $details['Last Valid Work'];

						if (($when - $lst) > 180)
						{
							msg("$dev=ICA".$details['ID']." on $des (Elapsed=$el when-lst=".($when-$lst).")\nSending API quit (then sleeping for 900s)");

							$process = api('quit');

							sleep(900);
						}
					}
				}
			}
		}

		if (!$gotone)
		{
			$dis[$rig] = time() + (60*60*24*365.25*10);

			dowarn("$des has no ICAs\nRestart monitoring disabled");

			if (count($dis) == count($rigs))
				doabort("No rigs to monitor");
		}
	}
 }
}
#
while (true)
{
 process();
 sleep(5);
}
#
?>