#include <lib/base/eerror.h>
#include <lib/dvb/pmt.h>
#include <lib/dvb/db.h>
-#include <Python.h>
+#include <lib/python/python.h>
int eventData::CacheSize=0;
descriptorMap eventData::descriptors;
__u8 eventData::data[4108];
extern const uint32_t crc32_table[256];
+const eServiceReference &handleGroup(const eServiceReference &ref)
+{
+ if (ref.flags & eServiceReference::isGroup)
+ {
+ ePtr<eDVBResourceManager> res;
+ if (!eDVBResourceManager::getInstance(res))
+ {
+ ePtr<iDVBChannelList> db;
+ if (!res->getChannelList(db))
+ {
+ eBouquet *bouquet=0;
+ if (!db->getBouquet(ref, bouquet))
+ {
+ std::list<eServiceReference>::iterator it(bouquet->m_services.begin());
+ if (it != bouquet->m_services.end())
+ return *it;
+ }
+ }
+ }
+ }
+ return ref;
+}
+
+
eventData::eventData(const eit_event_struct* e, int size, int type)
:ByteSize(size&0xFF), type(type&0xFF)
{
int ptr=10;
int descriptors_length = (data[ptr++]&0x0F) << 8;
descriptors_length |= data[ptr++];
- while ( descriptors_length > 0 )
+ while ( descriptors_length )
{
__u8 *descr = data+ptr;
int descr_len = descr[1]+2;
*pdescr++=crc;
descriptors_length -= descr_len;
}
+ ASSERT(pdescr <= &descr[65]);
ByteSize = 12+((pdescr-descr)*4);
EITdata = new __u8[ByteSize];
CacheSize+=ByteSize;
const eit_event_struct* eventData::get() const
{
- int pos = 12;
+ int pos = 10;
int tmp = ByteSize-12;
memcpy(data, EITdata, 12);
+ int descriptors_length = (data[pos++]&0x0F) << 8;
+ descriptors_length |= data[pos++];
__u32 *p = (__u32*)(EITdata+12);
while(tmp>0)
{
memcpy(data+pos, it->second.second, b );
pos += b;
}
+ else
+ eFatal("LINE %d descriptor not found in descriptor cache %08x!!!!!!", __LINE__, *(p-1));
tmp-=4;
}
-
+ ASSERT(pos <= 4108);
+ ASSERT((pos-12) == descriptors_length);
return (const eit_event_struct*)data;
}
if ( ByteSize )
{
CacheSize-=ByteSize;
- ByteSize-=12;
+ int descriptors_length = (EITdata[10]&0x0F) << 8;
+ descriptors_length |= EITdata[11];
__u32 *d = (__u32*)(EITdata+12);
- while(ByteSize)
+ while(descriptors_length)
{
descriptorMap::iterator it =
descriptors.find(*d++);
if ( it != descriptors.end() )
{
descriptorPair &p = it->second;
+ descriptors_length -= (it->second.second[1]+2);
if (!--p.first) // no more used descriptor
{
CacheSize -= it->second.second[1];
descriptors.erase(it); // remove entry from descriptor map
}
}
- ByteSize-=4;
+ else
+ eFatal("LINE %d descriptor not found in descriptor cache %08x!!!!!!", __LINE__, *(d-1));
}
delete [] EITdata;
+ ASSERT(!descriptors_length);
}
}
content_time_tables.find( DBIt->first );
if ( x != content_time_tables.end() )
{
- timeMap &tmMap = eventDB[DBIt->first].second;
+ timeMap &tmMap = DBIt->second.second;
for ( contentMap::iterator i = x->second.begin(); i != x->second.end(); )
{
for ( contentTimeMap::iterator it(i->second.begin());
#ifdef ENABLE_PRIVATE_EPG
case Message::got_private_pid:
{
+ singleLock s(channel_map_lock);
for (channelMapIterator it(m_knownChannels.begin()); it != m_knownChannels.end(); ++it)
{
eDVBChannel *channel = (eDVBChannel*) it->first;
data->m_PrevVersion = -1;
data->m_PrivatePid = msg.pid;
data->m_PrivateService = msg.service;
- updateMap::iterator It = channelLastUpdated.find( channel->getChannelID() );
+ int onid = chid.original_network_id.get();
+ onid |= 0x80000000; // we use highest bit as private epg indicator
+ chid.original_network_id = onid;
+ updateMap::iterator It = channelLastUpdated.find( chid );
int update = ( It != channelLastUpdated.end() ? ( UPDATE_INTERVAL - ( (eDVBLocalTimeHandler::getInstance()->nowTime()-It->second) * 1000 ) ) : ZAP_DELAY );
if (update < ZAP_DELAY)
update = ZAP_DELAY;
}
char text1[13];
fread( text1, 13, 1, f);
- if ( !strncmp( text1, "ENIGMA_EPG_V5", 13) )
+ if ( !strncmp( text1, "ENIGMA_EPG_V6", 13) )
{
fread( &size, sizeof(int), 1, f);
while(size--)
{
unsigned int magic = 0x98765432;
fwrite( &magic, sizeof(int), 1, f);
- const char *text = "ENIGMA_EPG_V5";
+ const char *text = "ENIGMA_EPG_V6";
fwrite( text, 13, 1, f );
int size = eventDB.size();
fwrite( &size, sizeof(int), 1, f );
// if t == -1 we search the current event...
{
singleLock s(cache_lock);
- uniqueEPGKey key(service);
+ uniqueEPGKey key(handleGroup(service));
// check if EPG for this service is ready...
eventCache::iterator It = eventDB.find( key );
RESULT eEPGCache::lookupEventId(const eServiceReference &service, int event_id, const eventData *&result )
{
singleLock s(cache_lock);
- uniqueEPGKey key( service );
+ uniqueEPGKey key(handleGroup(service));
eventCache::iterator It = eventDB.find( key );
if ( It != eventDB.end() && !It->second.first.empty() ) // entrys cached?
RESULT eEPGCache::startTimeQuery(const eServiceReference &service, time_t begin, int minutes)
{
- eventCache::iterator It = eventDB.find( service );
+ Lock();
+ eventCache::iterator It = eventDB.find(handleGroup(service));
if ( It != eventDB.end() && It->second.second.size() )
{
m_timemap_end = minutes != -1 ? It->second.second.upper_bound(begin+minutes*60) : It->second.second.end();
}
else
m_timemap_cursor = It->second.second.begin();
- const eServiceReferenceDVB &ref = (const eServiceReferenceDVB&)service;
+ const eServiceReferenceDVB &ref = (const eServiceReferenceDVB&)handleGroup(service);
currentQueryTsidOnid = (ref.getTransportStreamID().get()<<16) | ref.getOriginalNetworkID().get();
+ Unlock();
return 0;
}
+ Unlock();
return -1;
}
return -1;
}
-void fillTuple(PyObject *tuple, char *argstring, int argcount, PyObject *service, ePtr<eServiceEvent> &ptr, PyObject *nowTime, PyObject *service_name )
+void fillTuple(ePyObject tuple, char *argstring, int argcount, ePyObject service, ePtr<eServiceEvent> &ptr, ePyObject nowTime, ePyObject service_name )
{
- PyObject *tmp=NULL;
+ ePyObject tmp;
int pos=0;
while(pos < argcount)
{
tmp = PyLong_FromLong(0);
break;
case 'I': // Event Id
- tmp = ptr ? PyLong_FromLong(ptr->getEventId()) : NULL;
+ tmp = ptr ? PyLong_FromLong(ptr->getEventId()) : ePyObject();
break;
case 'B': // Event Begin Time
- tmp = ptr ? PyLong_FromLong(ptr->getBeginTime()) : NULL;
+ tmp = ptr ? PyLong_FromLong(ptr->getBeginTime()) : ePyObject();
break;
case 'D': // Event Duration
- tmp = ptr ? PyLong_FromLong(ptr->getDuration()) : NULL;
+ tmp = ptr ? PyLong_FromLong(ptr->getDuration()) : ePyObject();
break;
case 'T': // Event Title
- tmp = ptr ? PyString_FromString(ptr->getEventName().c_str()) : NULL;
+ tmp = ptr ? PyString_FromString(ptr->getEventName().c_str()) : ePyObject();
break;
case 'S': // Event Short Description
- tmp = ptr ? PyString_FromString(ptr->getShortDescription().c_str()) : NULL;
+ tmp = ptr ? PyString_FromString(ptr->getShortDescription().c_str()) : ePyObject();
break;
case 'E': // Event Extended Description
- tmp = ptr ? PyString_FromString(ptr->getExtendedDescription().c_str()) : NULL;
+ tmp = ptr ? PyString_FromString(ptr->getExtendedDescription().c_str()) : ePyObject();
break;
case 'C': // Current Time
tmp = nowTime;
}
}
-PyObject *handleEvent(ePtr<eServiceEvent> &ptr, PyObject *dest_list, char* argstring, int argcount, PyObject *service, PyObject *nowTime, PyObject *service_name, PyObject *convertFunc, PyObject *convertFuncArgs)
+int handleEvent(ePtr<eServiceEvent> &ptr, ePyObject dest_list, char* argstring, int argcount, ePyObject service, ePyObject nowTime, ePyObject service_name, ePyObject convertFunc, ePyObject convertFuncArgs)
{
if (convertFunc)
{
fillTuple(convertFuncArgs, argstring, argcount, service, ptr, nowTime, service_name);
- PyObject *result = PyObject_CallObject(convertFunc, convertFuncArgs);
- if (result == NULL)
+ ePyObject result = PyObject_CallObject(convertFunc, convertFuncArgs);
+ if (result)
{
if (service_name)
Py_DECREF(service_name);
Py_DECREF(nowTime);
Py_DECREF(convertFuncArgs);
Py_DECREF(dest_list);
- return result;
+ PyErr_SetString(PyExc_StandardError,
+ "error in convertFunc execute");
+ eDebug("error in convertFunc execute");
+ return -1;
}
PyList_Append(dest_list, result);
Py_DECREF(result);
}
else
{
- PyObject *tuple = PyTuple_New(argcount);
+ ePyObject tuple = PyTuple_New(argcount);
fillTuple(tuple, argstring, argcount, service, ptr, nowTime, service_name);
PyList_Append(dest_list, tuple);
Py_DECREF(tuple);
// when type is time then it is the start_time ( 0 for now_time )
// the fourth is the end_time .. ( optional .. for query all events in time range)
-PyObject *eEPGCache::lookupEvent(PyObject *list, PyObject *convertFunc)
+PyObject *eEPGCache::lookupEvent(ePyObject list, ePyObject convertFunc)
{
- PyObject *convertFuncArgs=NULL;
+ ePyObject convertFuncArgs;
int argcount=0;
char *argstring=NULL;
if (!PyList_Check(list))
}
else
{
- PyObject *argv=PyList_GET_ITEM(list, 0); // borrowed reference!
+ ePyObject argv=PyList_GET_ITEM(list, 0); // borrowed reference!
if (PyString_Check(argv))
{
argstring = PyString_AS_STRING(argv);
convertFuncArgs = PyTuple_New(argcount);
}
- PyObject *nowTime = strchr(argstring, 'C') ?
+ ePyObject nowTime = strchr(argstring, 'C') ?
PyLong_FromLong(eDVBLocalTimeHandler::getInstance()->nowTime()) :
- NULL;
+ ePyObject();
bool must_get_service_name = strchr(argstring, 'N') ? true : false;
// create dest list
- PyObject *dest_list=PyList_New(0);
+ ePyObject dest_list=PyList_New(0);
while(listSize > listIt)
{
- PyObject *item=PyList_GET_ITEM(list, listIt++); // borrowed reference!
+ ePyObject item=PyList_GET_ITEM(list, listIt++); // borrowed reference!
if (PyTuple_Check(item))
{
bool service_changed=false;
int minutes=0;
int tupleSize=PyTuple_Size(item);
int tupleIt=0;
- PyObject *service=NULL;
+ ePyObject service;
while(tupleSize > tupleIt) // parse query args
{
- PyObject *entry=PyTuple_GET_ITEM(item, tupleIt); // borrowed reference!
+ ePyObject entry=PyTuple_GET_ITEM(item, tupleIt); // borrowed reference!
switch(tupleIt++)
{
case 0:
break;
}
}
- eServiceReference ref(PyString_AS_STRING(service));
+ eServiceReference ref(handleGroup(eServiceReference(PyString_AS_STRING(service))));
if (ref.type != eServiceReference::idDVB)
{
eDebug("service reference for epg query is not valid");
}
}
- PyObject *service_name=NULL;
+ ePyObject service_name;
if (must_get_service_name)
{
ePtr<iStaticServiceInformation> sptr;
ePtr<eServiceEvent> ptr;
while (!getNextTimeEntry(ptr))
{
- PyObject *ret = handleEvent(ptr, dest_list, argstring, argcount, service, nowTime, service_name, convertFunc, convertFuncArgs);
- if (ret)
- return ret;
+ if (handleEvent(ptr, dest_list, argstring, argcount, service, nowTime, service_name, convertFunc, convertFuncArgs))
+ {
+ Unlock();
+ return 0; // error
+ }
}
}
Unlock();
else
lookupEventTime(ref, stime, ptr, type);
}
- PyObject *ret = handleEvent(ptr, dest_list, argstring, argcount, service, nowTime, service_name, convertFunc, convertFuncArgs);
- if (ret)
- return ret;
+ if (handleEvent(ptr, dest_list, argstring, argcount, service, nowTime, service_name, convertFunc, convertFuncArgs))
+ return 0; // error
}
if (service_changed)
Py_DECREF(service);
return dest_list;
}
-void fillTuple2(PyObject *tuple, const char *argstring, int argcount, eventData *evData, ePtr<eServiceEvent> &ptr, PyObject *service_name, PyObject *service_reference)
+void fillTuple2(ePyObject tuple, const char *argstring, int argcount, eventData *evData, ePtr<eServiceEvent> &ptr, ePyObject service_name, ePyObject service_reference)
{
- PyObject *tmp=NULL;
+ ePyObject tmp;
int pos=0;
while(pos < argcount)
{
break;
case 'B': // Event Begin Time
if (ptr)
- tmp = ptr ? PyLong_FromLong(ptr->getBeginTime()) : NULL;
+ tmp = ptr ? PyLong_FromLong(ptr->getBeginTime()) : ePyObject();
else
tmp = PyLong_FromLong(evData->getStartTime());
break;
case 'D': // Event Duration
if (ptr)
- tmp = ptr ? PyLong_FromLong(ptr->getDuration()) : NULL;
+ tmp = ptr ? PyLong_FromLong(ptr->getDuration()) : ePyObject();
else
tmp = PyLong_FromLong(evData->getDuration());
break;
case 'T': // Event Title
- tmp = ptr ? PyString_FromString(ptr->getEventName().c_str()) : NULL;
+ tmp = ptr ? PyString_FromString(ptr->getEventName().c_str()) : ePyObject();
break;
case 'S': // Event Short Description
- tmp = ptr ? PyString_FromString(ptr->getShortDescription().c_str()) : NULL;
+ tmp = ptr ? PyString_FromString(ptr->getShortDescription().c_str()) : ePyObject();
break;
case 'E': // Event Extended Description
- tmp = ptr ? PyString_FromString(ptr->getExtendedDescription().c_str()) : NULL;
+ tmp = ptr ? PyString_FromString(ptr->getExtendedDescription().c_str()) : ePyObject();
break;
case 'R': // service reference string
tmp = service_reference;
// 0 = case sensitive (CASE_CHECK)
// 1 = case insensitive (NO_CASECHECK)
-PyObject *eEPGCache::search(PyObject *arg)
+PyObject *eEPGCache::search(ePyObject arg)
{
- PyObject *ret = 0;
+ ePyObject ret;
int descridx = -1;
__u32 descr[512];
int eventid = -1;
int tuplesize=PyTuple_Size(arg);
if (tuplesize > 0)
{
- PyObject *obj = PyTuple_GET_ITEM(arg,0);
+ ePyObject obj = PyTuple_GET_ITEM(arg,0);
if (PyString_Check(obj))
{
argcount = PyString_GET_SIZE(obj);
querytype = PyLong_AsLong(PyTuple_GET_ITEM(arg, 2));
if (tuplesize > 4 && querytype == 0)
{
- PyObject *obj = PyTuple_GET_ITEM(arg, 3);
+ ePyObject obj = PyTuple_GET_ITEM(arg, 3);
if (PyString_Check(obj))
{
refstr = PyString_AS_STRING(obj);
}
else if (tuplesize > 4 && (querytype == 1 || querytype == 2) )
{
- PyObject *obj = PyTuple_GET_ITEM(arg, 3);
+ ePyObject obj = PyTuple_GET_ITEM(arg, 3);
if (PyString_Check(obj))
{
int casetype = PyLong_AsLong(PyTuple_GET_ITEM(arg, 4));
return NULL;
}
+ ASSERT(descridx <= 512);
+
if (descridx > -1)
{
int maxcount=maxmatches;
- eServiceReferenceDVB ref(refstr?refstr:"");
+ eServiceReferenceDVB ref(refstr?(const eServiceReferenceDVB&)handleGroup(eServiceReference(refstr)):eServiceReferenceDVB(""));
// ref is only valid in SIMILAR_BROADCASTING_SEARCH
// in this case we start searching with the base service
bool first = ref.valid() ? true : false;
++cit;
continue;
}
- PyObject *service_name=0;
- PyObject *service_reference=0;
+ ePyObject service_name;
+ ePyObject service_reference;
timeMap &evmap = cit->second.second;
// check all events
for (timeMap::iterator evit(evmap.begin()); evit != evmap.end() && maxcount; ++evit)
{
- if (evit->second->getEventID() == eventid)
+ int evid = evit->second->getEventID();
+ if ( evid == eventid)
continue;
__u8 *data = evit->second->EITdata;
int tmp = evit->second->ByteSize-12;
ePtr<eServiceEvent> ptr;
if (needServiceEvent)
{
- lookupEventId(ref, evit->first, ptr);
+ lookupEventId(ref, evid, ptr);
if (!ptr)
eDebug("event not found !!!!!!!!!!!");
}
if (!ret)
ret = PyList_New(0);
// create tuple
- PyObject *tuple = PyTuple_New(argcount);
+ ePyObject tuple = PyTuple_New(argcount);
// fill tuple
fillTuple2(tuple, argstring, argcount, evit->second, ptr, service_name, service_reference);
PyList_Append(ret, tuple);
}
if (!ret)
- {
- Py_INCREF(Py_None);
- ret=Py_None;
- }
+ Py_RETURN_NONE;
return ret;
}
int sid = data[ptr++] << 8;
sid |= data[ptr++];
-// WORKAROUND for wrong transmitted epg data
- if ( onid == 0x85 && tsid == 0x11 && sid == 0xd3 ) // premiere sends wrong tsid here
- tsid = 0x1;
- else if ( onid == 0x85 && tsid == 0x3 && sid == 0xf5 ) // premiere sends wrong sid here
- sid = 0xdc;
+// WORKAROUND for wrong transmitted epg data (01.08.2006)
+ if ( onid == 0x85 )
+ {
+ switch( (tsid << 16) | sid )
+ {
+ case 0x01030b: sid = 0x1b; tsid = 4; break; // Premiere Win
+ case 0x0300f0: sid = 0xe0; tsid = 2; break;
+ case 0x0300f1: sid = 0xe1; tsid = 2; break;
+ case 0x0300f5: sid = 0xdc; break;
+ case 0x0400d2: sid = 0xe2; tsid = 0x11; break;
+ case 0x1100d3: sid = 0xe3; break;
+ }
+ }
////////////////////////////////////////////
-
+
uniqueEPGKey service( sid, onid, tsid );
descr_len -= 6;
while( descr_len > 0 )
ptr += descr_len;
}
}
+ ASSERT(pdescr <= &descriptors[65])
__u8 event[4098];
eit_event_struct *ev_struct = (eit_event_struct*) event;
ev_struct->running_status = 0;
ptr+=(*d++)[1];
ptr+=2;
}
+ ASSERT(ptr <= 4098);
for ( std::map< date_time, std::list<uniqueEPGKey> >::iterator it(start_times.begin()); it != start_times.end(); ++it )
{
time_t now = eDVBLocalTimeHandler::getInstance()->nowTime();
void eEPGCache::channel_data::readPrivateData( const __u8 *data)
{
- if ( seenPrivateSections.find( data[6] ) == seenPrivateSections.end() )
+ if ( seenPrivateSections.find(data[6]) == seenPrivateSections.end() )
{
cache->privateSectionRead(m_PrivateService, data);
seenPrivateSections.insert(data[6]);
if ( seenPrivateSections.size() == (unsigned int)(data[7] + 1) )
{
eDebug("[EPGC] private finished");
+ eDVBChannelID chid = channel->getChannelID();
+ int tmp = chid.original_network_id.get();
+ tmp |= 0x80000000; // we use highest bit as private epg indicator
+ chid.original_network_id = tmp;
+ cache->channelLastUpdated[chid] = eDVBLocalTimeHandler::getInstance()->nowTime();
m_PrevVersion = (data[5] & 0x3E) >> 1;
startPrivateReader();
}
putenv("TZ=CET-1CEST,M3.5.0/2,M10.5.0/3");
tzset();
- tm *localnow = localtime( &dt );
+ tm localnow;
+ localtime_r(&dt, &localnow);
if (day == 7)
day = 0;
- if ( day + 1 < localnow->tm_wday ) // day + 1 to prevent old events to show for next week.
+ if ( day + 1 < localnow.tm_wday ) // day + 1 to prevent old events to show for next week.
day += 7;
if (local_hours <= 5)
day++;
- dt += 3600*24*(day - localnow->tm_wday); // Shift dt to the recording date (local time zone).
- dt += 3600*(local_hours - localnow->tm_hour); // Shift dt to the recording hour.
+ dt += 3600*24*(day - localnow.tm_wday); // Shift dt to the recording date (local time zone).
+ dt += 3600*(local_hours - localnow.tm_hour); // Shift dt to the recording hour.
- tm *recdate = gmtime( &dt ); // This will also take care of DST.
+ tm recdate;
+ gmtime_r( &dt, &recdate ); // This will also take care of DST.
if ( old_tz == NULL )
unsetenv( "TZ" );
// Calculate MJD according to annex in ETSI EN 300 468
int l=0;
- if ( recdate->tm_mon <= 1 ) // Jan or Feb
+ if ( recdate.tm_mon <= 1 ) // Jan or Feb
l=1;
- int mjd = 14956 + recdate->tm_mday + int( (recdate->tm_year - l) * 365.25) +
- int( (recdate->tm_mon + 2 + l * 12) * 30.6001);
+ int mjd = 14956 + recdate.tm_mday + int( (recdate.tm_year - l) * 365.25) +
+ int( (recdate.tm_mon + 2 + l * 12) * 30.6001);
return_time[0] = (mjd & 0xFF00)>>8;
return_time[1] = mjd & 0xFF;
- timeMHW2DVB( recdate->tm_hour, minutes, return_time+2 );
+ timeMHW2DVB( recdate.tm_hour, minutes, return_time+2 );
}
void eEPGCache::channel_data::storeTitle(std::map<__u32, mhw_title_t>::iterator itTitle, std::string sumText, const __u8 *data)
channel.transport_stream_id_lo = *(tmp++);
channel.channel_id_hi = *(tmp++);
channel.channel_id_lo = *(tmp++);
+#warning FIXME hardcoded network_id in mhw2 epg
channel.network_id_hi = 0; // hardcoded astra 19.2
channel.network_id_lo = 1;
m_channels.push_back(channel);
}
}
abort:
- isRunning &= ~eEPGCache::MHW;
+ isRunning &= ~MHW;
m_MHWConn2=0;
if ( m_MHWReader2 )
m_MHWReader2->stop();
git.cweiske.de / enigma2.git / blobdiff