added a parameter to customise a lock name for the aggregating jobs s…

…cript

CHANGELOG.md

@@ -4,6 +4,12 @@
 
 There are next changes:
 
+## 1.2.10
+
+There are next changes:
+
+- added a parameter to customise a lock name for the aggregating jobs script
+
 ## 1.2.9
 
 There are next changes:

src/Badoo/LiveProfilerUI/ConsoleCommands/ProcessAggregatingJobsCommand.php

@@ -28,7 +28,11 @@ protected function configure()
      */
     protected function execute(InputInterface $input, OutputInterface $output)
     {
-        $lock_filename = '/tmp/aggregator_processor.lock';
+        $output->writeln($this->getName() . ' started');
+
+        $App = new \Badoo\LiveProfilerUI\LiveProfilerUI();
+
+        $lock_filename = $App->getAggregatingJobsLockFile();
         !file_exists($lock_filename) && touch($lock_filename);
         $lock_fp = fopen($lock_filename, 'rb+');
         if (!flock($lock_fp, LOCK_EX | LOCK_NB)) {
@@ -38,10 +42,6 @@ protected function execute(InputInterface $input, OutputInterface $output)
 
         ini_set('memory_limit', '1G');
 
-        $output->writeln($this->getName() . ' started');
-
-        $App = new \Badoo\LiveProfilerUI\LiveProfilerUI();
-
         $JobStorage = $App->getJobDataProvider();
 
         $started_ts = time();

src/Badoo/LiveProfilerUI/LiveProfilerUI.php

@@ -170,4 +170,13 @@ public function isUseJobsInAggregation() : bool
     {
         return (bool)$this->getContainer()->getParameter('aggregator.use_jobs_in_aggregation');
     }
+
+    /**
+     * @return string
+     * @throws \Exception
+     */
+    public function getAggregatingJobsLockFile() : string
+    {
+        return (string)$this->getContainer()->getParameter('aggregator.aggregating_jobs_lock_file');
+    }
 }

src/config/services.yaml

@@ -7,6 +7,7 @@ parameters:
   aggregator.use_layout: true
   aggregator.log_file: ''
   aggregator.minimum_profiles_count: 0
+  aggregator.aggregating_jobs_lock_file: /app/db_data/aggregator_processor.lock
 
   aggregator.fields_descriptions:
     ct: Average calls count in this context during specified day (µs)