@@ -37,7 +37,7 @@ discard block |
||
37 | 37 | $this->container = new Container($this->config, $this->log); |
38 | 38 | $this->container->forkMaster(); |
39 | 39 | $this->registerSignalHandler($this->container, $this->log); |
40 | - $this->log->info('parent pid: ' . $this->config->get('ownerPid')); |
|
40 | + $this->log->info('parent pid: '.$this->config->get('ownerPid')); |
|
41 | 41 | } |
42 | 42 | |
43 | 43 | /** |
@@ -54,11 +54,11 @@ discard block |
||
54 | 54 | try { |
55 | 55 | $this->container->enqueue(new Task($callable, $args, $tag)); |
56 | 56 | } catch (\RuntimeException $e) { |
57 | - $this->log->error('failed to enqueue the task: ' . $e->getMessage()); |
|
57 | + $this->log->error('failed to enqueue the task: '.$e->getMessage()); |
|
58 | 58 | throw $e; |
59 | 59 | } |
60 | 60 | |
61 | - $this->log->info('queued task #' . $this->container->queuedCount()); |
|
61 | + $this->log->info('queued task #'.$this->container->queuedCount()); |
|
62 | 62 | } |
63 | 63 | |
64 | 64 | /** |
@@ -78,7 +78,7 @@ discard block |
||
78 | 78 | */ |
79 | 79 | public function results() |
80 | 80 | { |
81 | - foreach($this->container->results() as $r) { |
|
81 | + foreach ($this->container->results() as $r) { |
|
82 | 82 | yield $r; |
83 | 83 | } |
84 | 84 | } |
@@ -109,8 +109,8 @@ discard block |
||
109 | 109 | foreach ($this->signals as $sig) { |
110 | 110 | $pcntl->signal( |
111 | 111 | $sig, |
112 | - function ($sig) use ($log, $container) { |
|
113 | - $log->info('received signal. signo: ' . $sig); |
|
112 | + function($sig) use ($log, $container) { |
|
113 | + $log->info('received signal. signo: '.$sig); |
|
114 | 114 | $log->info('--> sending a signal " to children.'); |
115 | 115 | $container->sendSignalToMaster($sig); |
116 | 116 | $log->info('<-- signal handling has been completed successfully.'); |