ackintosh / snidel

src/Snidel/Log.php

Switch Indentation +9 added lines, -9 removed lines

@@ -50,15 +50,15 @@
         }
         $pid = getmypid();
         switch (true) {
-        case $this->ownerPid === $pid:
-            $role = 'owner';
-            break;
-        case $this->masterPid === $pid:
-            $role = 'master';
-            break;
-        default:
-            $role = 'worker';
-            break;
+            case $this->ownerPid === $pid:
+                $role = 'owner';
+                break;
+            case $this->masterPid === $pid:
+                $role = 'master';
+                break;
+            default:
+                $role = 'worker';
+                break;
         }
         fputs(
             $this->destination,

Spacing +1 added lines, -1 removed lines

@@ -70,7 +70,7 @@
                 $type,
                 $pid,
                 $role,
-                $message . PHP_EOL
+                $message.PHP_EOL
             )
         );
     }

src/Snidel/Result/Collection.php

Spacing +1 added lines, -1 removed lines

@@ -26,7 +26,7 @@
     public function toArray()
     {
         return array_map(
-            function ($result) {
+            function($result) {
                 return $result->getReturn();
             },
             $this->results

src/Snidel.php

Spacing +5 added lines, -5 removed lines

@@ -60,8 +60,8 @@ 
         foreach ($this->signals as $sig) {
             $this->pcntl->signal(
                 $sig,
-                function ($sig) use($log, $self) {
-                    $log->info('received signal. signo: ' . $sig);
+                function($sig) use($log, $self) {
+                    $log->info('received signal. signo: '.$sig);
                     $self->setReceivedSignal($sig);
 
                     $log->info('--> sending a signal " to children.');
@@ -73,7 +73,7 @@ 
             );
         }
 
-        $this->log->info('parent pid: ' . $this->ownerPid);
+        $this->log->info('parent pid: '.$this->ownerPid);
     }
 
     /**
@@ -111,7 +111,7 @@ 
             throw $e;
         }
 
-        $this->log->info('queued task #' . $this->container->queuedCount());
+        $this->log->info('queued task #'.$this->container->queuedCount());
     }
 
     /**
@@ -154,7 +154,7 @@ 
             $this->wait();
         }
         if ($tag !== null && !$this->container->hasTag($tag)) {
-            throw new \InvalidArgumentException('unknown tag: ' . $tag);
+            throw new \InvalidArgumentException('unknown tag: '.$tag);
         }
 
         return $this->container->getCollection($tag);

Unused Use Statements -2 removed lines

@@ -7,8 +7,6 @@
 use Ackintosh\Snidel\Fork\Container;
 use Ackintosh\Snidel\Log;
 use Ackintosh\Snidel\Pcntl;
-use Ackintosh\Snidel\DataRepository;
-use Ackintosh\Snidel\MapContainer;
 use Ackintosh\Snidel\Task\Task;
 
 class Snidel

src/Snidel/IpcKey.php

Spacing +1 added lines, -1 removed lines

@@ -20,7 +20,7 @@
     {
         $this->ownerPid = $ownerPid;
         $this->prefix   = $prefix;
-        $this->pathname = sys_get_temp_dir() . DIRECTORY_SEPARATOR . $this->prefix . $this->ownerPid;
+        $this->pathname = sys_get_temp_dir().DIRECTORY_SEPARATOR.$this->prefix.$this->ownerPid;
     }
 
     /**

src/Snidel/Fork/Container.php

Doc Comments +6 added lines, -1 removed lines

@@ -53,6 +53,7 @@ 
 
     /**
      * @param   int     $ownerPid
+     * @param \Ackintosh\Snidel\Log $log
      */
     public function __construct($ownerPid, $log, Config $config)
     {
@@ -66,6 +67,7 @@ 
 
     /**
      * @param   \Ackintosh\Snidel\Task
+     * @param \Ackintosh\Snidel\Task\Task $task
      * @return  void
      * @throws  \RuntimeException
      */
@@ -91,7 +93,7 @@ 
     }
 
     /**
-     * @return  \Ackintosh\Snidel\Fork\Fork
+     * @return  \Ackintosh\Snidel\Result\Result
      */
     private function dequeue()
     {
@@ -310,6 +312,9 @@ 
         }
     }
 
+    /**
+     * @param string $tag
+     */
     public function getCollection($tag = null)
     {
         if ($tag === null) {

Spacing +12 added lines, -12 removed lines

@@ -146,7 +146,7 @@ 
 
         if (getmypid() === $this->ownerPid) {
             // owner
-            $this->log->info('pid: ' . getmypid());
+            $this->log->info('pid: '.getmypid());
             $this->taskQueue    = $this->queueFactory->createTaskQueue();
             $this->resultQueue  = $this->queueFactory->createResultQueue();
 
@@ -154,20 +154,20 @@ 
         } else {
             // master
             $activeWorkerSet = new ActiveWorkerSet();
-            $this->log->info('pid: ' . $this->masterPid);
+            $this->log->info('pid: '.$this->masterPid);
 
             // for php5.3
             $log = $this->log;
             $receivedSignal = &$this->receivedSignal;
             foreach ($this->signals as $sig) {
-                $this->pcntl->signal($sig, function ($sig) use ($log, $activeWorkerSet, $receivedSignal) {
+                $this->pcntl->signal($sig, function($sig) use ($log, $activeWorkerSet, $receivedSignal) {
                     $receivedSignal = $sig;
-                    $log->info('received signal: ' . $sig);
+                    $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');
                     }
@@ -175,7 +175,7 @@ 
                 });
             }
 
-            $concurrency = (int)$this->config->get('concurrency');
+            $concurrency = (int) $this->config->get('concurrency');
             for ($i = 0; $i < $concurrency; $i++) {
                 $activeWorkerSet->add($this->forkWorker());
             }
@@ -212,17 +212,17 @@ 
 
         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());
 
             // for php5.3
             $receivedSignal = &$this->receivedSignal;
             foreach ($this->signals as $sig) {
-                $this->pcntl->signal($sig, function ($sig) use ($receivedSignal) {
+                $this->pcntl->signal($sig, function($sig) use ($receivedSignal) {
                     $receivedSignal = $sig;
                     exit;
                 }, false);
@@ -231,7 +231,7 @@ 
             $worker->setTaskQueue($this->queueFactory->createTaskQueue());
             $worker->setResultQueue($this->queueFactory->createResultQueue());
 
-            register_shutdown_function(function () use ($worker, $receivedSignal) {
+            register_shutdown_function(function() use ($worker, $receivedSignal) {
                 if ($worker->isFailedToEnqueueResult() && $receivedSignal === null) {
                     $worker->error();
                 }
@@ -267,14 +267,14 @@ 
      */
     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.');
 
         $this->log->info('----> waiting for master shutdown.');
         $status = null;
         $this->pcntl->waitpid($this->masterPid, $status);
-        $this->log->info('<---- master shutdown. status: ' . $status);
+        $this->log->info('<---- master shutdown. status: '.$status);
         $this->masterPid = null;
     }
 

src/Snidel/AbstractQueue.php

Spacing +1 added lines, -1 removed lines

@@ -1,5 +1,5 @@
 <?php
-declare(ticks=1);
+declare(ticks = 1);
 
 namespace Ackintosh\Snidel;