1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
/*
Copyright (C) 2004-2008 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 "switchtimer_thread.h"
#include "epgsearchcfg.h"
#include "epgsearchtools.h"
#include <vdr/tools.h>
#include <vdr/plugin.h>
#define MSG_DELAY 5
#define SWITCHTIMER_WAIT 20
cSwitchTimerThread *cSwitchTimerThread::m_Instance = NULL;
cSwitchTimerThread::cSwitchTimerThread(void)
: cThread("EPGSearch: switchtimer")
{
m_Active = false;
m_lastUpdate = time(NULL);
}
cSwitchTimerThread::~cSwitchTimerThread() {
if (m_Active)
Stop();
}
void cSwitchTimerThread::Init(void) {
if (m_Instance == NULL && SwitchTimers.Count() > 0) {
m_Instance = new cSwitchTimerThread;
m_Instance->Start();
}
}
void cSwitchTimerThread::Exit(void) {
if (m_Instance != NULL) {
m_Instance->Stop();
DELETENULL(m_Instance);
}
}
void cSwitchTimerThread::Stop(void) {
m_Active = false;
Cancel(6);
}
void cSwitchTimerThread::Action(void)
{
m_Active = true;
// let VDR do its startup
for(int wait = 0; wait < SWITCHTIMER_WAIT && m_Active; wait++)
sleepSec(1);
time_t nextUpdate = time(NULL);
while (m_Active)
{
time_t now = time(NULL);
if (now >= nextUpdate)
{
LogFile.Log(3,"locking switch timers");
cMutexLock SwitchTimersLock(&SwitchTimers);
LogFile.Log(3,"switch timer check started");
cSwitchTimer* switchTimer = SwitchTimers.First();
while (switchTimer && m_Active)
{
const cEvent* event = switchTimer->event;
if (event && event->StartTime() - now < switchTimer->switchMinsBefore*60 + MSG_DELAY + 1)
{
cChannel *channel = Channels.GetByChannelID(event->ChannelID(), true, true);
bool doswitch = (switchTimer->announceOnly == 0);
SwitchTimers.Del(switchTimer);
if (channel && (event->EndTime() >= now))
{
// announce and switch
if (doswitch)
{
LogFile.Log(1,"switching to channel %d", channel->Number());
cString cmd = cString::sprintf("CHAN %d", channel->Number());
SendViaSVDRP(cmd);
if (switchTimer->unmute && cDevice::PrimaryDevice()->IsMute())
cDevice::PrimaryDevice()->ToggleMute();
}
cString Message = cString::sprintf("%s: %s - %s", event->Title(),
CHANNELNAME(channel), GETTIMESTRING(event));
SendMsg(Message);
sleepSec(MSG_DELAY);
}
SwitchTimers.Save();
break;
}
switchTimer = SwitchTimers.Next(switchTimer);
}
LogFile.Log(3,"switch timer check finished");
sleepSec(MSG_DELAY);
m_lastUpdate = time(NULL);
nextUpdate = long(m_lastUpdate/60)*60+ 60 - MSG_DELAY ; // check at each full minute minus 5sec
if (SwitchTimers.Count() == 0)
m_Active = false;
}
while (m_Active && time(NULL)%MSG_DELAY != 0) // sync heart beat to MSG_DELAY
sleepSec(1);
sleepSec(1);
};
m_Instance = NULL;
}
|
