00001 #ifndef ALARM_SYSTEM_INTERFACE_H 00002 #define ALARM_SYSTEM_INTERFACE_H 00003 /******************************************************************************* 00004 * ALMA - Atacama Large Millimiter Array 00005 * (c) European Southern Observatory, 2006 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: AlarmSystemInterface.h,v 1.4 2009/10/08 10:21:01 acaproni Exp $" 00022 * 00023 * who when what 00024 * -------- -------- ---------------------------------------------- 00025 * acaproni 2006-08-16 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 #include "FaultState.h" 00038 #include "ASIMessage.h" 00039 #include "ASIConfiguration.h" 00040 #include <vector> 00041 #include <string> 00042 #include "ace/Task.h" 00043 00044 namespace acsalarm 00045 { 00051 class AlarmSystemInterface 00052 { 00053 public: 00054 00055 AlarmSystemInterface() {}; 00056 virtual ~AlarmSystemInterface() {}; 00057 00062 virtual void setSourceName(std::string newSourceName) { sourceName = newSourceName; } 00063 00068 virtual std::string getSourceName() { return sourceName; } 00069 00074 virtual void setHostName(std::string newHostName) { hostName = newHostName; } 00075 00080 virtual std::string getHostName() { return hostName; } 00081 00087 virtual void push(FaultState & state); //raises ASIException = 0; 00088 00094 virtual void push(std::vector<FaultState> & states); // raises ASIException = 0; 00095 00101 virtual void pushActiveList(std::vector<FaultState> & activeFaults); // raises ASIException = 0; 00102 00107 virtual void close() = 0; 00108 00109 protected: 00113 virtual bool publishMessage(ASIMessage msg) = 0; 00114 00115 std::string sourceName; 00116 std::string hostName; 00117 acsalarm::ASIConfiguration configuration; 00118 00119 // Synch the public methods because one source can be used 00120 // by different threads 00121 ACE_Recursive_Thread_Mutex m_mutex; 00122 00123 private: 00135 void commonPush(std::vector<FaultState> & states, bool backup); 00136 }; 00137 }; 00138 #endif 00139
1.7.0