00001 #ifndef ALARMSOURCETHREAD_H 00002 #define ALARMSOURCETHREAD_H 00003 /******************************************************************************* 00004 * ALMA - Atacama Large Millimiter Array 00005 * Copyright (c) European Southern Observatory, 2012 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: AlarmSourceThread.h,v 1.1 2012/04/26 12:35:42 acaproni Exp $" 00022 * 00023 * who when what 00024 * -------- -------- ---------------------------------------------- 00025 * acaproni 2012-04-24 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 <set> 00038 #include "ace/Task.h" 00039 00040 #include <acsThread.h> 00041 00042 #include "AlarmSource.h" 00043 00044 namespace acsalarm { 00045 00069 class AlarmSourceThread: public ACS::Thread { 00070 private: 00071 00072 // Synchronize access to shared vars 00073 ACE_Recursive_Thread_Mutex m_mutex; 00074 00075 std::set<AlarmSource*> m_alarmSources; 00076 00077 public: 00078 00082 AlarmSourceThread(); 00083 00087 virtual ~AlarmSourceThread(); 00088 00100 void runLoop(); 00101 00108 bool registerForUpdating(AlarmSource* src); 00109 00116 bool unregisterFromUpdating(AlarmSource* src); 00117 }; 00118 } 00119 00120 #endif
1.7.0