Initial commit

1 files changed, 156 insertions, 0 deletions

diff --git a/conflictcheck_thread.c b/conflictcheck_thread.c
new file mode 100644
index 0000000..7a7fabf
--- /dev/null
+++ b/conflictcheck_thread.c
@@ -0,0 +1,156 @@
+/*
+Copyright (C) 2004-2007 Christian Wieninger
+
+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, write to the Free Software
+Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+Or, point your browser to http://www.gnu.org/licenses/old-licenses/gpl-2.0.html
+
+The author can be reached at cwieninger@gmx.de
+
+The project's page is at http://winni.vdr-developer.org/epgsearch
+*/
+
+#include <vector>
+#include "conflictcheck_thread.h"
+#include "epgsearchcfg.h"
+#include "mail.h"
+
+#define CONFLICTCHECK_NICE 19
+#define CONFLCHECK_WAIT 20
+
+cConflictCheckThread *cConflictCheckThread::m_Instance = NULL;
+time_t cConflictCheckThread::m_cacheNextConflict = 0;
+int cConflictCheckThread::m_cacheRelevantConflicts = 0;
+int cConflictCheckThread::m_cacheTotalConflicts = 0;
+bool cConflictCheckThread::m_runOnce = false; 
+bool cConflictCheckThread::m_forceUpdate = false;
+
+cConflictCheckThread::cConflictCheckThread(cPluginEpgsearch* thePlugin)
+: cThread("EPGSearch: conflictcheck")
+{
+    m_plugin = thePlugin;
+    m_Active = false;
+    m_lastUpdate = time(NULL);
+    m_runOnce = false;
+    m_forceUpdate = false;
+}
+
+cConflictCheckThread::~cConflictCheckThread() {
+    if (m_Active) 
+	Stop();
+}
+
+void cConflictCheckThread::Init(cPluginEpgsearch* thePlugin, bool runOnce) 
+{
+   if (EPGSearchConfig.checkTimerConflictsAfterUpdate || EPGSearchConfig.conflictCheckIntervall == 0)
+   {
+      if (!runOnce) return;    
+      m_runOnce = true;
+   }
+
+   if (m_Instance == NULL) {
+      m_Instance = new cConflictCheckThread(thePlugin);
+      m_Instance->Start();
+   }
+   else
+      if (runOnce) m_forceUpdate = true; // force an update, because thread is already running
+
+}
+
+void cConflictCheckThread::Exit(void) {
+    if (m_Instance != NULL) {
+	m_Instance->Stop();
+	DELETENULL(m_Instance);
+    }
+}
+
+void cConflictCheckThread::Stop(void) {
+    m_Active = false;
+    Cancel(6);
+}
+
+void cConflictCheckThread::Action(void) 
+{
+    SetPriority(CONFLICTCHECK_NICE);
+
+    m_Active = true;
+    // let VDR do its startup
+    if (!m_runOnce)   
+      for(int wait = 0; wait < CONFLCHECK_WAIT && m_Active; wait++)
+	sleepSec(1);
+
+    time_t nextUpdate = time(NULL);
+    while (m_Active) 
+    {
+	time_t now = time(NULL);
+	if (now >= nextUpdate || m_forceUpdate)
+	{
+        m_forceUpdate = false;
+	    if (Timers.BeingEdited()) 		
+	    {
+		sleepSec(1);
+		continue;
+	    }
+	    LogFile.iSysLog("timer conflict check started");
+
+	    cConflictCheck conflictCheck;   
+	    conflictCheck.Check(); 
+
+	    time_t nextConflict = 0;
+	    if (conflictCheck.relevantConflicts > 0)
+	    {
+		char* msgfmt = NULL;
+		asprintf(&msgfmt, tr("%d timer conflict(s)! First at %s. Show them?"), conflictCheck.relevantConflicts,
+			 *DateTime(conflictCheck.nextRelevantConflictDate));
+        bool doMessage = EPGSearchConfig.noConflMsgWhileReplay == 0 || 
+           !cDevice::PrimaryDevice()->Replaying() || 
+           conflictCheck.nextRelevantConflictDate - now < 2*60*60;
+		if (doMessage && SendMsg(msgfmt, true,7) == kOk)			
+		{
+		    m_plugin->showConflicts = true;
+		    cRemote::CallPlugin("epgsearch");	
+		}
+		free(msgfmt);
+
+		if (EPGSearchConfig.sendMailOnConflicts)
+		{
+		    cMailConflictNotifier mailNotifier;
+		    mailNotifier.SendConflictNotifications(conflictCheck);
+		}
+	    }
+	    
+	    // store for external access
+	    cConflictCheckThread::m_cacheNextConflict = conflictCheck.nextRelevantConflictDate;
+	    cConflictCheckThread::m_cacheRelevantConflicts = conflictCheck.relevantConflicts;
+	    cConflictCheckThread::m_cacheTotalConflicts = conflictCheck.numConflicts;
+
+	    LogFile.iSysLog("timer conflict check finished");
+
+	    m_lastUpdate = time(NULL);
+	    int Intervall = EPGSearchConfig.conflictCheckIntervall;
+	    if (nextConflict > 0 && EPGSearchConfig.conflictCheckWithinLimit > 0 && 
+		nextConflict - time(NULL) < EPGSearchConfig.conflictCheckWithinLimit * 60)
+		Intervall = EPGSearchConfig.conflictCheckIntervall2;
+
+	    nextUpdate = long(m_lastUpdate/60)*60 + (Intervall * 60);
+	}
+	sleepSec(2); // to avoid high system load if time%30==0 
+	while (m_Active && time(NULL)%30 != 0 && !m_runOnce) // sync heart beat to a multiple of 5secs
+	    sleepSec(1);
+    };
+
+    m_Active = false;
+    LogFile.iSysLog("Leaving conflict check thread");
+}
+