/*
 * alarm-thread.cpp
 *
 * $Author: claudio $
 *
 * $Revision: 1.7 $
 *
 * $Log: alarm-thread.cpp,v $
 * Revision 1.7  2015-07-21 13:40:59  claudio
 * minor cleanups
 *
 * Revision 1.6  2013-03-06 10:41:11  claudio
 * commented out debug print statements
 *
 * Revision 1.5  2008-07-08 12:11:39  graziano
 * omni_thread_fatal exception handling
 *
 * Revision 1.4  2008/07/07 09:13:12  graziano
 * omni_thread_fatal exception handling
 *
 * Revision 1.3  2008/04/24 06:51:34  graziano
 * small code cleanings
 *
 *
 *
 * copyleft: Sincrotrone Trieste S.C.p.A. di interesse nazionale
 *           Strada Statale 14 - km 163,5 in AREA Science Park
 *           34012 Basovizza, Trieste ITALY
 */

#include "alarm-thread.h"
static const char __FILE__rev[] = __FILE__ " $Revision: 1.7 $";

/*
 * alarm_thread::alarm_thread()
 */
alarm_thread::alarm_thread(Alarm_ns::Alarm *p) : p_Alarm(p) 
{
	//cout << __FILE__rev << endl;
}

/*
 * alarm_thread::~alarm_thread()
 */
alarm_thread::~alarm_thread()
{
	p_Alarm = NULL;
}

/*
 * alarm_thread::run()
 */
void alarm_thread::run(void *)
{
	size_t to_be_evaluated = 0;
	//int period = 5; //seconds
	int awaken = 0;
	vector<string> alm_to_be_eval;
	while (true) {
		/*
		 * pop_front() will wait() on condition variable
		 */
		try
		{
			if(to_be_evaluated > 0)
			{
				bool changed = true;
				int num_changed = 0;
				if(alm_to_be_eval.size() > 0)
				{
					for(vector<string>::iterator i = alm_to_be_eval.begin(); i != alm_to_be_eval.end(); i++)
					{
						changed = p_Alarm->do_alarm_eval(*i, "FORCED_EVAL", gettime());
						if(changed)
							num_changed++;
					}
#if 0	//TODO
					prepare_alarm_attr();
					if(num_changed==0)
						return;
					if(ds_num == 0)
					{
						//attr.set_value_date_quality(ds,0/*gettime()*/,Tango::ATTR_WARNING, ds_num, 0, false);
						struct timeval now;
						gettimeofday(&now,NULL);
						push_change_event("alarm",(char**)ds,now,Tango::ATTR_WARNING, ds_num, 0, false);
					}
					else
						//attr.set_value(ds, ds_num, 0, false);
						push_change_event("alarm",ds, ds_num, 0, false);
#endif
				}
#if 0
				alm_to_be_eval = p_Alarm->alarms.to_be_evaluated_list();
				to_be_evaluated = alm_to_be_eval.size();
#else
				to_be_evaluated = 0;
#endif
			}
			bei_t e;
			{
				e = p_Alarm->evlist.pop_front();
				//DEBUG_STREAM << "alarm_thread::run(): woken up!!!! " << e.name << endl;
				if ((e.ev_name == ALARM_THREAD_EXIT) && \
					(e.value[0] == ALARM_THREAD_EXIT_VALUE))
				{
					break;
				}
				else if ((e.ev_name == ALARM_THREAD_TO_BE_EVAL) && \
					(e.value[0] == ALARM_THREAD_TO_BE_EVAL_VALUE))
				{
					alm_to_be_eval = p_Alarm->alarms.to_be_evaluated_list();
					to_be_evaluated = alm_to_be_eval.size();
					continue;
				}
				p_Alarm->do_alarm(e);
			}
		}
		catch(omni_thread_fatal& ex)
		{
			ostringstream err;
			err << "omni_thread_fatal exception running alarm thread, err=" << ex.error << ends;
			//WARN_STREAM << "alarm_thread::run(): " << err.str() << endl;	
			printf("alarm_thread::run(): %s", err.str().c_str());
		}			
		catch(Tango::DevFailed& ex)
		{
			ostringstream err;
			err << "exception running alarm thread: '" << ex.errors[0].desc << "'" << ends;
			//WARN_STREAM << "alarm_thread::run(): " << err.str() << endl;	
			printf("alarm_thread::run(): %s", err.str().c_str());
			Tango::Except::print_exception(ex);
		}		
		catch(...)
		{
			//WARN_STREAM << "alarm_thread::run(): catched unknown exception!!" << endl;
			printf("alarm_thread::run(): catched unknown exception!!");
		}		
	}
	//cout << "alarm_thread::run(): returning" << endl;
}  /* alarm_thread::run() */