| @@ -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; | 
| @@ -114,6 +114,9 @@ discard block | ||
| 114 | 114 | |
| 115 | 115 | } | 
| 116 | 116 | |
| 117 | + /** | |
| 118 | + * @param string $content_type | |
| 119 | + */ | |
| 117 | 120 |      protected function send($content_type, $data) { | 
| 118 | 121 | |
| 119 | 122 | $sent = $this->write($content_type, $data); | 
| @@ -199,6 +202,10 @@ discard block | ||
| 199 | 202 | |
| 200 | 203 | } | 
| 201 | 204 | |
| 205 | + /** | |
| 206 | + * @param string $data | |
| 207 | + * @param boolean $key | |
| 208 | + */ | |
| 202 | 209 |      private function can($data, $key) { | 
| 203 | 210 | |
| 204 | 211 |          if ( !empty($key) && is_string($key) ) { | 
| @@ -219,6 +226,9 @@ discard block | ||
| 219 | 226 | |
| 220 | 227 | } | 
| 221 | 228 | |
| 229 | + /** | |
| 230 | + * @param boolean $key | |
| 231 | + */ | |
| 222 | 232 |      private function uncan($data, $key) { | 
| 223 | 233 | |
| 224 | 234 |          if ( !empty($key) && is_string($key) ) { |