aboutsummaryrefslogtreecommitdiffstats
path: root/phpBB/includes/cron_lock.php
blob: 1046d62da4f130be97e23a9d2c7fdccabec7fc97 (plain)
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
<?php
/**
*
* @package phpBB3
* @version $Id$
* @copyright (c) 2010 phpBB Group
* @license http://opensource.org/licenses/gpl-license.php GNU Public License
*
*/

/**
* @ignore
*/
if (!defined('IN_PHPBB'))
{
	exit;
}

/**
* Cron lock class
* @package phpBB3
*/
class cron_lock
{
	private $cron_id;

	function lock()
	{
		global $config, $db;

		if (!isset($config['cron_lock']))
		{
			set_config('cron_lock', '0', true);
		}

		// make sure cron doesn't run multiple times in parallel
		if ($config['cron_lock'])
		{
			// if the other process is running more than an hour already we have to assume it
			// aborted without cleaning the lock
			$time = explode(' ', $config['cron_lock']);
			$time = $time[0];

			if ($time + 3600 >= time())
			{
				return false;
			}
		}

		$this->cron_id = time() . ' ' . unique_id();

		$sql = 'UPDATE ' . CONFIG_TABLE . "
			SET config_value = '" . $db->sql_escape($this->cron_id) . "'
			WHERE config_name = 'cron_lock' AND config_value = '" . $db->sql_escape($config['cron_lock']) . "'";
		$db->sql_query($sql);

		// another cron process altered the table between script start and UPDATE query so exit
		if ($db->sql_affectedrows() != 1)
		{
			return false;
		}

		return true;
	}

	function unlock()
	{
		global $db;

		$sql = 'UPDATE ' . CONFIG_TABLE . "
			SET config_value = '0'
			WHERE config_name = 'cron_lock' AND config_value = '" . $db->sql_escape($this->cron_id) . "'";
		$db->sql_query($sql);
	}
}