nupplaPhil/friendica-directory
1
0
Fork 0
forked from friendica/friendica-directory
Code Issues Pull requests Releases Wiki Activity

Add queue size info logging in Controllers/Cron

Browse source
This commit is contained in:
Hypolite Petovan 2018-11-13 22:01:34 -05:00
parent 641dc9b8eb
commit f9b9557415
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/classes/Controllers/Cron.php
View file

@ -93,6 +93,8 @@ class Cron
ORDER BY ISNULL(`last_polled`) DESC' ORDER BY ISNULL(`last_polled`) DESC'
); );
$this->logger->info('Directories polling queue size: ' . count($directories));
foreach ($directories as $directory) { foreach ($directories as $directory) {
if ($time_limit && microtime(true) - $this->startTime > $time_limit) { if ($time_limit && microtime(true) - $this->startTime > $time_limit) {
break; break;
@ -133,6 +135,8 @@ class Cron
ORDER BY ISNULL(`last_polled`) DESC, `request_count` DESC' ORDER BY ISNULL(`last_polled`) DESC, `request_count` DESC'
); );
$this->logger->info('Servers polling queue size: ' . count($servers));
foreach ($servers as $server_queue_item) { foreach ($servers as $server_queue_item) {
if ($time_limit && microtime(true) - $this->startTime > $time_limit) { if ($time_limit && microtime(true) - $this->startTime > $time_limit) {
break; break;
@ -188,6 +192,8 @@ class Cron
ORDER BY RAND() ASC' ORDER BY RAND() ASC'
); );
$this->logger->info('Profiles polling queue size: ' . count($profiles));
foreach ($profiles as $profile) { foreach ($profiles as $profile) {
if ($time_limit && microtime(true) - $this->startTime > $time_limit) { if ($time_limit && microtime(true) - $this->startTime > $time_limit) {
break; break;