mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-13 08:41:16 +00:00
82 lines
2.8 KiB
Bash
Executable File
82 lines
2.8 KiB
Bash
Executable File
#!/bin/bash
|
|
|
|
################################################################################
|
|
# Copyright (C) 2019-2021 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"
|
|
}
|
|
|
|
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..."
|
|
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
|
|
|
|
# TODO Simplify, see https://github.com/FairRootGroup/DDS/issues/369
|
|
if dds-agent-cmd getlog -a; then
|
|
logDir=$(eval "echo $(dds-user-defaults --key server.sandbox_dir)/log/agents")
|
|
echo "AGENT LOG FILES IN: ${logDir}"
|
|
fi
|
|
|
|
# This string is used by ctest to detect success
|
|
echo "Example successful :)"
|
|
|
|
# Cleanup function is called by EXIT trap
|