cs fix (and call ProcessNotifications statically).
This commit is contained in:
parent
04a8d3a3a9
commit
67fdc5cd1f
1 changed files with 93 additions and 99 deletions
192
src/cron.php
192
src/cron.php
|
@ -19,10 +19,10 @@
|
|||
*
|
||||
*/
|
||||
|
||||
include('./serverlib/init.inc.php');
|
||||
include('./serverlib/pop3gateway.class.php');
|
||||
include('./serverlib/userpop3gateway.class.php');
|
||||
include('./serverlib/calendar.class.php');
|
||||
include './serverlib/init.inc.php';
|
||||
include './serverlib/pop3gateway.class.php';
|
||||
include './serverlib/userpop3gateway.class.php';
|
||||
include './serverlib/calendar.class.php';
|
||||
|
||||
// try to prevent abortion
|
||||
header('Connection: close');
|
||||
|
@ -32,132 +32,126 @@ header('Expires: Wed, 04 Aug 2004 14:46:00 GMT');
|
|||
@set_time_limit(0);
|
||||
|
||||
// output status
|
||||
if(!isset($_REQUEST['out']) || $_REQUEST['out'] == 'text')
|
||||
{
|
||||
$str = microtime() . ' - OK';
|
||||
// if(!SERVER_IIS && !DEBUG)
|
||||
// header('Content-Length: ' . strlen($str));
|
||||
echo($str);
|
||||
}
|
||||
else if(isset($_REQUEST['out']) && $_REQUEST['out'] == 'img')
|
||||
{
|
||||
header('Content-Type: image/gif');
|
||||
if(!SERVER_IIS)
|
||||
header('Content-Length: ' . filesize('res/dummy.gif'));
|
||||
readfile('res/dummy.gif');
|
||||
if (!isset($_REQUEST['out']) || $_REQUEST['out'] == 'text') {
|
||||
$str = microtime().' - OK';
|
||||
// if(!SERVER_IIS && !DEBUG)
|
||||
// header('Content-Length: ' . strlen($str));
|
||||
echo $str;
|
||||
} elseif (isset($_REQUEST['out']) && $_REQUEST['out'] == 'img') {
|
||||
header('Content-Type: image/gif');
|
||||
if (!SERVER_IIS) {
|
||||
header('Content-Length: '.filesize('res/dummy.gif'));
|
||||
}
|
||||
readfile('res/dummy.gif');
|
||||
}
|
||||
flush();
|
||||
|
||||
// fetch user POP3 mails?
|
||||
if(isset($_REQUEST['sid']) && RequestPrivileges(PRIVILEGES_USER, true))
|
||||
{
|
||||
@session_write_close();
|
||||
$userPOP3Gateway = _new('BMUserPOP3Gateway', array($userRow['id'], &$thisUser));
|
||||
$userPOP3Gateway->Run();
|
||||
if (isset($_REQUEST['sid']) && RequestPrivileges(PRIVILEGES_USER, true)) {
|
||||
@session_write_close();
|
||||
$userPOP3Gateway = _new('BMUserPOP3Gateway', [$userRow['id'], &$thisUser]);
|
||||
$userPOP3Gateway->Run();
|
||||
}
|
||||
|
||||
// check if interval time passed
|
||||
if($bm_prefs['last_cron'] < time()-$bm_prefs['cron_interval'])
|
||||
{
|
||||
// set up lock
|
||||
function ReleaseCronLock()
|
||||
{
|
||||
global $lockFP;
|
||||
if ($bm_prefs['last_cron'] < time() - $bm_prefs['cron_interval']) {
|
||||
// set up lock
|
||||
function ReleaseCronLock()
|
||||
{
|
||||
global $lockFP;
|
||||
|
||||
flock($lockFP, LOCK_UN);
|
||||
fclose($lockFP);
|
||||
}
|
||||
$lockFileName = B1GMAIL_DIR . 'temp/cron.lock';
|
||||
$lockFP = fopen($lockFileName, 'w+');
|
||||
if(!flock($lockFP, LOCK_EX | LOCK_NB))
|
||||
exit();
|
||||
register_shutdown_function('ReleaseCronLock');
|
||||
flock($lockFP, LOCK_UN);
|
||||
fclose($lockFP);
|
||||
}
|
||||
$lockFileName = B1GMAIL_DIR.'temp/cron.lock';
|
||||
$lockFP = fopen($lockFileName, 'w+');
|
||||
if (!flock($lockFP, LOCK_EX | LOCK_NB)) {
|
||||
exit();
|
||||
}
|
||||
register_shutdown_function('ReleaseCronLock');
|
||||
|
||||
include('./serverlib/cron.inc.php');
|
||||
include './serverlib/cron.inc.php';
|
||||
|
||||
// update last cron run time
|
||||
$db->Query('UPDATE {pre}prefs SET last_cron=?',
|
||||
time());
|
||||
// update last cron run time
|
||||
$db->Query('UPDATE {pre}prefs SET last_cron=?',
|
||||
time());
|
||||
|
||||
// clean up expired action tokens
|
||||
CleanupActionTokens();
|
||||
// clean up expired action tokens
|
||||
CleanupActionTokens();
|
||||
|
||||
// clean up mail send stats
|
||||
CleanupSendStats();
|
||||
// clean up mail send stats
|
||||
CleanupSendStats();
|
||||
|
||||
// clean up mail receive stats
|
||||
CleanupRecvStats();
|
||||
// clean up mail receive stats
|
||||
CleanupRecvStats();
|
||||
|
||||
// clean up saved logins
|
||||
CleanupSavedLogins();
|
||||
// clean up saved logins
|
||||
CleanupSavedLogins();
|
||||
|
||||
// clean up safe codes
|
||||
CleanupSafeCodes();
|
||||
// clean up safe codes
|
||||
CleanupSafeCodes();
|
||||
|
||||
// clean up temp file
|
||||
CleanupTempFiles();
|
||||
// clean up temp file
|
||||
CleanupTempFiles();
|
||||
|
||||
// clean up parse cache
|
||||
if($bm_prefs['cache_type'] == CACHE_B1GMAIL)
|
||||
$cacheManager->CleanUp();
|
||||
// clean up parse cache
|
||||
if ($bm_prefs['cache_type'] == CACHE_B1GMAIL) {
|
||||
$cacheManager->CleanUp();
|
||||
}
|
||||
|
||||
// clean up aliases
|
||||
CleanupAliases();
|
||||
// clean up aliases
|
||||
CleanupAliases();
|
||||
|
||||
// clean up cert mails
|
||||
CleanupCertMails();
|
||||
// clean up cert mails
|
||||
CleanupCertMails();
|
||||
|
||||
// clean up webdisk locks
|
||||
CleanupWebdiskLocks();
|
||||
// clean up webdisk locks
|
||||
CleanupWebdiskLocks();
|
||||
|
||||
// clean up notifications
|
||||
CleanupNotifications();
|
||||
// clean up notifications
|
||||
CleanupNotifications();
|
||||
|
||||
// abuse protect cron
|
||||
AbuseCron();
|
||||
// abuse protect cron
|
||||
AbuseCron();
|
||||
|
||||
// reset webdisk traffic
|
||||
ResetWebdiskTraffic();
|
||||
// reset webdisk traffic
|
||||
ResetWebdiskTraffic();
|
||||
|
||||
// send birthday notifications
|
||||
ProcessBirthdayNotifications();
|
||||
// send birthday notifications
|
||||
ProcessBirthdayNotifications();
|
||||
|
||||
// auto-delete users who never logged in
|
||||
ProcessNoSignupAutoDel();
|
||||
// auto-delete users who never logged in
|
||||
ProcessNoSignupAutoDel();
|
||||
|
||||
// delete old mail delivery status entries
|
||||
CleanupMailDeliveryStatus();
|
||||
// delete old mail delivery status entries
|
||||
CleanupMailDeliveryStatus();
|
||||
|
||||
// send calendar notifications
|
||||
|
||||
(new BMCalendar($userRow['id']))->ProcessNotifications();
|
||||
// send calendar notifications
|
||||
BMCalendar::ProcessNotifications();
|
||||
|
||||
// fetch POP3 mails
|
||||
if($bm_prefs['receive_method'] == 'pop3')
|
||||
{
|
||||
$pop3Gateway = _new('BMPOP3Gateway');
|
||||
$pop3Gateway->Run();
|
||||
}
|
||||
// fetch POP3 mails
|
||||
if ($bm_prefs['receive_method'] == 'pop3') {
|
||||
$pop3Gateway = _new('BMPOP3Gateway');
|
||||
$pop3Gateway->Run();
|
||||
}
|
||||
|
||||
// plugin cron
|
||||
ModuleFunction('OnCron');
|
||||
// plugin cron
|
||||
ModuleFunction('OnCron');
|
||||
|
||||
// store time
|
||||
if($bm_prefs['last_storetime_cron'] < time()-STORETIME_CRON_INTERVAL)
|
||||
{
|
||||
// process
|
||||
StoreTimeCron();
|
||||
// store time
|
||||
if ($bm_prefs['last_storetime_cron'] < time() - STORETIME_CRON_INTERVAL) {
|
||||
// process
|
||||
StoreTimeCron();
|
||||
|
||||
// update last store time cron run time
|
||||
$db->query('UPDATE {pre}prefs SET last_storetime_cron=?',
|
||||
time());
|
||||
}
|
||||
// update last store time cron run time
|
||||
$db->query('UPDATE {pre}prefs SET last_storetime_cron=?',
|
||||
time());
|
||||
}
|
||||
|
||||
// auto archive logs
|
||||
AutoArchiveLogs();
|
||||
// auto archive logs
|
||||
AutoArchiveLogs();
|
||||
|
||||
// update last cron run time
|
||||
$db->Query('UPDATE {pre}prefs SET last_cron=?',
|
||||
time());
|
||||
// update last cron run time
|
||||
$db->Query('UPDATE {pre}prefs SET last_cron=?',
|
||||
time());
|
||||
}
|
||||
?>
|
Loading…
Reference in a new issue