Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 00:31:14 +00:00
Code Issues Packages Projects Releases Wiki Activity

Example.DDS: Add option to switch DDS RMS plugin

Browse Source
This commit is contained in:
Dennis Klein 2019-07-18 00:31:21 +02:00 committed by Dennis Klein
parent 7002dcbca3
commit 2c4a6674d2
2 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
examples/dds/ex-dds-hosts.cfg
View File

@ -1,7 +1,3 @@
@bash_begin@
# source setup.sh
@bash_end@
sampler, localhost, , /tmp/fairmq-ex-dds, 1
processor, localhost, , /tmp/fairmq-ex-dds, 10
sink, localhost, , /tmp/fairmq-ex-dds, 1
sampler, 127.0.0.1, , /tmp/fairmq-ex-dds, 1
processor, 127.0.0.1, , /tmp/fairmq-ex-dds, 10
sink, 127.0.0.1, , /tmp/fairmq-ex-dds, 1

12
examples/dds/fairmq-start-ex-dds.sh.in
View File

@ -8,6 +8,9 @@
# copied verbatim in the file "LICENSE" #
################################################################################
# fairmq-start-ex-dds.sh [localhost] -> submit agents with localhost plugin
# fairmq-start-ex-dds.sh ssh -> submit agents with ssh plugin
set -e
cleanup() {
@ -18,6 +21,8 @@ cleanup() {
source @DDS_INSTALL_PREFIX@/DDS_env.sh
export PATH=@BIN_DIR@:$PATH
plugin=${1:-localhost}
exec 5>&1
output=$(dds-session start | tee >(cat - >&5))
export DDS_SESSION_ID=$(echo ${output} | grep "DDS session ID: " | cut -d' ' -f4)
@ -26,7 +31,12 @@ echo "SESSION ID: ${DDS_SESSION_ID}"
trap "cleanup ${DDS_SESSION_ID}" EXIT
requiredNofAgents=12
dds-submit -r localhost -n ${requiredNofAgents}
if [[ "$plugin" == "ssh" ]]; then
dds-submit -r ${plugin} -c @DATA_DIR@/ex-dds-hosts.cfg
else
dds-submit -r ${plugin} -n ${requiredNofAgents}
fi
echo "...waiting for ${requiredNofAgents} idle agents..."
dds-info --wait-for-idle-agents ${requiredNofAgents}
topologyFile=@DATA_DIR@/ex-dds-topology.xml