#!/bin/bash


buffSize="1000" # zeromq high-water mark is in messages
dataFormat="Boost"

# STS SAMPLER

ID="101"
inputFile="@CBMROOT_SOURCE_DIR@/tutorials/MQTest/macro/data/test.rawsts.root"
parameterFile="@CBMROOT_SOURCE_DIR@/tutorials/MQTest/macro/data/params.root"
branch="TimeSlice."
eventRate="0"
numIoThreads="1"
outputSocketType="push"
outputBufSize=$buffSize
outputMethod="connect"
outputAddress="tcp://localhost:5566"
xterm -hold -e @CMAKE_BINARY_DIR@/bin/testCbmStsDetectorSampler_$dataFormat $ID $inputFile $parameterFile $branch $eventRate $numIoThreads $outputSocketType $outputBufSize $outputMethod $outputAddress &

# MUCH SAMPLER

ID="201"
inputFile="@CBMROOT_SOURCE_DIR@/tutorials/MQTest/macro/data/test.rawmuch.root"
parameterFile="@CBMROOT_SOURCE_DIR@/tutorials/MQTest/macro/data/params.root"
branch="TimeSlice."
eventRate="0"
numIoThreads="1"
outputSocketType="push"
outputBufSize=$buffSize
outputMethod="connect"
outputAddress="tcp://localhost:5567"
xterm -hold -e @CMAKE_BINARY_DIR@/bin/testCbmMuchDetectorSampler_$dataFormat $ID $inputFile $parameterFile $branch $eventRate $numIoThreads $outputSocketType $outputBufSize $outputMethod $outputAddress &


# MICROSLICE MERGER (processor)

MicroSliceNumberToMerge="8"
TimeSliceIndex="1"
ID="301"
numInputs="2"
numIoThreads="1"
inputSocketType1="pull"
inputRcvBufSize1=$buffSize
inputMethod1="bind"
inputAddress1="tcp://*:5566"
inputSocketType2="pull"
inputRcvBufSize2=$buffSize
inputMethod2="bind"
inputAddress2="tcp://*:5567"
outputSocketType="push"
outputSndBufSize=$buffSize
outputMethod="connect"
outputAddress="tcp://localhost:5568"
xterm -hold -e @CMAKE_BINARY_DIR@/bin/testCbmDetectorProcessor_$dataFormat $MicroSliceNumberToMerge $TimeSliceIndex $ID $processorTask $numIoThreads $numInputs $inputSocketType1 $inputRcvBufSize1 $inputMethod1 $inputAddress1 $inputSocketType2 $inputRcvBufSize2 $inputMethod2 $inputAddress2 $outputSocketType $outputSndBufSize $outputMethod $outputAddress &


# FILESINK

ID="401"
numIoThreads="1"
inputSocketType="pull"
inputRcvBufSize=$buffSize
inputMethod="bind"
inputAddress="tcp://*:5568"
xterm -hold -e @CMAKE_BINARY_DIR@/bin/testCbmfileSink_$dataFormat $ID $numIoThreads $inputSocketType $inputRcvBufSize $inputMethod $inputAddress &
#alternative for regular sink:
#xterm -e @CMAKE_BINARY_DIR@/bin/sink $ID $numIoThreads $inputSocketType $inputRcvBufSize $inputAddress &