@@ -164,6 +164,9 @@ |
||
| 164 | 164 | $queue->add_all( $data_to_enqueue ); |
| 165 | 165 | } |
| 166 | 166 | |
| 167 | + /** |
|
| 168 | + * @param Jetpack_Sync_Queue $queue |
|
| 169 | + */ |
|
| 167 | 170 | function enqueue_action( $current_filter, $args, $queue ) { |
| 168 | 171 | // don't enqueue an action during the outbound http request - this prevents recursion |
| 169 | 172 | if ( Jetpack_Sync_Settings::is_sending() ) { |
@@ -76,6 +76,9 @@ discard block |
||
| 76 | 76 | return (float) get_option( self::NEXT_SYNC_TIME_OPTION_NAME . '_' . $queue_name, 0 ); |
| 77 | 77 | } |
| 78 | 78 | |
| 79 | + /** |
|
| 80 | + * @param integer $time |
|
| 81 | + */ |
|
| 79 | 82 | public function set_next_sync_time( $time, $queue_name ) { |
| 80 | 83 | return update_option( self::NEXT_SYNC_TIME_OPTION_NAME . '_' . $queue_name, $time, true ); |
| 81 | 84 | } |
@@ -106,6 +109,9 @@ discard block |
||
| 106 | 109 | return $this->do_sync_and_set_delays( $this->sync_queue ); |
| 107 | 110 | } |
| 108 | 111 | |
| 112 | + /** |
|
| 113 | + * @param Jetpack_Sync_Queue $queue |
|
| 114 | + */ |
|
| 109 | 115 | public function do_sync_and_set_delays( $queue ) { |
| 110 | 116 | // don't sync if importing |
| 111 | 117 | if ( defined( 'WP_IMPORTING' ) && WP_IMPORTING ) { |
@@ -354,6 +360,10 @@ discard block |
||
| 354 | 360 | } |
| 355 | 361 | |
| 356 | 362 | // in seconds |
| 363 | + |
|
| 364 | + /** |
|
| 365 | + * @param double $seconds |
|
| 366 | + */ |
|
| 357 | 367 | function set_max_dequeue_time( $seconds ) { |
| 358 | 368 | $this->max_dequeue_time = $seconds; |
| 359 | 369 | } |