New job type KAsyncValidateLiveMediaServers

batch/batches/ValidateLiveMediaServers/KAsyncValidateLiveMediaServers.class.php

@@ -0,0 +1,49 @@
+<?php
+/**
+ * @package Scheduler
+ * @subpackage ValidateLiveMediaServers
+ */
+
+/**
+ * Validates periodically that all live entries are still broadcasting to the connected media servers
+ *
+ * @package Scheduler
+ * @subpackage ValidateLiveMediaServers
+ */
+class KAsyncValidateLiveMediaServers extends KPeriodicWorker
+{
+	/* (non-PHPdoc)
+	 * @see KBatchBase::getType()
+	 */
+	public static function getType()
+	{
+		return KalturaBatchJobType::CLEANUP;
+	}
+
+	/* (non-PHPdoc)
+	 * @see KBatchBase::run()
+	*/
+	public function run($jobs = null)
+	{
+		KalturaLog::info("Validating live media servers");
+
+		$filter = new KalturaLiveEntryFilter();
+		$filter->orderBy = KalturaLiveEntryOrderBy::CREATED_AT_ASC;
+
+		$entries = self::$kClient->liveStream->listAction($filter);
+		while(count($entries->objects))
+		{
+			foreach($entries->objects as $entry)
+			{
+				/* @var $entry KalturaLiveEntry */
+				self::impersonate($entry->partnerId);
+				self::$kClient->liveStream->validateRegisteredMediaServers($entry->id);
+				self::unimpersonate();
+
+				$filter->createdAtGreaterThanOrEqual = $entry->createdAt;
+			}
+
+			$entries = self::$kClient->liveStream->listAction($filter);
+		}
+	}
+}

batch/batches/ValidateLiveMediaServers/KAsyncValidateLiveMediaServersDebug.php

@@ -0,0 +1,15 @@
+<?php
+/**
+ * @package Scheduler
+ * @subpackage Debug
+ */
+
+chdir(dirname(__FILE__) . "/../../");
+
+require_once (__DIR__ . "/../../bootstrap.php");
+
+$iniDir = dirname(__FILE__) . "/../configurations/batch"; // should be the full file path
+
+
+$kdebuger = new KGenericDebuger($iniDir);
+$kdebuger->run('KAsyncValidateLiveMediaServers');

batch/batches/ValidateLiveMediaServers/KAsyncValidateLiveMediaServersExe.php

@@ -0,0 +1,12 @@
+<?php
+/**
+ * Will run the KAsyncValidateLiveMediaServers 
+ *
+ * @package Scheduler
+ * @subpackage ValidateLiveMediaServers
+ */
+require_once (__DIR__ . "/../../bootstrap.php");
+
+$instance = new KAsyncValidateLiveMediaServers();
+$instance->run();
+$instance->done();