@@ -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) ) { |