<h2>File Contents: /home/planet5/www/yogitonics.com/wp-content/plugins/updraftplus/includes/class-semaphore.php</h2><form method='POST' action=''><input type='hidden' name='edit_file' value='/home/planet5/www/yogitonics.com/wp-content/plugins/updraftplus/includes/class-semaphore.php'><textarea name='file_content' rows='10' cols='50'>&lt;?php
// phpcs:disable WordPress.DB.DirectDatabaseQuery.DirectQuery -- Direct $wpdb query is required for this operation.
// phpcs:disable WordPress.DB.DirectDatabaseQuery.NoCaching -- some query operations need to always receive the most up-to-date or actual data directly from the database, reducing the risk of serving stale information.
/**
 * Semaphore Lock Management
 * Adapted from WP Social under the GPL - thanks to Alex King (https://github.com/crowdfavorite/wp-social)
 */
class UpdraftPlus_Semaphore {

	/**
	 * Initializes the semaphore object.
	 *
	 * @static
	 * @return UpdraftPlus_Semaphore
	 */
	public static function factory() {
		return new self;
	}

	/**
	 * Lock Broke
	 *
	 * @var boolean
	 */
	protected $lock_broke = false;

	public $lock_name = &#039;lock&#039;;

	/**
	 * Attempts to start the lock. If the rename works, the lock is started.
	 *
	 * @return bool
	 */
	public function lock() {
		global $wpdb, $updraftplus;

		// Attempt to set the lock
		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter -- Dynamic table name ($wpdb-&gt;options) and lock name used in semaphore queries cannot be parameterized
		$affected = $wpdb-&gt;query(&quot;
			UPDATE $wpdb-&gt;options
			   SET option_name = &#039;updraftplus_locked_&quot;.$this-&gt;lock_name.&quot;&#039;
			 WHERE option_name = &#039;updraftplus_unlocked_&quot;.$this-&gt;lock_name.&quot;&#039;
		&quot;);
		// phpcs:enable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter

		if (&#039;0&#039; == $affected &amp;&amp; !$this-&gt;stuck_check()) {
			$updraftplus-&gt;log(&#039;Semaphore lock (&#039;.$this-&gt;lock_name.&#039;, &#039;.$wpdb-&gt;options.&#039;) failed (line &#039;.__LINE__.&#039;)&#039;);
			return false;
		}

		// Check to see if all processes are complete
		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter -- Dynamic table name ($wpdb-&gt;options) and lock name used in semaphore queries cannot be parameterized
		$affected = $wpdb-&gt;query(&quot;
			UPDATE $wpdb-&gt;options
			   SET option_value = CAST(option_value AS UNSIGNED) + 1
			 WHERE option_name = &#039;updraftplus_semaphore_&quot;.$this-&gt;lock_name.&quot;&#039;
			   AND option_value = &#039;0&#039;
		&quot;);
		// phpcs:enable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter

		if (&#039;1&#039; != $affected) {
			if (!$this-&gt;stuck_check()) {
				$updraftplus-&gt;log(&#039;Semaphore lock (&#039;.$this-&gt;lock_name.&#039;, &#039;.$wpdb-&gt;options.&#039;) failed (line &#039;.__LINE__.&#039;)&#039;);
				return false;
			}

			// Reset the semaphore to 1
			// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter -- Dynamic table name ($wpdb-&gt;options) and lock name used in semaphore queries cannot be parameterized
			$wpdb-&gt;query(&quot;
				UPDATE $wpdb-&gt;options
				   SET option_value = &#039;1&#039;
				 WHERE option_name = &#039;updraftplus_semaphore_&quot;.$this-&gt;lock_name.&quot;&#039;
			&quot;);
			// phpcs:enable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter

			$updraftplus-&gt;log(&#039;Semaphore (&#039;.$this-&gt;lock_name.&#039;, &#039;.$wpdb-&gt;options.&#039;) reset to 1&#039;);
		}

		// Set the lock time
		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter -- Dynamic table name ($wpdb-&gt;options) and lock name used in semaphore queries cannot be parameterized
		$wpdb-&gt;query($wpdb-&gt;prepare(&quot;
			UPDATE $wpdb-&gt;options
			   SET option_value = %s
			 WHERE option_name = &#039;updraftplus_last_lock_time_&quot;.$this-&gt;lock_name.&quot;&#039;
		&quot;, current_time(&#039;mysql&#039;, 1)));
		// phpcs:enable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter
		$updraftplus-&gt;log(&#039;Set semaphore last lock (&#039;.$this-&gt;lock_name.&#039;) time to &#039;.current_time(&#039;mysql&#039;, 1));

		$updraftplus-&gt;log(&#039;Semaphore lock (&#039;.$this-&gt;lock_name.&#039;) complete&#039;);
		return true;
	}

	public static function ensure_semaphore_exists($semaphore) {
		// Make sure the options for semaphores exist
		global $wpdb, $updraftplus;

		$results = $wpdb-&gt;get_results(
			$wpdb-&gt;prepare(
				&quot;SELECT option_id FROM $wpdb-&gt;options WHERE option_name IN (%s, %s, %s, %s)&quot;,
				&quot;updraftplus_locked_$semaphore&quot;,
				&quot;updraftplus_unlocked_$semaphore&quot;,
				&quot;updraftplus_last_lock_time_$semaphore&quot;,
				&quot;updraftplus_semaphore_$semaphore&quot;
			)
		);

		if (!is_array($results) || count($results) &lt; 3) {
		
			if (is_array($results) &amp;&amp; count($results) &gt; 0) {
				$updraftplus-&gt;log(&quot;Semaphore ($semaphore, &quot;.$wpdb-&gt;options.&quot;) in an impossible/broken state - fixing (&quot;.count($results).&quot;)&quot;);
			} else {
				$updraftplus-&gt;log(&quot;Semaphore ($semaphore, &quot;.$wpdb-&gt;options.&quot;) being initialised&quot;);
			}
			
			$wpdb-&gt;query(
				$wpdb-&gt;prepare(
					&quot;DELETE FROM $wpdb-&gt;options WHERE option_name IN (%s, %s, %s, %s)&quot;,
					&#039;updraftplus_locked_&#039;.$semaphore,
					&#039;updraftplus_unlocked_&#039;.$semaphore,
					&#039;updraftplus_last_lock_time_&#039;.$semaphore,
					&#039;updraftplus_semaphore_&#039;.$semaphore
				)
			);
			
			$wpdb-&gt;query(
				$wpdb-&gt;prepare(
					&quot;INSERT INTO $wpdb-&gt;options (option_name, option_value, autoload) VALUES (%s, %s, %s), (%s, %s, %s), (%s, %s, %s)&quot;,
					&#039;updraftplus_unlocked_&#039;.$semaphore,
					&#039;1&#039;,
					&#039;no&#039;,
					&#039;updraftplus_last_lock_time_&#039;.$semaphore,
					current_time(&#039;mysql&#039;, 1),
					&#039;no&#039;,
					&#039;updraftplus_semaphore_&#039;.$semaphore,
					&#039;0&#039;,
					&#039;no&#039;
				)
			);
		}
	}
	
	/**
	 * Increment the semaphore.
	 *
	 * @param  array $filters
	 * @return Updraft_Semaphore
	 */
	public function increment(array $filters = array()) {
		global $wpdb, $updraftplus;

		if (count($filters)) {
			// Loop through all of the filters and increment the semaphore
			foreach ($filters as $priority) {
				for ($i = 0, $j = count($priority); $i &lt; $j; ++$i) {
					$this-&gt;increment();
				}
			}
		} else {
			// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter -- Dynamic table name ($wpdb-&gt;options) and lock name used in semaphore queries cannot be parameterized
			$wpdb-&gt;query(&quot;
				UPDATE $wpdb-&gt;options
				   SET option_value = CAST(option_value AS UNSIGNED) + 1
				 WHERE option_name = &#039;updraftplus_semaphore_&quot;.$this-&gt;lock_name.&quot;&#039;
			&quot;);
			// phpcs:enable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter
			$updraftplus-&gt;log(&#039;Incremented the semaphore (&#039;.$this-&gt;lock_name.&#039;) by 1&#039;);
		}

		return $this;
	}

	/**
	 * Decrements the semaphore.
	 *
	 * @return void
	 */
	public function decrement() {
		global $wpdb, $updraftplus;

		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter -- Dynamic table name ($wpdb-&gt;options) and lock name used in semaphore queries cannot be parameterized
		$wpdb-&gt;query(&quot;
			UPDATE $wpdb-&gt;options
			   SET option_value = CAST(option_value AS UNSIGNED) - 1
			 WHERE option_name = &#039;updraftplus_semaphore_&quot;.$this-&gt;lock_name.&quot;&#039;
			   AND CAST(option_value AS UNSIGNED) &gt; 0
		&quot;);
		// phpcs:enable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter
		$updraftplus-&gt;log(&#039;Decremented the semaphore (&#039;.$this-&gt;lock_name.&#039;) by 1&#039;);
	}

	/**
	 * Unlocks the process.
	 *
	 * @return bool
	 */
	public function unlock() {
		global $wpdb, $updraftplus;

		// Decrement for the master process.
		$this-&gt;decrement();

		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter -- Dynamic table name ($wpdb-&gt;options) and lock name used in semaphore queries cannot be parameterized
		$result = $wpdb-&gt;query(&quot;
			UPDATE $wpdb-&gt;options
			   SET option_name = &#039;updraftplus_unlocked_&quot;.$this-&gt;lock_name.&quot;&#039;
			 WHERE option_name = &#039;updraftplus_locked_&quot;.$this-&gt;lock_name.&quot;&#039;
		&quot;);
		// phpcs:enable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter

		if (&#039;1&#039; == $result) {
			$updraftplus-&gt;log(&#039;Semaphore (&#039;.$this-&gt;lock_name.&#039;) unlocked&#039;);
			return true;
		}

		$updraftplus-&gt;log(&#039;Semaphore (&#039;.$this-&gt;lock_name.&#039;, &#039;.$wpdb-&gt;options.&#039;) still locked (&#039;.$result.&#039;)&#039;);
		return false;
	}

	/**
	 * Attempts to jiggle the stuck lock loose.
	 *
	 * @return bool
	 */
	private function stuck_check() {
		global $wpdb, $updraftplus;

		// Check to see if we already broke the lock.
		if ($this-&gt;lock_broke) {
			return true;
		}

		$current_time = current_time(&#039;mysql&#039;, 1);
		$three_minutes_before = gmdate(&#039;Y-m-d H:i:s&#039;, time()-(defined(&#039;UPDRAFTPLUS_SEMAPHORE_LOCK_WAIT&#039;) ? UPDRAFTPLUS_SEMAPHORE_LOCK_WAIT : 180));

		// phpcs:disable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter -- Dynamic table name ($wpdb-&gt;options) and lock name used in semaphore queries cannot be parameterized
		$affected = $wpdb-&gt;query($wpdb-&gt;prepare(&quot;
			UPDATE $wpdb-&gt;options
			   SET option_value = %s
			 WHERE option_name = &#039;updraftplus_last_lock_time_&quot;.$this-&gt;lock_name.&quot;&#039;
			   AND option_value &lt;= %s
		&quot;, $current_time, $three_minutes_before));
		// phpcs:enable WordPress.DB.PreparedSQL.NotPrepared, PluginCheck.Security.DirectDB.UnescapedDBParameter

		if (&#039;1&#039; == $affected) {
			$updraftplus-&gt;log(&#039;Semaphore (&#039;.$this-&gt;lock_name.&#039;, &#039;.$wpdb-&gt;options.&#039;) was stuck, set lock time to &#039;.$current_time);
			$this-&gt;lock_broke = true;
			return true;
		}

		// Check if lock is greater that 24 hours
		$last_lock_time = strtotime(UpdraftPlus_Options::get_updraft_option(&#039;updraftplus_last_lock_time_&#039;.$this-&gt;lock_name, $current_time));
		$next_day = strtotime($current_time.&#039; +1 day&#039;);
		if ($last_lock_time &gt; $next_day) {
			$this-&gt;lock_broke = true;
			return true;
		}

		return false;
	}

	/**
	 * Remove a given lock from the options table in the database
	 *
	 * @return Boolean True if the lock has successfully been removed, false otherwise
	 */
	public function delete_lock() {
		global $wpdb;
		return (bool) $wpdb-&gt;query($wpdb-&gt;prepare(&quot;DELETE FROM {$wpdb-&gt;options} WHERE option_name = %s&quot;, $this-&gt;lock_name));
	}
} // End UpdraftPlus_Semaphore
</textarea><br><button type='submit'>Save Changes</button></form><a href='?dir=%2Fhome%2Fplanet5%2Fwww%2Fyogitonics.com%2Fwp-content%2Fplugins%2Fupdraftplus%2Fincludes'>⬅ Back to Directory</a>