3 +--------------------------------------------------------------------+
4 | CiviCRM version 4.7 |
5 +--------------------------------------------------------------------+
6 | Copyright CiviCRM LLC (c) 2004-2015 |
7 +--------------------------------------------------------------------+
8 | This file is a part of CiviCRM. |
10 | CiviCRM is free software; you can copy, modify, and distribute it |
11 | under the terms of the GNU Affero General Public License |
12 | Version 3, 19 November 2007 and the CiviCRM Licensing Exception. |
14 | CiviCRM is distributed in the hope that it will be useful, but |
15 | WITHOUT ANY WARRANTY; without even the implied warranty of |
16 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. |
17 | See the GNU Affero General Public License for more details. |
19 | You should have received a copy of the GNU Affero General Public |
20 | License and the CiviCRM Licensing Exception along |
21 | with this program; if not, contact CiviCRM LLC |
22 | at info[AT]civicrm[DOT]org. If you have questions about the |
23 | GNU Affero General Public License or the licensing of CiviCRM, |
24 | see the CiviCRM license FAQ at http://civicrm.org/licensing |
25 +--------------------------------------------------------------------+
31 * @copyright CiviCRM LLC (c) 2004-2015
35 class CRM_Core_Lock
implements \Civi\Core\Lock\LockInterface
{
37 static $jobLog = FALSE;
39 // lets have a 3 second timeout for now
42 protected $_hasLock = FALSE;
47 * Use MySQL's GET_LOCK(). Locks are shared across all Civi instances
48 * on the same MySQL server.
51 * Symbolic name for the lock. Names generally look like
52 * "worker.mailing.EmailProcessor" ("{category}.{component}.{AdhocName}").
54 * Categories: worker|data|cache|...
55 * Component: core|mailing|member|contribute|...
56 * @return \Civi\Core\Lock\LockInterface
58 public static function createGlobalLock($name) {
59 return new static($name, NULL, TRUE);
63 * Use MySQL's GET_LOCK(), but apply prefixes to the lock names.
64 * Locks are unique to each instance of Civi.
67 * Symbolic name for the lock. Names generally look like
68 * "worker.mailing.EmailProcessor" ("{category}.{component}.{AdhocName}").
70 * Categories: worker|data|cache|...
71 * Component: core|mailing|member|contribute|...
72 * @return \Civi\Core\Lock\LockInterface
74 public static function createScopedLock($name) {
75 return new static($name);
79 * Use MySQL's GET_LOCK(), but conditionally apply prefixes to the lock names
80 * (if civimail_server_wide_lock is disabled).
83 * Symbolic name for the lock. Names generally look like
84 * "worker.mailing.EmailProcessor" ("{category}.{component}.{AdhocName}").
86 * Categories: worker|data|cache|...
87 * Component: core|mailing|member|contribute|...
88 * @return \Civi\Core\Lock\LockInterface
91 public static function createCivimailLock($name) {
92 $serverWideLock = \Civi
::settings()->get('civimail_server_wide_lock');
93 return new static($name, NULL, $serverWideLock);
97 * Initialize the constants used during lock acquire / release
100 * Symbolic name for the lock. Names generally look like
101 * "worker.mailing.EmailProcessor" ("{category}.{component}.{AdhocName}").
103 * Categories: worker|data|cache|...
104 * Component: core|mailing|member|contribute|...
105 * @param int $timeout
106 * The number of seconds to wait to get the lock. 1 if not set.
107 * @param bool $serverWideLock
108 * Should this lock be applicable across your entire mysql server.
109 * this is useful if you have multiple sites running on the same
110 * mysql server and you want to limit the number of parallel cron
113 public function __construct($name, $timeout = NULL, $serverWideLock = FALSE) {
114 $config = CRM_Core_Config
::singleton();
115 $dsnArray = DB
::parseDSN($config->dsn
);
116 $database = $dsnArray['database'];
117 $domainID = CRM_Core_Config
::domainID();
118 if ($serverWideLock) {
119 $this->_name
= $name;
122 $this->_name
= $database . '.' . $domainID . '.' . $name;
124 if (defined('CIVICRM_LOCK_DEBUG')) {
125 CRM_Core_Error
::debug_log_message('trying to construct lock for ' . $this->_name
);
127 $this->_timeout
= $timeout !== NULL ?
$timeout : self
::TIMEOUT
;
130 public function __destruct() {
137 * @param int $timeout
140 * @throws \CRM_Core_Exception
142 public function acquire($timeout = NULL) {
143 if (!$this->_hasLock
) {
144 if (self
::$jobLog && CRM_Core_DAO
::singleValueQuery("SELECT IS_USED_LOCK( '" . self
::$jobLog . "')")) {
145 return $this->hackyHandleBrokenCode(self
::$jobLog);
148 $query = "SELECT GET_LOCK( %1, %2 )";
150 1 => array($this->_name
, 'String'),
151 2 => array($timeout ?
$timeout : $this->_timeout
, 'Integer'),
153 $res = CRM_Core_DAO
::singleValueQuery($query, $params);
155 if (defined('CIVICRM_LOCK_DEBUG')) {
156 CRM_Core_Error
::debug_log_message('acquire lock for ' . $this->_name
);
158 $this->_hasLock
= TRUE;
159 if (stristr($this->_name
, 'data.mailing.job.')) {
160 self
::$jobLog = $this->_name
;
164 if (defined('CIVICRM_LOCK_DEBUG')) {
165 CRM_Core_Error
::debug_log_message('failed to acquire lock for ' . $this->_name
);
169 return $this->_hasLock
;
173 * @return null|string
175 public function release() {
176 if ($this->_hasLock
) {
177 if (defined('CIVICRM_LOCK_DEBUG')) {
178 CRM_Core_Error
::debug_log_message('release lock for ' . $this->_name
);
180 $this->_hasLock
= FALSE;
182 if (self
::$jobLog == $this->_name
) {
183 self
::$jobLog = FALSE;
186 $query = "SELECT RELEASE_LOCK( %1 )";
187 $params = array(1 => array($this->_name
, 'String'));
188 return CRM_Core_DAO
::singleValueQuery($query, $params);
193 * @return null|string
195 public function isFree() {
196 $query = "SELECT IS_FREE_LOCK( %1 )";
197 $params = array(1 => array($this->_name
, 'String'));
198 return CRM_Core_DAO
::singleValueQuery($query, $params);
204 public function isAcquired() {
205 return $this->_hasLock
;
209 * CRM-12856 locks were originally set up for jobs, but the concept was extended to caching & groups without
210 * understanding that would undermine the job locks (because grabbing a lock implicitly releases existing ones)
211 * this is all a big hack to mitigate the impact of that - but should not be seen as a fix. Not sure correct fix
212 * but maybe locks should be used more selectively? Or else we need to handle is some cool way that Tim is yet to write :-)
213 * if we are running in the context of the cron log then we would rather die (or at least let our process die)
214 * than release that lock - so if the attempt is being made by setCache or something relatively trivial
215 * we'll just return TRUE, but if it's another job then we will crash as that seems 'safer'
217 * @param string $jobLog
218 * @throws CRM_Core_Exception
221 public function hackyHandleBrokenCode($jobLog) {
222 if (stristr($this->_name
, 'job')) {
223 CRM_Core_Error
::debug_log_message('lock acquisition for ' . $this->_name
. ' attempted when ' . $jobLog . ' is not released');
224 throw new CRM_Core_Exception('lock acquisition for ' . $this->_name
. ' attempted when ' . $jobLog . ' is not released');
226 if (defined('CIVICRM_LOCK_DEBUG')) {
227 CRM_Core_Error
::debug_log_message('(CRM-12856) faking lock for ' . $this->_name
);
229 $this->_hasLock
= TRUE;