00001 #ifndef REPEATGUARD_H 00002 #define REPEATGUARD_H 00003 /******************************************************************************* 00004 * ALMA - Atacama Large Millimiter Array 00005 * (c) Associated Universities Inc., 2007 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: RepeatGuard.h,v 1.6 2008/05/21 20:25:08 nbarriga Exp $" 00022 * 00023 * who when what 00024 * -------- -------- ---------------------------------------------- 00025 * nbarriga 2007-02-20 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 <acsutilTimeStamp.h> 00038 #include "acsThread.h" 00039 00040 namespace repeatguard{ 00041 const unsigned int AND = 0; 00042 const unsigned int OR = 1; 00043 const unsigned int TIMER = 2; 00044 const unsigned int COUNTER =3; 00045 }; 00046 00055 class RepeatGuard{ 00056 private: 00057 00058 protected: 00059 unsigned int counter; 00060 unsigned int counterAtLastCheck; 00061 unsigned int maxRepetitions; 00062 unsigned int method; 00063 bool firstTime; 00064 ACS::TimeInterval interval; 00065 ACS::Time lastTime; 00066 ACE_Recursive_Thread_Mutex mutex; 00067 public: 00074 RepeatGuard(ACS::TimeInterval interval, unsigned int maxRepetitions, bool or_or_and=true); 00075 00076 ~RepeatGuard(); 00077 00082 bool check(); 00083 00089 bool checkAndIncrement(); 00090 00094 void increment(); 00095 00099 unsigned int count(); 00100 00103 void reset(); 00104 00111 void reset(ACS::TimeInterval interval, unsigned int maxRepetitions, bool or_or_and=true); 00112 00113 00114 }; 00115 #endif