Blame view

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