Gazelle/sections/peerupdate/index.php

<?
// We keep torrent groups cached. However, the peer counts change ofter, so our solutions are to not cache them for long, or to update them. Here is where we updated them.

if ((!isset($argv[1]) || $argv[1]!=SCHEDULE_KEY) && !check_perms('admin_schedule')) { // authorization, Fix to allow people with perms hit this page.
	error(403);
}

if (check_perms('admin_schedule')) {
	View::show_header();
	echo '<pre>';
}

ignore_user_abort();
ini_set('max_execution_time',300);
ob_end_flush();
gc_enable();

$Cache->InternalCache = false; // We don't want PHP to cache all results internally
$DB->query("TRUNCATE TABLE torrents_peerlists_compare");
$DB->query("
	INSERT INTO torrents_peerlists_compare
	SELECT ID, GroupID, Seeders, Leechers, Snatched
	FROM torrents
	ON DUPLICATE KEY UPDATE
		Seeders = VALUES(Seeders),
		Leechers = VALUES(Leechers),
		Snatches = VALUES(Snatches)");
$DB->query("
	CREATE TEMPORARY TABLE tpc_temp
		(TorrentID int, GroupID int, Seeders int, Leechers int, Snatched int,
	PRIMARY KEY (GroupID, TorrentID))");
$DB->query("
	INSERT INTO tpc_temp
	SELECT t2.*
	FROM torrents_peerlists AS t1
		JOIN torrents_peerlists_compare AS t2
	USING(TorrentID)
	WHERE t1.Seeders != t2.Seeders
		OR t1.Leechers != t2.Leechers
		OR t1.Snatches != t2.Snatches");

$StepSize = 30000;
$DB->query("
	SELECT *
	FROM tpc_temp
	ORDER BY GroupID ASC, TorrentID ASC
	LIMIT $StepSize");

$RowNum = 0;
$LastGroupID = 0;
$UpdatedKeys = $UncachedGroups = 0;
list($TorrentID, $GroupID, $Seeders, $Leechers, $Snatches) = $DB->next_record(MYSQLI_NUM, false);
while ($TorrentID) {
	if ($LastGroupID != $GroupID) {
		$CachedData = $Cache->get_value("torrent_group_$GroupID");
		if ($CachedData !== false) {
			if (isset($CachedData['ver']) && $CachedData['ver'] == CACHE::GROUP_VERSION) {
				$CachedStats = &$CachedData['d']['Torrents'];
			}
		} else {
			$UncachedGroups++;
		}
		$LastGroupID = $GroupID;
	}
	while ($LastGroupID == $GroupID) {
		$RowNum++;
		if (isset($CachedStats) && is_array($CachedStats[$TorrentID])) {
			$OldValues = &$CachedStats[$TorrentID];
			$OldValues['Seeders'] = $Seeders;
			$OldValues['Leechers'] = $Leechers;
			$OldValues['Snatched'] = $Snatches;
			$Changed = true;
			unset($OldValues);
		}
		if (!($RowNum % $StepSize)) {
			$DB->query("
				SELECT *
				FROM tpc_temp
				WHERE GroupID > $GroupID
					OR (GroupID = $GroupID AND TorrentID > $TorrentID)
				ORDER BY GroupID ASC, TorrentID ASC
				LIMIT $StepSize");
		}
		$LastGroupID = $GroupID;
		list($TorrentID, $GroupID, $Seeders, $Leechers, $Snatches) = $DB->next_record(MYSQLI_NUM, false);
	}
	if ($Changed) {
		$Cache->cache_value("torrent_group_$LastGroupID", $CachedData, 0);
		unset($CachedStats);
		$UpdatedKeys++;
		$Changed = false;
	}
}
printf("Updated %d keys, skipped %d keys in %.6fs (%d kB memory)\n", $UpdatedKeys, $UncachedGroups, microtime(true) - $ScriptStartTime, memory_get_usage(true) >> 10);

$DB->query("TRUNCATE TABLE torrents_peerlists");
$DB->query("
	INSERT INTO torrents_peerlists
	SELECT *
	FROM torrents_peerlists_compare");

if (check_perms('admin_schedule')) {
	echo '<pre>';
	View::show_footer();
}
?>