cron.php 3.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127
  1. <?php
  2. /**
  3. * ownCloud
  4. *
  5. * @author Jakob Sack
  6. * @copyright 2012 Jakob Sack owncloud@jakobsack.de
  7. *
  8. * This library is free software; you can redistribute it and/or
  9. * modify it under the terms of the GNU AFFERO GENERAL PUBLIC LICENSE
  10. * License as published by the Free Software Foundation; either
  11. * version 3 of the License, or any later version.
  12. *
  13. * This library is distributed in the hope that it will be useful,
  14. * but WITHOUT ANY WARRANTY; without even the implied warranty of
  15. * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  16. * GNU AFFERO GENERAL PUBLIC LICENSE for more details.
  17. *
  18. * You should have received a copy of the GNU Affero General Public
  19. * License along with this library. If not, see <http://www.gnu.org/licenses/>.
  20. *
  21. */
  22. // Unfortunately we need this class for shutdown function
  23. class TemporaryCronClass {
  24. public static $sent = false;
  25. public static $lockfile = "";
  26. public static $keeplock = false;
  27. }
  28. // We use this function to handle (unexpected) shutdowns
  29. function handleUnexpectedShutdown() {
  30. // Delete lockfile
  31. if (!TemporaryCronClass::$keeplock && file_exists(TemporaryCronClass::$lockfile)) {
  32. unlink(TemporaryCronClass::$lockfile);
  33. }
  34. // Say goodbye if the app did not shutdown properly
  35. if (!TemporaryCronClass::$sent) {
  36. if (OC::$CLI) {
  37. echo 'Unexpected error!' . PHP_EOL;
  38. } else {
  39. OC_JSON::error(array('data' => array('message' => 'Unexpected error!')));
  40. }
  41. }
  42. }
  43. try {
  44. require_once 'lib/base.php';
  45. session_write_close();
  46. $logger = \OC_Log::$object;
  47. // Don't do anything if ownCloud has not been installed
  48. if (!OC_Config::getValue('installed', false)) {
  49. exit(0);
  50. }
  51. // Handle unexpected errors
  52. register_shutdown_function('handleUnexpectedShutdown');
  53. // Delete temp folder
  54. OC_Helper::cleanTmpNoClean();
  55. // Exit if background jobs are disabled!
  56. $appmode = OC_BackgroundJob::getExecutionType();
  57. if ($appmode == 'none') {
  58. TemporaryCronClass::$sent = true;
  59. if (OC::$CLI) {
  60. echo 'Background Jobs are disabled!' . PHP_EOL;
  61. } else {
  62. OC_JSON::error(array('data' => array('message' => 'Background jobs disabled!')));
  63. }
  64. exit(1);
  65. }
  66. if (OC::$CLI) {
  67. // Create lock file first
  68. TemporaryCronClass::$lockfile = OC_Config::getValue("datadirectory", OC::$SERVERROOT . '/data') . '/cron.lock';
  69. // We call ownCloud from the CLI (aka cron)
  70. if ($appmode != 'cron') {
  71. // Use cron in future!
  72. OC_BackgroundJob::setExecutionType('cron');
  73. }
  74. // check if backgroundjobs is still running
  75. if (file_exists(TemporaryCronClass::$lockfile)) {
  76. TemporaryCronClass::$keeplock = true;
  77. TemporaryCronClass::$sent = true;
  78. echo "Another instance of cron.php is still running!";
  79. exit(1);
  80. }
  81. // Create a lock file
  82. touch(TemporaryCronClass::$lockfile);
  83. // Work
  84. $jobList = new \OC\BackgroundJob\JobList();
  85. $jobs = $jobList->getAll();
  86. foreach ($jobs as $job) {
  87. $job->execute($jobList, $logger);
  88. }
  89. } else {
  90. // We call cron.php from some website
  91. if ($appmode == 'cron') {
  92. // Cron is cron :-P
  93. OC_JSON::error(array('data' => array('message' => 'Backgroundjobs are using system cron!')));
  94. } else {
  95. // Work and success :-)
  96. $jobList = new \OC\BackgroundJob\JobList();
  97. $job = $jobList->getNext();
  98. $job->execute($jobList, $logger);
  99. $jobList->setLastJob($job);
  100. OC_JSON::success();
  101. }
  102. }
  103. // done!
  104. TemporaryCronClass::$sent = true;
  105. exit();
  106. } catch (Exception $ex) {
  107. \OCP\Util::writeLog('cron', $ex->getMessage(), \OCP\Util::FATAL);
  108. }