X-Git-Url: https://git.mxchange.org/?a=blobdiff_plain;f=include%2Fpoller.php;h=46f1079fd11c74042fd372f83ab1f7b14d17f633;hb=660bd39efad52b1c69bd8dd0ca27141b81f84ca5;hp=e85a4555d31286767b6e8ebb10bd37a8b81bf7fc;hpb=c9307eb96a1cd6f0f99ef01127a3ec6d356543ef;p=friendica.git diff --git a/include/poller.php b/include/poller.php index e85a4555d3..46f1079fd1 100644 --- a/include/poller.php +++ b/include/poller.php @@ -41,11 +41,17 @@ function poller_run(&$argv, &$argc){ } } - $lockpath = get_config('system','lockpath'); + $lockpath = get_lockpath(); if ($lockpath != '') { - $pidfile = new pidfile($lockpath, 'poller.lck'); + $pidfile = new pidfile($lockpath, 'poller'); if($pidfile->is_already_running()) { logger("poller: Already running"); + if ($pidfile->running_time() > 9*60) { + $pidfile->kill(); + logger("poller: killed stale process"); + // Calling a new instance + proc_run('php','include/poller.php'); + } exit; } } @@ -89,6 +95,9 @@ function poller_run(&$argv, &$argc){ // Check OStatus conversations check_conversations(); + // To-Do: Regenerate usage statistics + // q("ANALYZE TABLE `item`"); + // once daily run birthday_updates and then expire in background $d1 = get_config('system','last_expire_day'); @@ -122,6 +131,9 @@ function poller_run(&$argv, &$argc){ // clear cache for photos clear_cache($a->get_basepath(), $a->get_basepath()."/photo"); + // clear smarty cache + clear_cache($a->get_basepath()."/view/smarty3/compiled", $a->get_basepath()."/view/smarty3/compiled"); + set_config('system','cache_last_cleared', time()); } @@ -168,9 +180,9 @@ function poller_run(&$argv, &$argc){ : '' ); - $contacts = q("SELECT `contact`.`id` FROM `contact` LEFT JOIN `user` ON `user`.`uid` = `contact`.`uid` + $contacts = q("SELECT `contact`.`id` FROM `contact` INNER JOIN `user` ON `user`.`uid` = `contact`.`uid` WHERE ( `rel` = %d OR `rel` = %d ) AND `poll` != '' - AND NOT `network` IN ( '%s', '%s' ) + AND NOT `network` IN ( '%s', '%s', '%s' ) $sql_extra AND `self` = 0 AND `contact`.`blocked` = 0 AND `contact`.`readonly` = 0 AND `contact`.`archive` = 0 @@ -178,7 +190,8 @@ function poller_run(&$argv, &$argc){ intval(CONTACT_IS_SHARING), intval(CONTACT_IS_FRIEND), dbesc(NETWORK_DIASPORA), - dbesc(NETWORK_FACEBOOK) + dbesc(NETWORK_FACEBOOK), + dbesc(NETWORK_PUMPIO) ); if(! count($contacts)) {