Mirror/FairMQ
1
0
Fork 0
mirror of https://github.com/FairRootGroup/FairMQ.git synced 2025-10-13 16:46:47 +00:00
Code Issues Packages Projects Releases Wiki Activity
4be6ba6e66
FairMQ/fairmq/examples/2-sampler-processor-sink
History
Florian Uhlig af70d03ab0 Add missing include directories for ZeroMQ and NanoMsg. They have been found by chance when the packages are in SIMPATH. They are not found if they are in another path.
2015-10-21 17:12:04 +02:00
..
CMakeLists.txt Add missing include directories for ZeroMQ and NanoMsg. They have been found by chance when the packages are in SIMPATH. They are not found if they are in another path. 2015-10-21 17:12:04 +02:00
ex2-sampler-processor-sink.json Add DDS and Copy+Push examples. 2015-09-28 12:17:24 +02:00
FairMQExample2Processor.cxx Add orthogonal OK/ERROR states. 2015-09-28 12:17:24 +02:00
FairMQExample2Processor.h Add first two simple FairMQ examples 2015-06-22 16:35:00 +02:00
FairMQExample2Sampler.cxx Add orthogonal OK/ERROR states. 2015-09-28 12:17:24 +02:00
FairMQExample2Sampler.h Add first two simple FairMQ examples 2015-06-22 16:35:00 +02:00
FairMQExample2Sink.cxx Add orthogonal OK/ERROR states. 2015-09-28 12:17:24 +02:00
FairMQExample2Sink.h Add first two simple FairMQ examples 2015-06-22 16:35:00 +02:00
README.md Add DDS and Copy+Push examples. 2015-09-28 12:17:24 +02:00
runExample2Processor.cxx Add FairMQ Example 6 - Working with multiple channels 2015-10-07 16:46:10 +02:00
runExample2Sampler.cxx Several FairMQ fixes and improvements: 2015-09-28 12:17:22 +02:00
runExample2Sink.cxx Add FairMQ Example 6 - Working with multiple channels 2015-10-07 16:46:10 +02:00

README.md

Example 2: Sampler -> Processor -> Sink

A simple topology of three devices - Sampler, Processor and Sink. Sampler sends data to one or more Processors, who modify the data and send it to one Sink. Transport with the PUSH-PULL pattern.

In this example the Sampler is configured to bind its output and the Sink is configured to also bind its input. This allows us run any number of processors with the same configuration, because they all connect to same Sampler and Sink addresses. Furthermore, it allows adding of processors dynamically during run-time. The PUSH and PULL sockets will handle the data distribution to/from the new devices according to their distribution strategies (Round-robin output for PUSH and Fair-queued input for PULL).

The Sampler sends out a simple text string (its content configurable with --text command line parameter, defaul is "Hello"). Each Processor modifies the string by appending its ID to it and send it to the Sink.

The provided configuration file contains two Processors. To add more Processors, you can either extend the configuration file, or create a separate file only for new processors.