bulkDataNTReceiverStream.h

Go to the documentation of this file.

#ifndef _BULK_DATA_NT_RECEIVER_STREAM_H_
#define _BULK_DATA_NT_RECEIVER_STREAM_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: bulkDataNTReceiverStream.h,v 1.20 2012/10/15 09:46:17 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 "bulkDataNTStream.h"
#include "bulkDataNTReceiverFlow.h"
#include <map>

namespace AcsBulkdata
{



//TBD: actually we can move lots of stuff from BulkDataNTReceiverStream template class which do not depend on template parameter
class BulkDataNTReceiverStreamBase : public BulkDataNTStream
{
public:
        BulkDataNTReceiverStreamBase(const char* streamName, const ReceiverStreamConfiguration &cfg):
                BulkDataNTStream(streamName, cfg), receiverName_m("DefaultReceiver")
        {
                flowUnicastPort_m = (cfg.isUseIncrementUnicastPort()) ? (cfg.getBaseUnicastPort()) : 0;
        }

        BulkDataNTReceiverStreamBase( const char* receiverName, const char* streamName, const ReceiverStreamConfiguration &cfg):
                        BulkDataNTStream(streamName, cfg), receiverName_m(receiverName)
        {
                flowUnicastPort_m = (cfg.isUseIncrementUnicastPort()) ? (cfg.getBaseUnicastPort()) : ReceiverFlowConfiguration::DEFAULT_UNICAST_PORT/*=0*/;
        }

        void setReceiverName(char * recvName) { receiverName_m = recvName; }

        void setReceiverName(const char * recvName) { receiverName_m = recvName; }

        const char* getReceiverName() { return receiverName_m.c_str(); }

        unsigned short getNextFlowUnicastPort()
        {
                unsigned short port=flowUnicastPort_m;
                if (flowUnicastPort_m!=ReceiverFlowConfiguration::DEFAULT_UNICAST_PORT/*=0*/) flowUnicastPort_m++;
                return port;
        }

protected:

        std::string receiverName_m;
        unsigned short flowUnicastPort_m; 

};//BulkDataNTReceiverStreamBase

template<class TReceiverCallback>
class BulkDataNTReceiverStream : public BulkDataNTReceiverStreamBase

//, public AcsBulkdata::BulkDataNTDDSSubscriber

{
public:

        BulkDataNTReceiverStream(const char* streamName, const ReceiverStreamConfiguration &cfg=ReceiverStreamConfiguration(), bool enabledCallingCBforAllFlows=true);

        BulkDataNTReceiverStream(
                        const char* receiverName,
                        const char* streamName,
                        const ReceiverStreamConfiguration &cfg=ReceiverStreamConfiguration(),
                        bool enabledCallingCBforAllFlows=true);

        virtual ~BulkDataNTReceiverStream();


        BulkDataNTReceiverFlow* createFlow(const char *flowName, const ReceiverFlowConfiguration &cfg=ReceiverFlowConfiguration(),
                        BulkDataNTCallback *cb=0, bool releaseCB=false);

        BulkDataNTReceiverFlow* getFlow(const char* flowName);


        bool existFlow(const char* flowName);

        void createMultipleFlowsFromConfig(const char *config);

        std::vector<std::string> getFlowNames();

        unsigned int getFlowNumber();

        void enableCallingCBforAllFlows();

        void disableCallingCBforAllFlows();







        /*
         *  @throw ACSBulkDataError::AVNotificationMechanismErrorExImpl
         */





protected:

        virtual void removeFlowFromMap(const char* flow);

        typedef std::map<std::string, BulkDataNTReceiverFlow*> ReceiverFlowMap;
        ReceiverFlowMap receiverFlows_m;
        // we need a flag that prevents elements to be removed from map when we delete flows from dtor
        bool notRemoveFromMap_m;

        bool enabledCallingCBforAllFlows_m;

        BulkDataNTReceiverStream();
        void operator=(const BulkDataNTReceiverStream&);
        BulkDataNTReceiverStream(const BulkDataNTReceiverStream&);
};//class BulkDataNTReceiverStream

};//namespace AcsBulkdata

#include "bulkDataNTReceiverStream.i"

#endif