wikimedia / mediawiki

	 *

	 * @return array List of job types that have non-empty queues

	 */

	public function getQueuesWithJobs() {

		$types = [];

		foreach ( $this->getCoalescedQueues() as $info ) {

			$nonEmpty = $info['queue']->getSiblingQueuesWithJobs( $this->getQueueTypes() );

			if ( is_array( $nonEmpty ) ) { // batching features supported

				$types = array_merge( $types, $nonEmpty );

			} else { // we have to go through the queues in the bucket one-by-one

				foreach ( $info['types'] as $type ) {

					if ( !$this->get( $type )->isEmpty() ) {

						$types[] = $type;

					}

				}

			}

		}

		return $types;

	}

	/**

	 * Get the size of the queus for a list of job types

	 *

	 * @return array Map of (job type => size)

	 */

	public function getQueueSizes() {

		$sizeMap = [];

		foreach ( $this->getCoalescedQueues() as $info ) {

			$sizes = $info['queue']->getSiblingQueueSizes( $this->getQueueTypes() );

			if ( is_array( $sizes ) ) { // batching features supported

				$sizeMap = $sizeMap + $sizes;

			} else { // we have to go through the queues in the bucket one-by-one

				foreach ( $info['types'] as $type ) {

					$sizeMap[$type] = $this->get( $type )->getSize();

				}

			}

		}

		return $sizeMap;

	}

	/**

	 * @return array