@@ -50,15 +50,15 @@ |
||
| 50 | 50 | } |
| 51 | 51 | $pid = getmypid(); |
| 52 | 52 | switch (true) { |
| 53 | - case $this->ownerPid === $pid: |
|
| 54 | - $role = 'owner'; |
|
| 55 | - break; |
|
| 56 | - case $this->masterPid === $pid: |
|
| 57 | - $role = 'master'; |
|
| 58 | - break; |
|
| 59 | - default: |
|
| 60 | - $role = 'worker'; |
|
| 61 | - break; |
|
| 53 | + case $this->ownerPid === $pid: |
|
| 54 | + $role = 'owner'; |
|
| 55 | + break; |
|
| 56 | + case $this->masterPid === $pid: |
|
| 57 | + $role = 'master'; |
|
| 58 | + break; |
|
| 59 | + default: |
|
| 60 | + $role = 'worker'; |
|
| 61 | + break; |
|
| 62 | 62 | } |
| 63 | 63 | fputs( |
| 64 | 64 | $this->destination, |
@@ -7,10 +7,7 @@ |
||
| 7 | 7 | use Ackintosh\Snidel\Result\Result; |
| 8 | 8 | use Ackintosh\Snidel\Log; |
| 9 | 9 | use Ackintosh\Snidel\Pcntl; |
| 10 | -use Ackintosh\Snidel\DataRepository; |
|
| 11 | -use Ackintosh\Snidel\MapContainer; |
|
| 12 | 10 | use Ackintosh\Snidel\Task\Task; |
| 13 | -use Ackintosh\Snidel\Exception\SharedMemoryControlException; |
|
| 14 | 11 | |
| 15 | 12 | class Snidel |
| 16 | 13 | { |
@@ -4,13 +4,10 @@ |
||
| 4 | 4 | use Ackintosh\Snidel\Config; |
| 5 | 5 | use Ackintosh\Snidel\Fork\Fork; |
| 6 | 6 | use Ackintosh\Snidel\Pcntl; |
| 7 | -use Ackintosh\Snidel\Task\Queue as TaskQueue; |
|
| 8 | 7 | use Ackintosh\Snidel\QueueFactory; |
| 9 | 8 | use Ackintosh\Snidel\Result\Result; |
| 10 | -use Ackintosh\Snidel\Result\Queue as ResultQueue; |
|
| 11 | 9 | use Ackintosh\Snidel\Result\Collection; |
| 12 | 10 | use Ackintosh\Snidel\Error; |
| 13 | -use Ackintosh\Snidel\Exception\SharedMemoryControlException; |
|
| 14 | 11 | use Ackintosh\Snidel\Worker; |
| 15 | 12 | use Ackintosh\Snidel\ActiveWorkerSet; |
| 16 | 13 | |