mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-13 16:46:47 +00:00
Update JSON files & readme, use FairMQDevicePtr, cleanup.
This commit is contained in:
parent
f18c6e50e2
commit
626ebdd298
|
@ -17,7 +17,7 @@ void addCustomOptions(bpo::options_description& options)
|
|||
("text", bpo::value<std::string>()->default_value("Hello"), "Text to send out");
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample1Sampler();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample1Sink();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample2Processor();
|
||||
}
|
||||
|
|
|
@ -17,7 +17,7 @@ void addCustomOptions(bpo::options_description& options)
|
|||
("text", bpo::value<std::string>()->default_value("Hello"), "Text to send out");
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample2Sampler();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample2Sink();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& config)
|
||||
{
|
||||
return new FairMQExample3Processor();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample3Sampler();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample3Sink();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample4Sampler();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample4Sink();
|
||||
}
|
||||
|
|
|
@ -17,7 +17,7 @@ void addCustomOptions(bpo::options_description& options)
|
|||
("text", bpo::value<std::string>()->default_value("Hello"), "Text to send out");
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample5Client();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample5Server();
|
||||
}
|
||||
|
|
|
@ -22,36 +22,22 @@ using namespace std;
|
|||
|
||||
FairMQExample6Sink::FairMQExample6Sink()
|
||||
{
|
||||
OnData("broadcast", &FairMQExample6Sink::HandleBroadcast);
|
||||
OnData("data", &FairMQExample6Sink::HandleData);
|
||||
}
|
||||
|
||||
void FairMQExample6Sink::Run()
|
||||
{
|
||||
std::unique_ptr<FairMQPoller> poller(fTransportFactory->CreatePoller(fChannels, { "data", "broadcast" }));
|
||||
|
||||
while (CheckCurrentState(RUNNING))
|
||||
{
|
||||
poller->Poll(100);
|
||||
|
||||
if (poller->CheckInput("broadcast", 0))
|
||||
{
|
||||
FairMQMessagePtr msg(NewMessage());
|
||||
|
||||
if (Receive(msg, "broadcast") > 0)
|
||||
bool FairMQExample6Sink::HandleBroadcast(FairMQMessagePtr& msg, int /*index*/)
|
||||
{
|
||||
LOG(INFO) << "Received broadcast: \"" << string(static_cast<char*>(msg->GetData()), msg->GetSize()) << "\"";
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
if (poller->CheckInput("data", 0))
|
||||
{
|
||||
FairMQMessagePtr msg(NewMessage());
|
||||
|
||||
if (Receive(msg, "data") > 0)
|
||||
bool FairMQExample6Sink::HandleData(FairMQMessagePtr& msg, int /*index*/)
|
||||
{
|
||||
LOG(INFO) << "Received message: \"" << string(static_cast<char*>(msg->GetData()), msg->GetSize()) << "\"";
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
FairMQExample6Sink::~FairMQExample6Sink()
|
||||
|
|
|
@ -24,7 +24,8 @@ class FairMQExample6Sink : public FairMQDevice
|
|||
virtual ~FairMQExample6Sink();
|
||||
|
||||
protected:
|
||||
virtual void Run();
|
||||
bool HandleBroadcast(FairMQMessagePtr&, int);
|
||||
bool HandleData(FairMQMessagePtr&, int);
|
||||
};
|
||||
|
||||
#endif /* FAIRMQEXAMPLE6SINK_H_ */
|
||||
|
|
|
@ -1,11 +1,11 @@
|
|||
{
|
||||
"fairMQOptions":
|
||||
{
|
||||
"device":
|
||||
{
|
||||
"devices":
|
||||
[{
|
||||
"id": "sampler1",
|
||||
"channel":
|
||||
{
|
||||
"channels":
|
||||
[{
|
||||
"name": "data",
|
||||
"socket":
|
||||
{
|
||||
|
@ -17,7 +17,6 @@
|
|||
"rateLogging": "0"
|
||||
}
|
||||
},
|
||||
"channel":
|
||||
{
|
||||
"name": "broadcast",
|
||||
"socket":
|
||||
|
@ -29,14 +28,12 @@
|
|||
"rcvBufSize": "1000",
|
||||
"rateLogging": "0"
|
||||
}
|
||||
}
|
||||
}]
|
||||
},
|
||||
|
||||
"device":
|
||||
{
|
||||
"id": "sink1",
|
||||
"channel":
|
||||
{
|
||||
"channels":
|
||||
[{
|
||||
"name": "data",
|
||||
"socket":
|
||||
{
|
||||
|
@ -48,7 +45,6 @@
|
|||
"rateLogging": "0"
|
||||
}
|
||||
},
|
||||
"channel":
|
||||
{
|
||||
"name": "broadcast",
|
||||
"socket":
|
||||
|
@ -60,10 +56,8 @@
|
|||
"rcvBufSize": "1000",
|
||||
"rateLogging": "0"
|
||||
}
|
||||
}
|
||||
}]
|
||||
},
|
||||
|
||||
"device":
|
||||
{
|
||||
"id": "broadcaster1",
|
||||
"channel":
|
||||
|
@ -79,7 +73,7 @@
|
|||
"rateLogging": "0"
|
||||
}
|
||||
}
|
||||
}
|
||||
}]
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample6Broadcaster();
|
||||
}
|
||||
|
|
|
@ -17,7 +17,7 @@ void addCustomOptions(bpo::options_description& options)
|
|||
("text", bpo::value<std::string>()->default_value("Hello"), "Text to send out");
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample6Sampler();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample6Sink();
|
||||
}
|
||||
|
|
|
@ -1,8 +1,8 @@
|
|||
{
|
||||
"fairMQOptions":
|
||||
{
|
||||
"device":
|
||||
{
|
||||
"devices":
|
||||
[{
|
||||
"id": "sampler1",
|
||||
"channel":
|
||||
{
|
||||
|
@ -18,8 +18,6 @@
|
|||
}
|
||||
}
|
||||
},
|
||||
|
||||
"device":
|
||||
{
|
||||
"id": "sink1",
|
||||
"channel":
|
||||
|
@ -35,6 +33,6 @@
|
|||
"rateLogging": "0"
|
||||
}
|
||||
}
|
||||
}
|
||||
}]
|
||||
}
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample8Sampler();
|
||||
}
|
||||
|
|
|
@ -15,7 +15,7 @@ void addCustomOptions(bpo::options_description& /*options*/)
|
|||
{
|
||||
}
|
||||
|
||||
FairMQDevice* getDevice(const FairMQProgOptions& /*config*/)
|
||||
FairMQDevicePtr getDevice(const FairMQProgOptions& /*config*/)
|
||||
{
|
||||
return new FairMQExample8Sink();
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue
Block a user