#!/bin/bash

function cmd_ti_cases_consistency_resync()
{
	local ti_file="${1}"
	local ti_args="${2}"
	shift 6

	local scale='0.1'
	if [ ! -z "${1+x}" ]; then
		local scale="${1}"
	fi

	local db=`echo "tpch_${scale}" | scale_to_name`
	local table='lineitem'
	local ti="${integrated}/ops/ti.sh"

	"${ti}" -k "${ti_args}" "${ti_file}" must burn : up : tpch/load "${scale}" "${table}" : \
		wait/available "${db}" "${table}" : verify/rows "${db}" "${table}"

	"${integrated}/ops/ti.sh" -k "${ti_args}" "${ti_file}" parallel \
		GO: store/rm : up : store/rm : up : store/rm : up : store/rm : up : store/rm : up \
			store/rm : up : store/rm : up : store/rm : up : store/rm : up : store/rm : up \
			store/rm : up : store/rm : up : store/rm : up : store/rm : up : store/rm : up \
			store/rm : up : store/rm : up : store/rm : up : store/rm : up : store/rm : up \
			verify/rows "${db}" "${table}" : verify/consistency "${db}" "${table}" \
		GO: LOOP: wait/available "${db}" "${table}" : verify/consistency "${db}" "${table}"
}

set -euo pipefail
cmd_ti_cases_consistency_resync "${@}"