Changeset 44483 for trunk/src/wp-includes/cron.php

Timestamp:

01/08/2019 09:48:07 PM (8 years ago)

Author:

peterwilsoncc

Message:

Cron API: Add function and filter to return ready cron jobs.

Add the function wp_get_ready_cron_jobs() to return a modified version of the cron array limited to jobs ready to be run, ie with a timestamp of time() or earlier.

The new function includes the filter pre_get_ready_cron_jobs to allow for custom cron storage systems. This rounds out the functionality added in #32656.

Props Pento for code review.
Fixes #45797.

File:

• trunk/src/wp-includes/cron.php (modified) (3 diffs)

trunk/src/wp-includes/cron.php

@@ -642 +642 @@
 
         //sanity check
-        $crons = _get_cron_array();
-        if ( ! is_array( $crons ) ) {
+        $crons = wp_get_ready_cron_jobs();
+        if ( empty( $crons ) ) {
                 return false;
         }
@@ -737 +737 @@
         }
 
-        $crons = _get_cron_array();
-        if ( false === $crons ) {
+        $crons = wp_get_ready_cron_jobs();
+        if ( empty( $crons ) ) {
                 return 0;
         }
@@ -855 +855 @@
 }
 
+/**
+ * Retrieve cron jobs ready to be run.
+ *
+ * Returns the results of _get_cron_array() limited to events ready to be run,
+ * ie, with a timestamp in the past.
+ *
+ * @since 5.1.0
+ *
+ * @return array Cron jobs ready to be run.
+ */
+function wp_get_ready_cron_jobs() {
+        /**
+         * Filter to preflight or hijack retrieving ready cron jobs.
+         *
+         * Returning an array will short-circuit the normal retrieval of ready
+         * cron jobs, causing the function to return the filtered value instead.
+         *
+         * @since 5.1.0
+         *
+         * @param null|array $pre Array of ready cron tasks to return instead. Default null
+         *                        to continue using results from _get_cron_array().
+         */
+        $pre = apply_filters( 'pre_get_ready_cron_jobs', null );
+        if ( null !== $pre ) {
+                return $pre;
+        }
+
+        $crons = _get_cron_array();
+
+        if ( false === $crons ) {
+                return array();
+        }
+
+        $gmt_time = microtime( true );
+        $keys     = array_keys( $crons );
+        if ( isset( $keys[0] ) && $keys[0] > $gmt_time ) {
+                return array();
+        }
+
+        $results = array();
+        foreach ( $crons as $timestamp => $cronhooks ) {
+                if ( $timestamp > $gmt_time ) {
+                        break;
+                }
+                $results[ $timestamp ] = $cronhooks;
+        }
+
+        return $results;
+}
+
 //
 // Private functions