wikimedia / mediawiki

	 * @param array $params

	 */

	public function forEachOpenConnection( $callback, array $params = [] ) {

		foreach ( $this->mConns as $connsByServer ) {

			foreach ( $connsByServer as $serverConns ) {

				foreach ( $serverConns as $conn ) {

					$mergedParams = array_merge( [ $conn ], $params );

					call_user_func_array( $callback, $mergedParams );

				}

			}

		}

	}

	/**

	 */

	public function forEachOpenMasterConnection( $callback, array $params = [] ) {

		$masterIndex = $this->getWriterIndex();

		foreach ( $this->mConns as $connsByServer ) {

			if ( isset( $connsByServer[$masterIndex] ) ) {

				/** @var DatabaseBase $conn */

				foreach ( $connsByServer[$masterIndex] as $conn ) {

					$mergedParams = array_merge( [ $conn ], $params );

					call_user_func_array( $callback, $mergedParams );

				}

			}

		}

	}

	/**