mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-13 08:41:16 +00:00
5efa50929d
Distribution policies forbid installation of environment scripts at the install prefix. So, e.g. in the Fedora DDS package the DDS_env.sh is installed to /usr/bin and available via $PATH.
89 lines
3.0 KiB
Bash
Executable File
89 lines
3.0 KiB
Bash
Executable File
#!/bin/bash
|
|
|
|
################################################################################
|
|
# Copyright (C) 2019 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH #
|
|
# #
|
|
# This software is distributed under the terms of the #
|
|
# GNU Lesser General Public Licence (LGPL) version 3, #
|
|
# copied verbatim in the file "LICENSE" #
|
|
################################################################################
|
|
|
|
# fairmq-start-ex-qc.sh -> submit agents with localhost plugin
|
|
|
|
set -e
|
|
|
|
cleanup() {
|
|
dds-session stop $1
|
|
echo "CLEANUP PERFORMED"
|
|
}
|
|
|
|
|
|
if [[ -e "@DDS_INSTALL_PREFIX@/DDS_env.sh" ]]; then
|
|
source @DDS_INSTALL_PREFIX@/DDS_env.sh
|
|
elif command -v DDS_env.sh &> /dev/null; then
|
|
source DDS_env.sh
|
|
fi
|
|
|
|
export PATH=@BIN_DIR@:$PATH
|
|
|
|
exec 5>&1
|
|
output=$(dds-session start | tee >(cat - >&5))
|
|
export DDS_SESSION_ID=$(echo ${output} | grep "DDS session ID: " | cut -d' ' -f4)
|
|
echo "SESSION ID: ${DDS_SESSION_ID}"
|
|
|
|
trap "cleanup ${DDS_SESSION_ID}" EXIT
|
|
|
|
requiredNofSlots=4
|
|
dds-submit -r localhost --slots ${requiredNofSlots}
|
|
echo "...waiting for ${requiredNofSlots} idle slots..."
|
|
dds-info --idle-count --wait ${requiredNofSlots}
|
|
|
|
export FAIRMQ_DDS_TOPO_FILE=@DATA_DIR@/ex-qc-topology.xml
|
|
echo "TOPOLOGY FILE: ${FAIRMQ_DDS_TOPO_FILE}"
|
|
echo "TOPOLOGY NAME: $(dds-topology --disable-validation --topology-name ${FAIRMQ_DDS_TOPO_FILE})"
|
|
|
|
dds-info --active-topology
|
|
dds-topology --activate ${FAIRMQ_DDS_TOPO_FILE}
|
|
dds-info --active-topology
|
|
echo "...waiting for ${requiredNofSlots} executing slots..."
|
|
dds-info --executing-count --wait ${requiredNofSlots}
|
|
|
|
echo "------------------------"
|
|
echo "...waiting for Topology to finish..."
|
|
# TODO Retrieve number of devices from DDS topology API instead of having the user pass it explicitely
|
|
fairmq-dds-command-ui -w "IDLE"
|
|
fairmq-dds-command-ui -c i
|
|
fairmq-dds-command-ui -c k
|
|
fairmq-dds-command-ui -c b
|
|
fairmq-dds-command-ui -c x
|
|
fairmq-dds-command-ui -c j
|
|
allexceptqctasks="main/(Sampler|QCDispatcher|Sink).*"
|
|
fairmq-dds-command-ui -c r -p $allexceptqctasks
|
|
qctask="main/QCTask.*"
|
|
qcdispatcher="main/QCDispatcher.*"
|
|
fairmq-dds-command-ui -c p --property-key qc --property-value active -p $qcdispatcher
|
|
fairmq-dds-command-ui -c r -p $qctask
|
|
fairmq-dds-command-ui -w "RUNNING->READY" -p $qctask
|
|
echo "...$qctask received data and transitioned to READY, sending shutdown..."
|
|
fairmq-dds-command-ui -c s
|
|
fairmq-dds-command-ui -c t
|
|
fairmq-dds-command-ui -c d
|
|
fairmq-dds-command-ui -c q
|
|
echo "...waiting for ${requiredNofSlots} idle slots..."
|
|
dds-info --idle-count --wait ${requiredNofSlots}
|
|
echo "------------------------"
|
|
|
|
dds-info --active-topology
|
|
dds-topology --stop
|
|
dds-info --active-topology
|
|
|
|
dds-agent-cmd getlog -a
|
|
logDir="${wrkDir}/logs"
|
|
for file in $(find "${logDir}" -name "*.tar.gz"); do tar -xf ${file} -C "${logDir}" ; done
|
|
echo "AGENT LOG FILES IN: ${logDir}"
|
|
|
|
# This string is used by ctest to detect success
|
|
echo "Example successful :)"
|
|
|
|
# Cleanup function is called by EXIT trap
|