@@ -26,6 +26,9 @@ discard block |
||
26 | 26 | return $this->pid; |
27 | 27 | } |
28 | 28 | |
29 | + /** |
|
30 | + * @return resource |
|
31 | + */ |
|
29 | 32 | public function socket() |
30 | 33 | { |
31 | 34 | return $this->socket; |
@@ -89,6 +92,9 @@ discard block |
||
89 | 92 | return call_user_func_array($this->timeoutCallback, [$output]); |
90 | 93 | } |
91 | 94 | |
95 | + /** |
|
96 | + * @param string $internalId |
|
97 | + */ |
|
92 | 98 | public function setInternalId($internalId): self |
93 | 99 | { |
94 | 100 | $this->internalId = $internalId; |
@@ -96,6 +102,9 @@ discard block |
||
96 | 102 | return $this; |
97 | 103 | } |
98 | 104 | |
105 | + /** |
|
106 | + * @param integer $pid |
|
107 | + */ |
|
99 | 108 | public function setPid($pid): self |
100 | 109 | { |
101 | 110 | $this->pid = $pid; |
@@ -110,6 +119,9 @@ discard block |
||
110 | 119 | return $this; |
111 | 120 | } |
112 | 121 | |
122 | + /** |
|
123 | + * @param integer $startTime |
|
124 | + */ |
|
113 | 125 | public function setStartTime($startTime): self |
114 | 126 | { |
115 | 127 | $this->startTime = $startTime; |
@@ -55,6 +55,9 @@ |
||
55 | 55 | return true; |
56 | 56 | } |
57 | 57 | |
58 | + /** |
|
59 | + * @param integer $status |
|
60 | + */ |
|
58 | 61 | public function handleRunningProcess(Process $process, $status): bool |
59 | 62 | { |
60 | 63 | if ($process->startTime() + $this->maximumExecutionTime < time() || pcntl_wifstopped($status)) { |