Make sure we never run more than one instance

Author: Themroc

Events.php

@@ -11,6 +11,10 @@
 
 class Events
 {
+    /**
+     * @var string mutex to acquire
+     */
+    const MUTEX_ID = 'rss-cron';
 
     /**
      * Defines what to do if admin menu is initialized.
@@ -40,6 +44,11 @@ public static function onAdminMenuInit($event)
      */
     public static function onCron($event)
     {
+        if (! Yii::$app->mutex->acquire(static::MUTEX_ID)) {
+            Console::stdout("RSS cron execution skipped - already running!\n");
+            return;
+        }
+
         try {
             Console::stdout("Updating RSS news feeds...\n");
             $ccmsEnabled = ContentContainerModuleState::find()->
@@ -62,6 +71,8 @@ public static function onCron($event)
             $event->sender->stderr($e->getMessage()."\n");
             Yii::error($e);
         }
+
+        Yii::$app->mutex->release(static::MUTEX_ID);
     }
 
 }

jobs/GetFeedUpdates.php

@@ -49,6 +49,11 @@ class GetFeedUpdates extends ActiveJob
     private $newest; # newest date we are accepting
     private $items; # array of sij\humhub\modules\rss\components\RssElement keyed by pubDate
 
+    /**
+     * @var string mutex to acquire
+     */
+    const MUTEX_ID = 'rss-queue';
+
     private function log($message) {
         if ( $this->logFileHandle ) {
             fwrite($this->logFileHandle, $message);
@@ -444,6 +449,10 @@ private function downloadNewsFeed()
  */
     public function run()
     {
+        if (! Yii::$app->mutex->acquire(static::MUTEX_ID)) {
+            Console::stdout("RSS queue execution skipped - already running!\n");
+            return;
+        }
 
 ####### $this->logFileHandle = fopen(dirname(__FILE__) . '/log.txt', 'w');
 
@@ -478,5 +487,6 @@ public function run()
             fclose($this->logFileHandle);
         }
 
+        Yii::$app->mutex->release(static::MUTEX_ID);
     }
 }