/*
	Based up Neutrino-GUI - Tuxbox-Project
	Copyright (C) 2001 by Steffen Hehn 'McClean'

	Generic Timer.
	Copyright (C) 2013-2016, Thilo Graf 'dbt'

	License: GPL

	This program is free software; you can redistribute it and/or
	modify it under the terms of the GNU General Public
	License as published by the Free Software Foundation; either
	version 2 of the License, or (at your option) any later version.

	This program is distributed in the hope that it will be useful,
	but WITHOUT ANY WARRANTY; without even the implied warranty of
	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
	General Public License for more details.

	You should have received a copy of the GNU General Public License
	along with this program. If not, see <http://www.gnu.org/licenses/>.
*/

#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <global.h>
#include <neutrino.h>

#include "cc_timer.h"
#include <pthread.h>
#include <errno.h>
#include <system/helpers.h>
#include <system/debug.h>
#include <system/set_threadname.h>

using namespace std;

CComponentsTimer::CComponentsTimer(const int& interval, bool is_nano)
{
	name			= "unnamed";
	tm_thread 		= 0;
	tm_interval 		= interval;
	tm_enable_nano		= is_nano;

	sl_stop_timer 		= sigc::mem_fun(*this, &CComponentsTimer::stopTimer);

	if (interval > 0)
		startTimer();
}

CComponentsTimer::~CComponentsTimer()
{
	stopTimer();
}

void CComponentsTimer::runSharedTimerAction()
{
	//start loop
	string tn = "cc:"+name;
	set_threadname(tn.c_str());
	while(tm_enable && tm_interval > 0) {
		tm_mutex.lock();
		OnTimer();
		if (!tm_enable_nano)
			mySleep(tm_interval);
		else
			usleep((useconds_t)tm_interval);
		tm_mutex.unlock();
	}

	if (tm_thread)
		stopThread();
}

//thread handle
void* CComponentsTimer::initThreadAction(void *arg)
{
	CComponentsTimer *timer = static_cast<CComponentsTimer*>(arg);

	timer->runSharedTimerAction();

	return 0;
}

//start up running timer with own thread, return true on succses
void CComponentsTimer::initThread()
{
	if (!tm_enable)
		return;

	if(!tm_thread) {
		void *ptr = static_cast<void*>(this);

		pthread_setcancelstate(PTHREAD_CANCEL_ENABLE,0);
		pthread_setcanceltype (PTHREAD_CANCEL_ASYNCHRONOUS,0);

		int res = pthread_create (&tm_thread, NULL, initThreadAction, ptr);

		if (res != 0){
			dprintf(DEBUG_NORMAL,"\033[33m[CComponentsTimer] [%s - %d] ERROR! pthread_create\033[0m\n", __func__, __LINE__);
			return;
		}else
			dprintf(DEBUG_DEBUG,"\033[33m[CComponentsTimer] [%s - %d] started thread ID:%ld \033[0m\n", __func__, __LINE__, pthread_self());

		if (res == 0)
			CNeutrinoApp::getInstance()->OnBeforeRestart.connect(sl_stop_timer);
	}
}

void CComponentsTimer::stopThread()
{
	//ensure disconnecting possible slots
	while (!sl_stop_timer.empty())
		sl_stop_timer.disconnect();

	while(tm_thread) {
		int thres = pthread_cancel(tm_thread);
		if (thres != 0)
			dprintf(DEBUG_NORMAL,"\033[33m[CComponentsTimer] [%s - %d] ERROR! pthread_cancel, error [%d] %s\033[0m\n", __func__, __LINE__, thres, strerror(thres));

		void* res;
		thres = pthread_join(tm_thread, &res);

		if (res != PTHREAD_CANCELED)
			dprintf(DEBUG_NORMAL, "\033[33m[CComponentsTimer] [%s - %d] ERROR! pthread_join, thread ID:%ld, error [%d] %s\033[0m\n", __func__, __LINE__, pthread_self(), thres, strerror(thres));
		else
			tm_thread = 0;
	}
}

bool CComponentsTimer::startTimer()
{
	tm_enable = true;
	initThread();
	if(tm_thread)
		return true;

	return false;
}

bool CComponentsTimer::stopTimer()
{
	tm_enable = false;
	stopThread();
	if(tm_thread == 0)
		return true;

	return false;
}

void CComponentsTimer::setTimerInterval(const int& interval, bool is_nano)
{
	if (tm_interval == interval && tm_enable_nano == is_nano)
		return;

	tm_enable_nano	= is_nano;
	tm_interval 	= interval;
}