@@ -48,6 +48,9 @@ discard block |
||
| 48 | 48 | |
| 49 | 49 | } |
| 50 | 50 | |
| 51 | + /** |
|
| 52 | + * @param integer $uid |
|
| 53 | + */ |
|
| 51 | 54 | public function init($uid) { |
| 52 | 55 | |
| 53 | 56 | $this->ipc[$uid] = []; |
@@ -72,6 +75,10 @@ discard block |
||
| 72 | 75 | |
| 73 | 76 | } |
| 74 | 77 | |
| 78 | + /** |
|
| 79 | + * @param integer $uid |
|
| 80 | + * @param string $data |
|
| 81 | + */ |
|
| 75 | 82 | public function write($uid, $data) { |
| 76 | 83 | |
| 77 | 84 | $writer = $this->ipc[$uid][self::WRITER]; |
@@ -136,7 +136,7 @@ discard block |
||
| 136 | 136 | /** |
| 137 | 137 | * Get cron expression of this schedule |
| 138 | 138 | * |
| 139 | - * @return string |
|
| 139 | + * @return CronExpression |
|
| 140 | 140 | */ |
| 141 | 141 | public function getExpression() { |
| 142 | 142 | |
@@ -147,7 +147,7 @@ discard block |
||
| 147 | 147 | /** |
| 148 | 148 | * set cron expression for this schedule |
| 149 | 149 | * |
| 150 | - * @param srting $expression A cron-compatible expression |
|
| 150 | + * @param CronExpression $expression A cron-compatible expression |
|
| 151 | 151 | * @return Schedule |
| 152 | 152 | */ |
| 153 | 153 | public function setExpression(CronExpression $expression) { |
@@ -177,7 +177,7 @@ discard block |
||
| 177 | 177 | /** |
| 178 | 178 | * Set enable/disable status |
| 179 | 179 | * |
| 180 | - * @param bool $enable |
|
| 180 | + * @param boolean $enabled |
|
| 181 | 181 | * @return Schedule |
| 182 | 182 | */ |
| 183 | 183 | public function setEnabled($enabled) { |
@@ -38,10 +38,8 @@ |
||
| 38 | 38 | /** |
| 39 | 39 | * Class constructor |
| 40 | 40 | * |
| 41 | - * @param string $manager_name |
|
| 42 | 41 | * @param Configuration $configuration |
| 43 | 42 | * @param LoggerInterface $logger |
| 44 | - * @param TasksTable $tasks |
|
| 45 | 43 | * @param EventsManager $events |
| 46 | 44 | * @param EntityManager $em |
| 47 | 45 | */ |
@@ -138,7 +138,7 @@ discard block |
||
| 138 | 138 | $date = new DateTime(); |
| 139 | 139 | $timestamps = []; |
| 140 | 140 | |
| 141 | - foreach ($items as $schedule) { |
|
| 141 | + foreach ( $items as $schedule ) { |
|
| 142 | 142 | |
| 143 | 143 | $timestamps[] = $schedule->getNextPlannedRun($date)->getTimestamp(); |
| 144 | 144 | |
@@ -152,7 +152,7 @@ discard block |
||
| 152 | 152 | |
| 153 | 153 | $em = $this->getEntityManager(); |
| 154 | 154 | |
| 155 | - foreach ($results as $result) { |
|
| 155 | + foreach ( $results as $result ) { |
|
| 156 | 156 | |
| 157 | 157 | $id = $result->jid; |
| 158 | 158 | |
@@ -196,7 +196,7 @@ discard block |
||
| 196 | 196 | |
| 197 | 197 | $records = []; |
| 198 | 198 | |
| 199 | - foreach ($schedules as $key => $schedule) { |
|
| 199 | + foreach ( $schedules as $key => $schedule ) { |
|
| 200 | 200 | |
| 201 | 201 | try { |
| 202 | 202 | |
@@ -429,6 +429,9 @@ |
||
| 429 | 429 | |
| 430 | 430 | } |
| 431 | 431 | |
| 432 | + /** |
|
| 433 | + * @param string $message |
|
| 434 | + */ |
|
| 432 | 435 | private function generateSyntheticResult($uid, $message, $jid = null, $success = true) { |
| 433 | 436 | |
| 434 | 437 | return new Result([ |
@@ -116,6 +116,9 @@ discard block |
||
| 116 | 116 | |
| 117 | 117 | } |
| 118 | 118 | |
| 119 | + /** |
|
| 120 | + * @param string $name |
|
| 121 | + */ |
|
| 119 | 122 | public function setName($name) { |
| 120 | 123 | |
| 121 | 124 | $this->name = $name; |
@@ -135,6 +138,9 @@ discard block |
||
| 135 | 138 | |
| 136 | 139 | } |
| 137 | 140 | |
| 141 | + /** |
|
| 142 | + * @param string $task |
|
| 143 | + */ |
|
| 138 | 144 | public function setTask($task) { |
| 139 | 145 | |
| 140 | 146 | $this->task = $task; |
@@ -260,7 +266,7 @@ discard block |
||
| 260 | 266 | /** |
| 261 | 267 | * Get start timestamp (microseconds) |
| 262 | 268 | * |
| 263 | - * @return float |
|
| 269 | + * @return integer |
|
| 264 | 270 | */ |
| 265 | 271 | public function getStartTimestamp() { |
| 266 | 272 | |