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