#!/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="bind"
outputAddress="tcp://*:5565"
xterm -e @CMAKE_BINARY_DIR@/bin/testDetectorSampler $ID $inputFile $parameterFile $branch $eventRate $numIoThreads $outputSocketType $outputBufSize $outputMethod $outputAddress &


ID="201"
numIoThreads="1"
inputSocketType="pull"
inputRcvBufSize="1000"
inputMethod="connect"
inputAddress="tcp://localhost:5565"
outputSocketType1="push"
outputSndBufSize1="1000"
outputMethod1="bind"
outputAddress1="tcp://*:5566"
outputSocketType2="push"
outputSndBufSize2="1000"
outputMethod2="bind"
outputAddress2="tcp://*:5567"
xterm -e @CMAKE_BINARY_DIR@/bin/splitter $ID $numIoThreads $inputSocketType $inputRcvBufSize $inputMethod $inputAddress $outputSocketType1 $outputSndBufSize1 $outputMethod1 $outputAddress1 $outputSocketType2 $outputSndBufSize2 $outputMethod2 $outputAddress2 &


ID="301"
processorTask="FairTestDetectorMQRecoTask"
numIoThreads="1"
inputSocketType="pull"
inputRcvBufSize="1000"
inputMethod="connect"
inputAddress="tcp://localhost:5566"
outputSocketType="push"
outputSndBufSize="1000"
outputMethod="bind"
outputAddress="tcp://*:5568"
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="bind"
outputAddress="tcp://*:5569"
xterm -e @CMAKE_BINARY_DIR@/bin/testDetectorProcessor $ID $processorTask $numIoThreads $inputSocketType $inputRcvBufSize $inputMethod $inputAddress $outputSocketType $outputSndBufSize $outputMethod $outputAddress &


ID="501"
numIoThreads="1"
inputSocketType1="pull"
inputRcvBufSize1="1000"
inputMethod1="connect"
inputAddress1="tcp://localhost:5568"
inputSocketType2="pull"
inputRcvBufSize2="1000"
inputMethod2="connect"
inputAddress2="tcp://localhost:5569"
outputSocketType="push"
outputSndBufSize="1000"
outputMethod="bind"
outputAddress="tcp://*:5570"
xterm -e @CMAKE_BINARY_DIR@/bin/merger $ID $numIoThreads $inputSocketType1 $inputRcvBufSize1 $inputMethod1 $inputAddress1 $inputSocketType2 $inputRcvBufSize2 $inputMethod2 $inputAddress2 $outputSocketType $outputSndBufSize $outputMethod $outputAddress &


ID="601"
numIoThreads="1"
inputSocketType="pull"
inputRcvBufSize="1000"
inputMethod="connect"
inputAddress="tcp://localhost:5570"
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 &