1 | <?php |
||
8 | class Fork |
||
9 | { |
||
10 | /** @var int */ |
||
11 | private $pid; |
||
12 | |||
13 | /** @var \Ackintosh\Snidel\Pcntl */ |
||
14 | private $pcntl; |
||
15 | |||
16 | /** @var int */ |
||
17 | private $status; |
||
18 | |||
19 | /** @var callable */ |
||
20 | private $callable; |
||
21 | |||
22 | /** @var array */ |
||
23 | private $args; |
||
24 | |||
25 | /** @var \Ackintosh\Snidel\Result */ |
||
26 | private $result; |
||
27 | |||
28 | /** @var string */ |
||
29 | private $tag; |
||
30 | |||
31 | /** @var \Ackintosh\Snidel\Task */ |
||
32 | private $task; |
||
33 | |||
34 | /** @var string */ |
||
35 | private $serializedTask; |
||
36 | |||
37 | /** @var bool */ |
||
38 | private $queued = false; |
||
39 | |||
40 | /** |
||
41 | * @param int $pid |
||
42 | */ |
||
43 | public function __construct($pid, $task) |
||
49 | |||
50 | /** |
||
51 | * set exit status |
||
52 | * |
||
53 | * @param int $status |
||
54 | * @return void |
||
55 | */ |
||
56 | public function setStatus($status) |
||
60 | |||
61 | /** |
||
62 | * return pid |
||
63 | * |
||
64 | * @return int |
||
65 | */ |
||
66 | public function getPid() |
||
70 | |||
71 | /** |
||
72 | * return exit status |
||
73 | * |
||
74 | * @return int |
||
75 | */ |
||
76 | public function getStatus() |
||
80 | |||
81 | /** |
||
82 | * set callable |
||
83 | * |
||
84 | * @param callable $callable |
||
85 | * @return void |
||
86 | */ |
||
87 | public function setCallable($callable) |
||
91 | |||
92 | public function getCallable() |
||
96 | |||
97 | /** |
||
98 | * set arguments |
||
99 | * |
||
100 | * @param array $args |
||
101 | * @return void |
||
102 | */ |
||
103 | public function setArgs($args) |
||
107 | |||
108 | public function getArgs() |
||
112 | |||
113 | /** |
||
114 | * @return bool |
||
115 | */ |
||
116 | public function hasFinishedSuccessfully() |
||
120 | |||
121 | /** |
||
122 | * @return bool |
||
123 | */ |
||
124 | public function hasNotFinishedSuccessfully() |
||
128 | |||
129 | /** |
||
130 | * |
||
131 | * @param \Ackintosh\Snidel\Result |
||
132 | * @return void |
||
133 | */ |
||
134 | public function setResult($result) |
||
138 | |||
139 | /** |
||
140 | * return result |
||
141 | * |
||
142 | * @return \Ackintosh\Snidel\Result |
||
143 | */ |
||
144 | public function getResult() |
||
148 | |||
149 | public function hasNoResult() |
||
153 | |||
154 | /** |
||
155 | * @param string $tag |
||
156 | * @return void |
||
157 | */ |
||
158 | public function setTag($tag) |
||
162 | |||
163 | /** |
||
164 | * @return string |
||
165 | */ |
||
166 | public function getTag() |
||
170 | |||
171 | /** |
||
172 | * @return void |
||
173 | */ |
||
174 | public function setQueued() |
||
178 | |||
179 | /** |
||
180 | * @return bool |
||
181 | */ |
||
182 | public function isQueued() |
||
186 | |||
187 | public function executeTask() |
||
195 | |||
196 | /** |
||
197 | * @param \Ackintosh\Snidel\Fork $fork |
||
198 | * @return string |
||
199 | */ |
||
200 | public static function serialize($fork) |
||
206 | |||
207 | /** |
||
208 | * @return void |
||
209 | */ |
||
210 | private function serializeTask() |
||
215 | |||
216 | /** |
||
217 | * @param string $serializedFork |
||
218 | * @return \Ackintosh\Snidel\Fork |
||
219 | */ |
||
220 | public static function unserialize($serializedFork) |
||
227 | |||
228 | /** |
||
229 | * @return void |
||
230 | */ |
||
231 | private function unserializeTask() |
||
236 | } |
||
237 |