FileXXXXXXXXXXX

dvadf

File manager - Edit - /home/centroca/public_html/ActionScheduler_WPCLI_QueueRunner.php.tar

Back
vendor/woocommerce/action-scheduler/classes/WP_CLI/ActionScheduler_WPCLI_QueueRunner.php��0000644��00000016167�15253071436�0041072 0��ustar�00��home/centroca/public_html/wp/wp-content/plugins/wp-mail-smtp��<?php use Action_Scheduler\WP_CLI\ProgressBar; /** * WP CLI Queue runner. * * This class can only be called from within a WP CLI instance. / class ActionScheduler_WPCLI_QueueRunner extends ActionScheduler_Abstract_QueueRunner { /* * Whether the cleaner instance is a non-default one. * * @var bool / private $is_custom_cleaner; /* * Claimed actions. * * @var array / protected $actions; /* * ActionScheduler_ActionClaim instance. * * @var ActionScheduler_ActionClaim / protected $claim; /* * Progress bar instance. * * @var \cli\progress\Bar / protected $progress_bar; /* * ActionScheduler_WPCLI_QueueRunner constructor. * * @param ActionScheduler_Store\|null $store Store object. * @param ActionScheduler_FatalErrorMonitor\|null $monitor Monitor object. * @param ActionScheduler_QueueCleaner\|null $cleaner Cleaner object. * * @throws Exception When this is not run within WP CLI. / public function __construct( ?ActionScheduler_Store $store = null, ?ActionScheduler_FatalErrorMonitor $monitor = null, ?ActionScheduler_QueueCleaner $cleaner = null ) { if ( ! ( defined( 'WP_CLI' ) && WP_CLI ) ) { / translators: %s php class name / throw new Exception( sprintf( __( 'The %s class can only be run within WP CLI.', 'action-scheduler' ), __CLASS__ ) ); } parent::__construct( $store, $monitor, $cleaner ); $this->is_custom_cleaner = get_class( $this->cleaner ) !== ActionScheduler_QueueCleaner::class; } /* * Set up the Queue before processing. * * @param int $batch_size The batch size to process. * @param array $hooks The hooks being used to filter the actions claimed in this batch. * @param string $group The group of actions to claim with this batch. * @param bool $force Whether to force running even with too many concurrent processes. * * @return int The number of actions that will be run. * @throws \WP_CLI\ExitException When there are too many concurrent batches. / public function setup( $batch_size, $hooks = array(), $group = '', $force = false ) { $cleanup_time_limit = 10 $this->get_time_limit(); // Backward compatibility: If the action cleaner is standard, cleaning will be performed as an action to improve throughput // and enable daily runs. If not, cleaning will occur explicitly before processing actions to ensure backward compatibility. if ( $this->is_custom_cleaner ) { // Execute complete cleanup cycle, as in this logical branch deletion IS NOT executed via a separate action. $this->cleaner->clean( $cleanup_time_limit ); } else { // Execute partial cleanup cycle, as in this logical branch deletion IS executed via a separate action. $this->cleaner->reset_timeouts( $cleanup_time_limit ); $this->cleaner->mark_failures( $cleanup_time_limit ); } $this->add_hooks(); // Check to make sure there aren't too many concurrent processes running. if ( $this->has_maximum_concurrent_batches() ) { if ( $force ) { WP_CLI::warning( __( 'There are too many concurrent batches, but the run is forced to continue.', 'action-scheduler' ) ); } else { WP_CLI::error( __( 'There are too many concurrent batches.', 'action-scheduler' ) ); } } // Stake a claim and store it. $this->claim = $this->store->stake_claim( $batch_size, null, $hooks, $group ); $this->monitor->attach( $this->claim ); $this->actions = $this->claim->get_actions(); return count( $this->actions ); } /** * Add our hooks to the appropriate actions. / protected function add_hooks() { add_action( 'action_scheduler_before_execute', array( $this, 'before_execute' ) ); add_action( 'action_scheduler_after_execute', array( $this, 'after_execute' ), 10, 2 ); add_action( 'action_scheduler_failed_execution', array( $this, 'action_failed' ), 10, 2 ); } /* * Set up the WP CLI progress bar. / protected function setup_progress_bar() { $count = count( $this->actions ); $this->progress_bar = new ProgressBar( / translators: %d: amount of actions / sprintf( _n( 'Running %d action', 'Running %d actions', $count, 'action-scheduler' ), $count ), $count ); } /* * Process actions in the queue. * * @param string $context Optional runner context. Default 'WP CLI'. * * @return int The number of actions processed. / public function run( $context = 'WP CLI' ) { do_action( 'action_scheduler_before_process_queue' ); $this->setup_progress_bar(); $claim_id = $this->claim->get_id(); foreach ( $this->actions as $action_id ) { // Bail if we lost the claim. if ( $claim_id !== $this->store->get_claim_id( $action_id ) ) { WP_CLI::warning( __( 'The claim has been lost. Aborting current batch.', 'action-scheduler' ) ); break; } $this->process_action( $action_id, $context ); $this->progress_bar->tick(); } $completed = $this->progress_bar->current(); $this->progress_bar->finish(); $this->store->release_claim( $this->claim ); do_action( 'action_scheduler_after_process_queue' ); return $completed; } /* * Handle WP CLI message when the action is starting. * * @param int $action_id Action ID. / public function before_execute( $action_id ) { / translators: %s refers to the action ID / WP_CLI::log( sprintf( __( 'Started processing action %s', 'action-scheduler' ), $action_id ) ); } /* * Handle WP CLI message when the action has completed. * * @param int $action_id ActionID. * @param null\|ActionScheduler_Action $action The instance of the action. Default to null for backward compatibility. / public function after_execute( $action_id, $action = null ) { // backward compatibility. if ( null === $action ) { $action = $this->store->fetch_action( $action_id ); } / translators: 1: action ID 2: hook name / WP_CLI::log( sprintf( __( 'Completed processing action %1$s with hook: %2$s', 'action-scheduler' ), $action_id, $action->get_hook() ) ); } /* * Handle WP CLI message when the action has failed. * * @param int $action_id Action ID. * @param Exception $exception Exception. * @throws \WP_CLI\ExitException With failure message. / public function action_failed( $action_id, $exception ) { WP_CLI::error( / translators: 1: action ID 2: exception message / sprintf( __( 'Error processing action %1$s: %2$s', 'action-scheduler' ), $action_id, $exception->getMessage() ), false ); } /* * Sleep and help avoid hitting memory limit * * @param int $sleep_time Amount of seconds to sleep. * @deprecated 3.0.0 / protected function stop_the_insanity( $sleep_time = 0 ) { _deprecated_function( 'ActionScheduler_WPCLI_QueueRunner::stop_the_insanity', '3.0.0', 'ActionScheduler_DataController::free_memory' ); ActionScheduler_DataController::free_memory(); } /* * Maybe trigger the stop_the_insanity() method to free up memory. */ protected function maybe_stop_the_insanity() { // The value returned by progress_bar->current() might be padded. Remove padding, and convert to int. $current_iteration = intval( trim( $this->progress_bar->current() ) ); if ( 0 === $current_iteration % 50 ) { $this->stop_the_insanity(); } } } ��

dvadf

dvadf