mirror of
https://github.com/FairRootGroup/FairMQ.git
synced 2025-10-13 16:46:47 +00:00
97 lines
2.8 KiB
C++
97 lines
2.8 KiB
C++
/********************************************************************************
|
|
* Copyright (C) 2017 GSI Helmholtzzentrum fuer Schwerionenforschung GmbH *
|
|
* *
|
|
* This software is distributed under the terms of the *
|
|
* GNU Lesser General Public License (LGPL) version 3, *
|
|
* copied verbatim in the file "LICENSE" *
|
|
********************************************************************************/
|
|
|
|
/// @file FairMQSuboptParser.cxx
|
|
/// @author Matthias.Richter@scieq.net
|
|
/// @since 2017-03-30
|
|
/// @brief Parser implementation for key-value subopt format
|
|
|
|
#include "FairMQSuboptParser.h"
|
|
|
|
#include <boost/property_tree/ptree.hpp>
|
|
#include <cstring>
|
|
#include <utility> // make_pair
|
|
|
|
using boost::property_tree::ptree;
|
|
using namespace std;
|
|
|
|
namespace fair
|
|
{
|
|
namespace mq
|
|
{
|
|
namespace parser
|
|
{
|
|
|
|
constexpr const char* SUBOPT::channelOptionKeys[];
|
|
|
|
FairMQMap SUBOPT::UserParser(const vector<string>& channelConfig, const string& deviceId, const string& rootNode)
|
|
{
|
|
ptree pt;
|
|
|
|
ptree devicesArray;
|
|
ptree deviceProperties;
|
|
|
|
ptree channelsArray;
|
|
|
|
for (auto token : channelConfig)
|
|
{
|
|
string channelName;
|
|
ptree channelProperties;
|
|
|
|
ptree socketsArray;
|
|
|
|
string argString(token);
|
|
char* subopts = &argString[0];
|
|
char* value = nullptr;
|
|
while (subopts && *subopts != 0 && *subopts != ' ')
|
|
{
|
|
int subopt = getsubopt(&subopts, (char**)channelOptionKeys, &value);
|
|
if (subopt == NAME)
|
|
{
|
|
channelName = value;
|
|
channelProperties.put("name", channelName);
|
|
}
|
|
else if (subopt == ADDRESS)
|
|
{
|
|
ptree socketProperties;
|
|
socketProperties.put(channelOptionKeys[subopt], value);
|
|
socketsArray.push_back(make_pair("", socketProperties));
|
|
}
|
|
else if (subopt >= 0 && value != nullptr)
|
|
{
|
|
channelProperties.put(channelOptionKeys[subopt], value);
|
|
}
|
|
}
|
|
|
|
if (channelName != "")
|
|
{
|
|
channelProperties.add_child("sockets", socketsArray);
|
|
}
|
|
else
|
|
{
|
|
// TODO: what is the error policy here, should we abort?
|
|
LOG(error) << "missing channel name in argument of option --channel-config";
|
|
}
|
|
|
|
channelsArray.push_back(make_pair("", channelProperties));
|
|
}
|
|
|
|
deviceProperties.put("id", deviceId);
|
|
deviceProperties.add_child("channels", channelsArray);
|
|
|
|
devicesArray.push_back(make_pair("", deviceProperties));
|
|
|
|
pt.add_child("fairMQOptions.devices", devicesArray);
|
|
|
|
return ptreeToMQMap(pt, deviceId, rootNode);
|
|
}
|
|
|
|
}
|
|
}
|
|
}
|