#!/bin/bash

ID="101"
inputFile="@CMAKE_SOURCE_DIR@/example/Tutorial3/macro/data/testdigi.root"
parameterFile="@CMAKE_SOURCE_DIR@/example/Tutorial3/macro/data/testparams.root"
branch="FairTestDetectorDigi"
eventRate="0"
numIoThreads="1"
outputSocketType="push"
outputBufSize="1000"
outputMethod="connect"
outputAddress="tcp://localhost:5565"
xterm -e @CMAKE_BINARY_DIR@/bin/testDetectorSampler $ID $inputFile $parameterFile $branch $eventRate $numIoThreads $outputSocketType $outputBufSize $outputMethod $outputAddress &


ID="201"
numIoThreads="1"
numOutputs="3"
inputSocketType="pull"
inputRcvBufSize="1000"
inputMethod="bind"
inputAddress="tcp://*:5565"
outputSocketType1="push"
outputSndBufSize1="1000"
outputMethod1="bind"
outputAddress1="tcp://*:5566"
outputSocketType2="push"
outputSndBufSize2="1000"
outputMethod2="bind"
outputAddress2="tcp://*:5567"
outputSocketType3="push"
outputSndBufSize3="1000"
outputMethod3="bind"
outputAddress3="tcp://*:5568"
xterm -e @CMAKE_BINARY_DIR@/bin/one_n_splitter $ID $numIoThreads $numOutputs $inputSocketType $inputRcvBufSize $inputMethod $inputAddress $outputSocketType1 $outputSndBufSize1 $outputMethod1 $outputAddress1 $outputSocketType2 $outputSndBufSize2 $outputMethod2 $outputAddress2 $outputSocketType3 $outputSndBufSize3 $outputMethod3 $outputAddress3 &


ID="301"
processorTask="FairTestDetectorMQRecoTask"
numIoThreads="1"
inputSocketType="pull"
inputRcvBufSize="1000"
inputMethod="connect"
inputAddress="tcp://localhost:5566"
outputSocketType="push"
outputSndBufSize="1000"
outputMethod="connect"
outputAddress="tcp://localhost:5569"
xterm -e @CMAKE_BINARY_DIR@/bin/testDetectorProcessor $ID $processorTask $numIoThreads $inputSocketType $inputRcvBufSize $inputMethod $inputAddress $outputSocketType $outputSndBufSize $outputMethod $outputAddress &


ID="401"
processorTask="FairTestDetectorMQRecoTask"
numIoThreads="1"
inputSocketType="pull"
inputRcvBufSize="1000"
inputMethod="connect"
inputAddress="tcp://localhost:5567"
outputSocketType="push"
outputSndBufSize="1000"
outputMethod="connect"
outputAddress="tcp://localhost:5570"
xterm -e @CMAKE_BINARY_DIR@/bin/testDetectorProcessor $ID $processorTask $numIoThreads $inputSocketType $inputRcvBufSize $inputMethod $inputAddress $outputSocketType $outputSndBufSize $outputMethod $outputAddress &

ID="401"
processorTask="FairTestDetectorMQRecoTask"
numIoThreads="1"
inputSocketType="pull"
inputRcvBufSize="1000"
inputMethod="connect"
inputAddress="tcp://localhost:5568"
outputSocketType="push"
outputSndBufSize="1000"
outputMethod="connect"
outputAddress="tcp://localhost:5571"
xterm -e @CMAKE_BINARY_DIR@/bin/testDetectorProcessor $ID $processorTask $numIoThreads $inputSocketType $inputRcvBufSize $inputMethod $inputAddress $outputSocketType $outputSndBufSize $outputMethod $outputAddress &


ID="501"
numIoThreads="1"
numInputs="3"
inputSocketType1="pull"
inputRcvBufSize1="1000"
inputMethod1="bind"
inputAddress1="tcp://*:5569"
inputSocketType2="pull"
inputRcvBufSize2="1000"
inputMethod2="bind"
inputAddress2="tcp://*:5570"
inputSocketType3="pull"
inputRcvBufSize3="1000"
inputMethod3="bind"
inputAddress3="tcp://*:5571"
outputSocketType="push"
outputSndBufSize="1000"
outputMethod="bind"
outputAddress="tcp://*:5572"
xterm -e @CMAKE_BINARY_DIR@/bin/n_one_merger $ID $numIoThreads $numInputs $inputSocketType1 $inputRcvBufSize1 $inputMethod1 $inputAddress1 $inputSocketType2 $inputRcvBufSize2 $inputMethod2 $inputAddress2  $inputSocketType3 $inputRcvBufSize3 $inputMethod3 $inputAddress3 $outputSocketType $outputSndBufSize $outputMethod $outputAddress &


ID="601"
numIoThreads="1"
inputSocketType="pull"
inputRcvBufSize="1000"
inputMethod="connect"
inputAddress="tcp://localhost:5572"
xterm -e @CMAKE_BINARY_DIR@/bin/fileSink $ID $numIoThreads $inputSocketType $inputRcvBufSize $inputMethod $inputAddress &
#alternative for regular sink:
#xterm -e @CMAKE_BINARY_DIR@/bin/sink $ID $numIoThreads $inputSocketType $inputRcvBufSize $inputAddress &