@@ -366,6 +366,9 @@ |
||
| 366 | 366 | |
| 367 | 367 | } |
| 368 | 368 | |
| 369 | + /** |
|
| 370 | + * @param string $status |
|
| 371 | + */ |
|
| 369 | 372 | private function open(Connection $client, $status) { |
| 370 | 373 | |
| 371 | 374 | $idx = $client->getIndex(); |
@@ -145,6 +145,9 @@ |
||
| 145 | 145 | |
| 146 | 146 | } |
| 147 | 147 | |
| 148 | + /** |
|
| 149 | + * @param integer $status |
|
| 150 | + */ |
|
| 148 | 151 | private function setStatus($status) { |
| 149 | 152 | $this->status = $status; |
| 150 | 153 | return $this->worker->getInputChannel()->send($status); |
@@ -79,6 +79,9 @@ discard block |
||
| 79 | 79 | |
| 80 | 80 | } |
| 81 | 81 | |
| 82 | + /** |
|
| 83 | + * @param integer $pid |
|
| 84 | + */ |
|
| 82 | 85 | public function setPid($name, $pid) { |
| 83 | 86 | |
| 84 | 87 | if ( !$this->isInstalled($name) ) { |
@@ -91,6 +94,9 @@ discard block |
||
| 91 | 94 | |
| 92 | 95 | } |
| 93 | 96 | |
| 97 | + /** |
|
| 98 | + * @return Worker |
|
| 99 | + */ |
|
| 94 | 100 | public function get($name = null) { |
| 95 | 101 | |
| 96 | 102 | if ( is_null($name) ) return $this->data; |
@@ -44,6 +44,9 @@ discard block |
||
| 44 | 44 | |
| 45 | 45 | } |
| 46 | 46 | |
| 47 | + /** |
|
| 48 | + * @param WorkerInterface $instance |
|
| 49 | + */ |
|
| 47 | 50 | public function setInstance($instance) { |
| 48 | 51 | |
| 49 | 52 | $this->instance = $instance; |
@@ -58,6 +61,9 @@ discard block |
||
| 58 | 61 | |
| 59 | 62 | } |
| 60 | 63 | |
| 64 | + /** |
|
| 65 | + * @param integer $looptime |
|
| 66 | + */ |
|
| 61 | 67 | public function setLooptime($looptime) { |
| 62 | 68 | |
| 63 | 69 | $this->looptime = $looptime; |
@@ -72,6 +78,9 @@ discard block |
||
| 72 | 78 | |
| 73 | 79 | } |
| 74 | 80 | |
| 81 | + /** |
|
| 82 | + * @param boolean $forever |
|
| 83 | + */ |
|
| 75 | 84 | public function setForever($forever) { |
| 76 | 85 | |
| 77 | 86 | $this->forever = $forever; |
@@ -86,6 +95,9 @@ discard block |
||
| 86 | 95 | |
| 87 | 96 | } |
| 88 | 97 | |
| 98 | + /** |
|
| 99 | + * @param SharedMemory $input |
|
| 100 | + */ |
|
| 89 | 101 | public function setInputChannel($input) { |
| 90 | 102 | |
| 91 | 103 | $this->input_channel = $input; |
@@ -100,6 +112,9 @@ discard block |
||
| 100 | 112 | |
| 101 | 113 | } |
| 102 | 114 | |
| 115 | + /** |
|
| 116 | + * @param SharedMemory $output |
|
| 117 | + */ |
|
| 103 | 118 | public function setOutputChannel($output) { |
| 104 | 119 | |
| 105 | 120 | $this->output_channel = $output; |