#ifndef _BULK_DATA_NT_STREAM_H_
#define _BULK_DATA_NT_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: bulkDataNTStream.h,v 1.17 2012/09/13 14:02:48 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 <vector>
#include <string>
#include <Message_Block.h>
#include "bulkDataNTDDS.h"
#include "ACS_BD_Errors.h"
#include "bulkDataNTConfiguration.h"

namespace AcsBulkdata
{

typedef unsigned long FlowNumberType;


/**
 *  base class for Bulk data sender and receiver
 *  TBD probably we do not need it
 */
class BulkDataNTStream
{
	friend class BulkDataNTReceiverFlow;
public:

	/**
	 * Constructor
	 */
	BulkDataNTStream(const char* name, const StreamConfiguration &cfg);

	/**
	 * Destructor
	 */
	virtual ~BulkDataNTStream();

	std::string getName() { return streamName_m; }

	/// adding and applying DDS QoS profile. Setting qoS from XML for a  stream or a flow
	///@cfg configuration
	///@name: flow or stream name
	void addDDSQoSProfile(DDSConfiguration &cfg, const char *name);

	/// removing DDS QoS profile (from XML for a  stream or a flow)
	void removeDDSQoSProfile(const DDSConfiguration &cfg);

	//void destroyFlow(const  char* flowName);

	static unsigned int factoryRefCount_m; /// how many time / streams need the factory
protected:

	DDS::DomainParticipant* getDDSParticipant(){ return participant_m; }

	virtual void removeFlowFromMap(const char* flow)=0;

	std::string streamName_m;

	StreamConfiguration  configuration_m; //configuration
	// those two methods and members should probably go to another class  ??
	void createDDSFactory();
	void destroyDDSFactory();

	DDS::DomainParticipant* createDDSParticipant();
	void destroyDDSParticipant(DDS::DomainParticipant* domainParticipant);

	static DDS::DomainParticipantFactory *factory_m;
	static unsigned int globalParticipantRefCount_m; /// how many streams do need the participant
	static DDS::DomainParticipant* globalParticipant_m; /// if we use just one participant
	DDS::DomainParticipant* participant_m; /// could be a newly created per stream or used global one
	static ACE_Recursive_Thread_Mutex globalPartMutex_m; /// protection global participant + counter
	static ACE_Recursive_Thread_Mutex DDSFactoryMutex_m; /// protection DDS factory ( counter)
};//class BulkDataNTStream

};

#endif