Automattic / jetpack

	 *

	 * @return WP_Error

	 */

	protected function get_buffer( $queue, $number_of_items ) {

		$start        = time();

		$max_duration = 5; // this will try to get the buffer.

		$buffer   = $queue->checkout( $number_of_items );

		$duration = time() - $start;

		while ( is_wp_error( $buffer ) && $duration < $max_duration ) {

			sleep( 2 );

			$duration = time() - $start;

			$buffer   = $queue->checkout( $number_of_items );

		}

		if ( false === $buffer ) {

			return new WP_Error( 'queue_size', 'The queue is empty and there is nothing to send', 400 );

		}

		return $buffer;

	}

}

		);

	}

	protected function get_buffer( $queue, $number_of_items ) {

		$start = time();

		$max_duration = 5; // this will try to get the buffer

		$buffer = $queue->checkout( $number_of_items );

		$duration = time() - $start;

		while( is_wp_error( $buffer ) && $duration < $max_duration ) {

			sleep( 2 );

			$duration = time() - $start;

			$buffer = $queue->checkout( $number_of_items );

		}

		if ( $buffer === false ) {

			return new WP_Error( 'queue_size', 'The queue is empty and there is nothing to send', 400 );

		}

		return $buffer;

	}

}

class Jetpack_JSON_API_Sync_Close_Endpoint extends Jetpack_JSON_API_Sync_Endpoint {