ackintosh / snidel

src/Snidel/Fork/Container.php

Unused Use Statements -3 removed lines

@@ -4,13 +4,10 @@
 use Ackintosh\Snidel\Config;
 use Ackintosh\Snidel\Fork\Fork;
 use Ackintosh\Snidel\Pcntl;
-use Ackintosh\Snidel\Task\Queue as TaskQueue;
 use Ackintosh\Snidel\QueueFactory;
 use Ackintosh\Snidel\Result\Result;
-use Ackintosh\Snidel\Result\Queue as ResultQueue;
 use Ackintosh\Snidel\Result\Collection;
 use Ackintosh\Snidel\Error;
-use Ackintosh\Snidel\Exception\SharedMemoryControlException;
 use Ackintosh\Snidel\Worker;
 use Ackintosh\Snidel\ActiveWorkerSet;
 

Spacing +12 added lines, -12 removed lines

@@ -140,24 +140,24 @@ 
 
         if (getmypid() === $this->ownerPid) {
             // owner
-            $this->log->info('pid: ' . getmypid());
+            $this->log->info('pid: '.getmypid());
 
             return $this->masterPid;
         } else {
             // master
             $taskQueue          = $this->queueFactory->createTaskQueue();
             $activeWorkerSet    = new ActiveWorkerSet();
-            $this->log->info('pid: ' . $this->masterPid);
+            $this->log->info('pid: '.$this->masterPid);
 
             $log = $this->log;
             foreach ($this->signals as $sig) {
-                $this->pcntl->signal($sig, function ($sig) use ($log, $activeWorkerSet) {
-                    $log->info('received signal: ' . $sig);
+                $this->pcntl->signal($sig, function($sig) use ($log, $activeWorkerSet) {
+                    $log->info('received signal: '.$sig);
 
                     if ($activeWorkerSet->count() === 0) {
                         $log->info('no worker is active.');
                     } else {
-                        $log->info('------> sending signal to workers. signal: ' . $sig);
+                        $log->info('------> sending signal to workers. signal: '.$sig);
                         $activeWorkerSet->terminate($sig);
                         $log->info('<------ sent signal');
                     }
@@ -165,9 +165,9 @@ 
                 });
             }
 
-            $concurrency = (int)$this->config->get('concurrency');
+            $concurrency = (int) $this->config->get('concurrency');
             while ($task = $taskQueue->dequeue()) {
-                $this->log->info('dequeued task #' . $taskQueue->dequeuedCount());
+                $this->log->info('dequeued task #'.$taskQueue->dequeuedCount());
                 if ($activeWorkerSet->count() >= $concurrency) {
                     $status = null;
                     $workerPid = $this->pcntl->waitpid(-1, $status);
@@ -201,12 +201,12 @@ 
 
         if (getmypid() === $this->masterPid) {
             // master
-            $this->log->info('forked worker. pid: ' . $worker->getPid());
+            $this->log->info('forked worker. pid: '.$worker->getPid());
             return $worker;
         } else {
             // worker
             // @codeCoverageIgnoreStart
-            $this->log->info('has forked. pid: ' . getmypid());
+            $this->log->info('has forked. pid: '.getmypid());
 
             foreach ($this->signals as $sig) {
                 $this->pcntl->signal($sig, SIG_DFL, true);
@@ -215,7 +215,7 @@ 
             $worker->setResultQueue($this->queueFactory->createResultQueue());
 
             $resultHasQueued = false;
-            register_shutdown_function(function () use (&$resultHasQueued, $worker) {
+            register_shutdown_function(function() use (&$resultHasQueued, $worker) {
                 if (!$resultHasQueued) {
                     $worker->error();
                 }
@@ -252,13 +252,13 @@ 
      */
     public function sendSignalToMaster($sig = SIGTERM)
     {
-        $this->log->info('----> sending signal to master. signal: ' . $sig);
+        $this->log->info('----> sending signal to master. signal: '.$sig);
         posix_kill($this->masterPid, $sig);
         $this->log->info('<---- sent signal.');
 
         $status = null;
         $this->pcntl->waitpid($this->masterPid, $status);
-        $this->log->info('. status: ' . $status);
+        $this->log->info('. status: '.$status);
         $this->masterPid = null;
     }