#
# set -o errexit -o noglob are assumed.
#
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}" ]; 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