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