@@ -43,6 +43,9 @@ discard block |
||
43 | 43 | return array( 'scheduled' => Actions::do_full_sync( $modules ) ); |
44 | 44 | } |
45 | 45 | |
46 | + /** |
|
47 | + * @return string |
|
48 | + */ |
|
46 | 49 | protected function validate_queue( $query ) { |
47 | 50 | if ( ! isset( $query ) ) { |
48 | 51 | return new WP_Error( 'invalid_queue', 'Queue name is required', 400 ); |
@@ -233,6 +236,9 @@ discard block |
||
233 | 236 | ); |
234 | 237 | } |
235 | 238 | |
239 | + /** |
|
240 | + * @param Queue $queue |
|
241 | + */ |
|
236 | 242 | protected function get_buffer( $queue, $number_of_items ) { |
237 | 243 | $start = time(); |
238 | 244 | $max_duration = 5; // this will try to get the buffer |
@@ -374,7 +374,7 @@ |
||
374 | 374 | /** |
375 | 375 | * Close the buffer. |
376 | 376 | * |
377 | - * @param Automattic\Jetpack\Sync\Queue_Buffer $buffer Queue_Buffer object. |
|
377 | + * @param Queue_Buffer $buffer Queue_Buffer object. |
|
378 | 378 | * @param null|array $ids_to_remove Ids to remove from the queue. |
379 | 379 | * |
380 | 380 | * @return bool|\WP_Error |