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.12 2011/11/08 11:12:04 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") {}

        BulkDataNTReceiverStreamBase( const char* receiverName, const char* streamName, const ReceiverStreamConfiguration &cfg):
                        BulkDataNTStream(streamName, cfg), receiverName_m(receiverName){}

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

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

protected:

        std::string receiverName_m;

};//BulkDataNTReceiverStreamBase

template<class TReceiverCallback>
class BulkDataNTReceiverStream : public BulkDataNTReceiverStreamBase

//, public AcsBulkdata::BulkDataNTDDSSubscriber

{
public:

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

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

        virtual ~BulkDataNTReceiverStream();



        // TBD: is this better than createSingleFlow and createMultipleFlows
        // do we have to provide a name or just a number, for example we need three flows
        // if we decide for name then we have to change send methods as well.
        // here we should connect to the DDS topic
        // TBD: here we can also send the callback?
        BulkDataNTReceiverFlow* createFlow(const char *flowName, const ReceiverFlowConfiguration &cfg=ReceiverFlowConfiguration(),
                        BulkDataNTCallback *cb=0, bool releaseCB=false);

        BulkDataNTReceiverFlow* getFlow(const char* flowName);

        void createMultipleFlowsFromConfig(const char *config);







        void closeReceiver();








        /*
         *  @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;


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

};//namespace AcsBulkdata

#include "bulkDataNTReceiverStream.i"

#endif