bulkDataNTConfigurationParser.h

Go to the documentation of this file.

#ifndef _BULKDATA_NT_CONFIGURATION_PARSER_H_
#define _BULKDATA_NT_CONFIGURATION_PARSER_H_

/*******************************************************************************
* ALMA - Atacama Large Millimiter Array
* (c) European Southern Observatory, 2011
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307  USA
*
* "@(#) $Id: bulkDataNTConfigurationParser.h,v 1.15 2013/02/06 13:59:09 bjeram Exp $"
*
* who       when      what
* --------  --------  ----------------------------------------------
* bjeram  2011-04-19  created
*/

#ifndef __cplusplus
#error This is a C++ include file and cannot be used from plain C
#endif

#include <map>
#include <string>
#include <set>

#include <xercesc/dom/DOMNode.hpp>
#include <xercesc/dom/DOMWriter.hpp>
#include <xercesc/parsers/AbstractDOMParser.hpp>

#include "bulkDataNTSenderStream.h"
#include "bulkDataNTReceiverStream.h"

namespace AcsBulkdata
{

        class XMLChSP {

        public:
                XMLChSP();
                XMLChSP(char* xmlCh);
                ~XMLChSP();
                char * get();
                XMLChSP& operator=(const char*);
                void release();

        private:
                char* xmlch_m;

        };

        class BulkDataConfigurationParser {

        private:

                const char                 *m_baseLibrary; 
                xercesc::DOMWriter         *m_writer;
                xercesc::AbstractDOMParser *m_parser;
                std::string                                         m_baseQoSlibrary; 

                typedef struct _SenderCfg {
                        SenderStreamConfiguration *streamCfg;
                        std::map<std::string, SenderFlowConfiguration *> flowsCfgMap;
                } SenderCfg;

                typedef struct _ReceiverCfg {
                        ReceiverStreamConfiguration *streamCfg;
                        std::map<std::string, ReceiverFlowConfiguration *> flowsCfgMap;
                } ReceiverCfg;

                typedef std::map<std::string, ReceiverCfg> ReceiverCfgMap;
                typedef std::map<std::string, SenderCfg>   SenderCfgMap;

                ReceiverCfgMap receiverConfigMap_m;
                SenderCfgMap   senderConfigMap_m;

                static const char* const SENDER_STREAM_NODENAME;
                static const char* const SENDER_STREAM_QOS_NODENAME;
                static const char* const SENDER_FLOW_NODENAME;
                static const char* const SENDER_FLOW_QOS_NODENAME;
                static const char* const RECEIVER_STREAM_NODENAME;
                static const char* const RECEIVER_STREAM_QOS_NODENAME;
                static const char* const RECEIVER_FLOW_NODENAME;
                static const char* const RECEIVER_FLOW_QOS_NODENAME;

                static const char* const DYNAMIC_LIBRARY_NAME;
                static const char* const DEFAULT_QOS_LIBRARY_NAME;

                enum ParsingType {
                        SENDER,
                        RECEIVER
                };

                struct ParsingInfo {
                        ParsingType type;
                        const char* const reqStreamNodeName;
                        const char* const reqStreamQoSNodeName;
                        const char* const reqFlowNodeName;
                        const char* const reqFlowQoSNodeName;
                        const char* const defaultStreamProfileName;
                        const char* const defaultFlowProfileName;
                };

                const static struct ParsingInfo SENDER_PARSING_INFO;
                const static struct ParsingInfo RECEIVER_PARSING_INFO;


                void parseConfig(const char *config, const struct ParsingInfo &parsingInfo);

                const XMLCh* getAttrValue(xercesc::DOMNode *node, const char * name);

                unsigned short getUnsignedShortFromAttribute(xercesc::DOMNode *node, const char * attribute, unsigned short defaultVal);

                double getDoubleFromAttribute(xercesc::DOMNode *node, const char * attribute, double defaultVal);

                std::string getStringFromAttribute(xercesc::DOMNode *node, const char * attribute, std::string defaultVal);

                bool getBooleanFromAttribute(xercesc::DOMNode *node, const char * attribute, bool defaultVal);

                std::string getQosProfile(const char *profileName, const char *baseProfile, xercesc::DOMNode *node);

                std::string getStrURIforStream(std::list<std::string> profiles);

                void cleanReceiverConfigs();

                void cleanSenderConfigs();

                void cleanConfig(ReceiverCfg *recvConfig, SenderCfg *senderConfig, ParsingType type);

                std::string getElementLocalName(xercesc::DOMNode *node);

        public:

                BulkDataConfigurationParser(const char *baseLibraryName);

                ~BulkDataConfigurationParser();

                void parseSenderConfig(char const *configXML);
                void parseReceiverConfig(char const *configXML);

                std::set<char const *> getAllSenderStreamNames();

                std::set<char const *> getAllReceiverStreamNames();

                std::set<char const *> getAllSenderFlowNames(char const *streamName);

                std::set<char const *> getAllReceiverFlowNames(char const *streamName);

                SenderStreamConfiguration * getSenderStreamConfiguration(char const *streamName);

                SenderFlowConfiguration * getSenderFlowConfiguration(char const *streamName, char const *flowName);

                ReceiverStreamConfiguration * getReceiverStreamConfiguration(char const *streamName);

                ReceiverFlowConfiguration * getReceiverFlowConfiguration(char const *streamName, char const *flowName);
        };

};

#endif