00001 #ifndef _BULK_DATA_NT_STREAM_H_ 00002 #define _BULK_DATA_NT_STREAM_H_ 00003 /******************************************************************************* 00004 * ALMA - Atacama Large Millimiter Array 00005 * (c) European Southern Observatory, 2011 00006 * 00007 * This library is free software; you can redistribute it and/or 00008 * modify it under the terms of the GNU Lesser General Public 00009 * License as published by the Free Software Foundation; either 00010 * version 2.1 of the License, or (at your option) any later version. 00011 * 00012 * This library is distributed in the hope that it will be useful, 00013 * but WITHOUT ANY WARRANTY; without even the implied warranty of 00014 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 00015 * Lesser General Public License for more details. 00016 * 00017 * You should have received a copy of the GNU Lesser General Public 00018 * License along with this library; if not, write to the Free Software 00019 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA 00020 * 00021 * "@(#) $Id: bulkDataNTStream.h,v 1.17 2012/09/13 14:02:48 bjeram Exp $" 00022 * 00023 * who when what 00024 * -------- -------- ---------------------------------------------- 00025 * bjeram 2011-04-19 created 00026 */ 00027 00028 /************************************************************************ 00029 * 00030 *---------------------------------------------------------------------- 00031 */ 00032 00033 #ifndef __cplusplus 00034 #error This is a C++ include file and cannot be used from plain C 00035 #endif 00036 00037 00038 #include <vector> 00039 #include <string> 00040 #include <Message_Block.h> 00041 #include "bulkDataNTDDS.h" 00042 #include "ACS_BD_Errors.h" 00043 #include "bulkDataNTConfiguration.h" 00044 00045 namespace AcsBulkdata 00046 { 00047 00048 typedef unsigned long FlowNumberType; 00049 00050 00055 class BulkDataNTStream 00056 { 00057 friend class BulkDataNTReceiverFlow; 00058 public: 00059 00063 BulkDataNTStream(const char* name, const StreamConfiguration &cfg); 00064 00068 virtual ~BulkDataNTStream(); 00069 00070 std::string getName() { return streamName_m; } 00071 00075 void addDDSQoSProfile(DDSConfiguration &cfg, const char *name); 00076 00078 void removeDDSQoSProfile(const DDSConfiguration &cfg); 00079 00080 //void destroyFlow(const char* flowName); 00081 00082 static unsigned int factoryRefCount_m; 00083 protected: 00084 00085 DDS::DomainParticipant* getDDSParticipant(){ return participant_m; } 00086 00087 virtual void removeFlowFromMap(const char* flow)=0; 00088 00089 std::string streamName_m; 00090 00091 StreamConfiguration configuration_m; //configuration 00092 // those two methods and members should probably go to another class ?? 00093 void createDDSFactory(); 00094 void destroyDDSFactory(); 00095 00096 DDS::DomainParticipant* createDDSParticipant(); 00097 void destroyDDSParticipant(DDS::DomainParticipant* domainParticipant); 00098 00099 static DDS::DomainParticipantFactory *factory_m; 00100 static unsigned int globalParticipantRefCount_m; 00101 static DDS::DomainParticipant* globalParticipant_m; 00102 DDS::DomainParticipant* participant_m; 00103 ACE_Recursive_Thread_Mutex globalPartMutex_m; 00104 ACE_Recursive_Thread_Mutex DDSFactoryMutex_m; 00105 };//class BulkDataNTStream 00106 00107 }; 00108 00109 #endif
1.7.0