wikimedia / mediawiki

		return $success;

	}

	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();

		}

	}

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

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

			foreach ( $connsByServer as $i => $serverConns ) {

				if ( $i === $this->getWriterIndex() ) {

					continue; // skip master

				}

				foreach ( $serverConns as $conn ) {

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

					call_user_func_array( $callback, $mergedParams );

				}

			}

		}

	}

	public function getMaxLag( $domain = false ) {

		$maxLag = -1;