bulkDataNTSenderFlow.h

Go to the documentation of this file.

#ifndef _BULK_DATA_NT_SENDER_FLOW_H_
#define _BULK_DATA_NT_SENDER_FLOW_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: bulkDataNTSenderFlow.h,v 1.22 2013/01/08 11:39:40 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 "bulkDataNTFlow.h"
#include "bulkDataNTDDSPublisher.h"
#include "bulkDataNTSenderStream.h"
#include "bulkDataNTSenderFlowCallback.h"
#include "bulkDataNTWriterListener.h"


namespace AcsBulkdata
{

class BulkDataNTSenderStream;

class BulkDataNTSenderFlow : public BulkDataNTFlow
{
public:

        BulkDataNTSenderFlow(BulkDataNTSenderStream *senderStream,
                                                const char* flowName,
                                                const SenderFlowConfiguration &sndCfg,
                                                BulkDataNTSenderFlowCallback *cb,
                                                bool releaseCB );

        virtual ~BulkDataNTSenderFlow();


        unsigned int getNumberOfReceivers();

        void startSend(ACE_Message_Block *param = 0);

        void startSend(const unsigned char *param, size_t len);

        void sendData(const unsigned char *buffer, size_t len);

        void stopSend();

        void dumpStatistics(ACE_Log_Priority level=LM_DEBUG);
        void getStatistics(bool log);

protected:

        typedef enum {StartState, DataRcvState, StopState, IgnoreDataState } SenderFlowStates;
        SenderFlowStates currentState_m; 
        static const char* state2String[]; 

        AcsBulkdata::BulkDataNTSenderStream *senderStream_m; 

        SenderFlowConfiguration senderFlowCfg_m; 

        BulkDataNTSenderFlowCallback *callback_m; 
        bool releaseCB_m; 

        AcsBulkdata::BulkDataNTDDSPublisher *ddsPublisher_m;  
        DDS::Topic *ddsTopic_m;  
        BulkDataNTWriterListener *writerReaderListener_m;  
        ACSBulkData::BulkDataNTFrameDataWriter *ddsDataWriter_m;  

        DDS::Duration_t ackTimeout_m;  
        void setACKsTimeout(double ACKsTimeout);  

        double throttling_m;
        double throttlingMinFrameTime_m; 
        void setThrottling(double throttling); 

        // should it go to upper class Publisher ?
        void writeFrame(ACSBulkData::DataType dataType,  const unsigned char *param=0, size_t len=0, unsigned int restFrameCount=0, bool waitForACKs=false);

        ACSBulkData::BulkDataNTFrame *frame_m;

        BulkDataNTSenderFlow();
        void operator=(const BulkDataNTSenderFlow&);
        BulkDataNTSenderFlow(const BulkDataNTSenderFlow&);
};//class BulkDataSenderFlow

};


#endif