#

# set -o noglob is assumed.

# WARNING: ex_pkg_dispatch(), its caller, and its callers must _NOT_ be executed

# as part of conditional evaluation, e.g. if, until, while, !, or && and ||, as

# doing so would inhibit set -o errexit during execution of this function and its

# subshell(!).  Instead, call ex_pkg_dispatch() and subsequently evaluate ${?}.

#

ex_pkg_dispatch() {

	local _tgt_name="${1}" _restart="${2}" _restart_at="${3}"		\

		_dispatch_fn="${4}" _tgt_name_uc				\

		_pkg_names _pkg_name _pkg_name_uc				\

		_pipe_path _stderrout_path _pipe_msg _script_rc;

	ex_rtl_fileop mkdir "${BUILD_WORKDIR}";

	_pipe_path="${BUILD_WORKDIR}/build.fifo";

	_tgt_name_uc="$(ex_rtl_toupper "${_tgt_name}")";

	"${_dispatch_fn}" start_target "" "${_tgt_name}";

	_pkg_names="$(ex_rtl_get_var_unsafe ${_tgt_name_uc}_PACKAGES)";

	if [ -n "${_restart}" ]\

	&& [ "${_restart}" != ALL ]; then

		_pkg_names="$(ex_rtl_lfilter "${_pkg_names}" "${_restart}")";

	fi;

	for _pkg_name in ${_pkg_names}; do

		_pkg_name_uc="$(ex_rtl_toupper "${_pkg_name}")";

		if [ -n "$(ex_rtl_get_var_unsafe PKG_${_pkg_name_uc}_DISABLED)" ]; then

			"${_dispatch_fn}" disabled_pkg "${_pkg_name}" "${_tgt_name}";

			continue;

		elif ex_pkg_state_test "${_pkg_name}" finish\

		&& [ -z "${_restart_at}" ]; then

			"${_dispatch_fn}" skipped_pkg "${_pkg_name}" "${_tgt_name}";

			continue;

		else

			ex_rtl_fileop mkfifo "${_pipe_path}";

			_stderrout_path="${BUILD_WORKDIR}/${_pkg_name}_stderrout.log";

			_script_rc=1;

			"${_dispatch_fn}" start_pkg "${_pkg_name}" "${_tgt_name}";

		fi;

		(set -o errexit -o noglob;

		ex_pkg_env "${_pkg_name}" "${_tgt_name}" "${_restart_at}";

		trap "if [ \${?} -eq 0 ]; then					\

			echo \"done ${PKG_NAME}\" >&3;				\

		      else							\

			echo \"fail ${PKG_NAME}\" >&3;				\

		      fi;" EXIT HUP INT TERM USR1 USR2;

		ex_pkg_exec "${_pkg_name}" "${_tgt_name}" "${_restart_at}"	\

			"${_dispatch_fn}";) 1>"${_stderrout_path}" 2>&1 3>"${_pipe_path}" &

		while read _pipe_msg; do

		case "${_pipe_msg%% *}" in

		done)	_script_rc=0;

			"${_dispatch_fn}" finish_pkg "${_pkg_name}" "${_tgt_name}";

			break; ;;

		fail)	_script_rc=1;

			"${_dispatch_fn}" fail_pkg "${_pkg_name}" "${_tgt_name}";

			break; ;;

		step)	"${_dispatch_fn}" step_pkg ${_pipe_msg#step }; ;;

		*)	_script_rc=1;

			"${_dispatch_fn}" fail_pkg "${_pkg_name}" "${_tgt_name}";

			break; ;;

		esac; done <"${_pipe_path}";

		ex_rtl_fileop rm "${_pipe_path}";

		if [ "${_script_rc:-1}" -eq 1 ]; then

			return 1;

		fi;

	done;

	"${_dispatch_fn}" finish_target "" "${_tgt_name}";

};

# vim:filetype=sh