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