@@ -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; |