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

Port DDS plugin to the new plugin system.

Browse Source
This commit is contained in:
Alexey Rybalchenko 2017-09-15 13:51:42 +02:00 committed by Mohammad Al-Turany
parent 6d03dda95d
commit f827655f81
3 changed files with 3 additions and 46 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
examples/MQ/3-dds/CMakeLists.txt
View File

@ -10,8 +10,6 @@ configure_file(${CMAKE_SOURCE_DIR}/examples/MQ/3-dds/ex3-dds-topology.xml
${CMAKE_BINARY_DIR}/bin/config/ex3-dds-topology.xml @ONLY) ${CMAKE_BINARY_DIR}/bin/config/ex3-dds-topology.xml @ONLY)
configure_file(${CMAKE_SOURCE_DIR}/examples/MQ/3-dds/ex3-dds-hosts.cfg configure_file(${CMAKE_SOURCE_DIR}/examples/MQ/3-dds/ex3-dds-hosts.cfg
${CMAKE_BINARY_DIR}/bin/config/ex3-dds-hosts.cfg COPYONLY) ${CMAKE_BINARY_DIR}/bin/config/ex3-dds-hosts.cfg COPYONLY)
configure_file(${CMAKE_SOURCE_DIR}/examples/MQ/3-dds/ex3-dds.json
${CMAKE_BINARY_DIR}/bin/config/ex3-dds.json COPYONLY)
Set(INCLUDE_DIRECTORIES Set(INCLUDE_DIRECTORIES
${CMAKE_SOURCE_DIR}/fairmq ${CMAKE_SOURCE_DIR}/fairmq

6
examples/MQ/3-dds/ex3-dds-topology.xml
View File

@ -8,7 +8,7 @@
<declrequirement id="SinkWorker" type="wnname" value="sink"/> <declrequirement id="SinkWorker" type="wnname" value="sink"/>
<decltask id="Sampler"> <decltask id="Sampler">
<exe reachable="true">@CMAKE_BINARY_DIR@/bin/examples/MQ/3-dds/ex3-sampler --id sampler --log-color false --control libFairMQDDSControlPlugin.so --config libFairMQDDSConfigPlugin.so --mq-config @CMAKE_BINARY_DIR@/bin/config/ex3-dds.json</exe> <exe reachable="true">@CMAKE_BINARY_DIR@/bin/examples/MQ/3-dds/ex3-sampler --id sampler --log-color false --channel-config name=data1,type=push,method=bind -S "&lt;@CMAKE_BINARY_DIR@/lib" -P dds</exe>
<requirements> <requirements>
<id>SamplerWorker</id> <id>SamplerWorker</id>
</requirements> </requirements>
@ -18,7 +18,7 @@
</decltask> </decltask>
<decltask id="Processor"> <decltask id="Processor">
<exe reachable="true">@CMAKE_BINARY_DIR@/bin/examples/MQ/3-dds/ex3-processor --id processor_%taskIndex% --config-key processor --log-color false --control libFairMQDDSControlPlugin.so --config libFairMQDDSConfigPlugin.so --mq-config @CMAKE_BINARY_DIR@/bin/config/ex3-dds.json</exe> <exe reachable="true">@CMAKE_BINARY_DIR@/bin/examples/MQ/3-dds/ex3-processor --id processor_%taskIndex% --config-key processor --log-color false --channel-config name=data1,type=pull,method=connect name=data2,type=push,method=connect -S "&lt;@CMAKE_BINARY_DIR@/lib" -P dds</exe>
<requirements> <requirements>
<id>ProcessorWorker</id> <id>ProcessorWorker</id>
</requirements> </requirements>
@ -29,7 +29,7 @@
</decltask> </decltask>
<decltask id="Sink"> <decltask id="Sink">
<exe reachable="true">@CMAKE_BINARY_DIR@/bin/examples/MQ/3-dds/ex3-sink --id sink --log-color false --control libFairMQDDSControlPlugin.so --config libFairMQDDSConfigPlugin.so --mq-config @CMAKE_BINARY_DIR@/bin/config/ex3-dds.json</exe> <exe reachable="true">@CMAKE_BINARY_DIR@/bin/examples/MQ/3-dds/ex3-sink --id sink --log-color false --channel-config name=data2,type=pull,method=bind -S "&lt;@CMAKE_BINARY_DIR@/lib" -P dds</exe>
<requirements> <requirements>
<id>SinkWorker</id> <id>SinkWorker</id>
</requirements> </requirements>

41
examples/MQ/3-dds/ex3-dds.json
View File

@ -1,41 +0,0 @@
{
"fairMQOptions": {
"devices": [
{
"id": "sampler",
"channels": [
{
"name": "data1",
"type": "push",
"method": "bind"
}
]
},
{
"key": "processor",
"channels": [
{
"name": "data1",
"type": "pull",
"method": "connect"
},
{
"name": "data2",
"type": "push",
"method": "connect"
}
]
},
{
"id": "sink",
"channels": [
{
"name": "data2",
"type": "pull",
"method": "bind"
}
]
}
]
}
}