Converter.__init__(self, type)
self.invert = type == "Invert"
- def changed(self):
+ def changed(self, what):
for x in self.downstream_elements:
x.visible = self.source.boolean
self.type = self.NAME
def getText(self):
+ if self.cache is None:
+ self.cache = self.__getText()
+ return self.cache
+
+ def __getText(self):
event = self.source.event
if event is None:
return "N/A"
raise str("'%s' is not <StartTime|EndTime|Remaining|Duration> for EventTime converter" % type)
def getTime(self):
+ if self.cache is None or self.cache[0] is None:
+ self.cache = (self.__getTime(), self.cache and self.cache[1])
+ return self.cache[0]
+
+ def __getTime(self):
assert self.type != self.PROGRESS
event = self.source.event
return (duration, None)
def getValue(self):
+ if self.cache is None or self.cache[1] is None:
+ self.cache = (self.cache and self.cache[0], self.__getValue())
+ return self.cache[1]
+
+ def __getValue(self):
assert self.type == self.PROGRESS
event = self.source.event
class Poll(object):
def __init__(self):
self.__poll_timer = eTimer()
- self.__poll_timer.timeout.get().append(self.changed)
+ self.__poll_timer.timeout.get().append(self.poll)
self.__interval = 1000
self.__enabled = False
poll_interval = property(lambda self: self.__interval, __setInterval)
poll_enabled = property(lambda self: self.__enabled, __setEnable)
+
+ def poll(self):
+ self.changed((self.CHANGED_POLL,))
}[type]
self.interesting_events = {
- self.HAS_TELETEXT: [iPlayableService.evEnd, iPlayableService.evUpdatedInfo],
- self.IS_MULTICHANNEL: [iPlayableService.evUpdatedInfo, iPlayableService.evEnd],
- self.IS_CRYPTED: [iPlayableService.evUpdatedInfo, iPlayableService.evEnd],
- self.IS_WIDESCREEN: [iPlayableService.evUpdatedEventInfo, iPlayableService.evEnd],
- self.SUBSERVICES_AVAILABLE: [iPlayableService.evUpdatedEventInfo, iPlayableService.evEnd]
+ self.HAS_TELETEXT: [iPlayableService.evUpdatedInfo],
+ self.IS_MULTICHANNEL: [iPlayableService.evUpdatedInfo],
+ self.IS_CRYPTED: [iPlayableService.evUpdatedInfo],
+ self.IS_WIDESCREEN: [iPlayableService.evUpdatedEventInfo],
+ self.SUBSERVICES_AVAILABLE: [iPlayableService.evUpdatedEventInfo]
}[self.type]
def getServiceInfoValue(self, info, what):
return info.getInfoString(what)
def getBoolean(self):
+ if self.cache is None:
+ self.cache = self.__getBoolean()
+ return self.cache
+
+ def __getBoolean(self):
service = self.source.service
info = service and service.info()
if not info:
boolean = property(getBoolean)
- def changed(self, *args):
- if not len(args) or args[0] in [iPlayableService.evStart, iPlayableService.evEnd,
- iPlayableService.evUpdatedInfo, iPlayableService.evUpdatedEventInfo]:
- Converter.changed(self)
+ def changed(self, what):
+ if what[0] != self.CHANGED_SPECIFIC or what[1] in self.interesting_events:
+ Converter.changed(self, what)
text = property(getText)
- def changed(self, *args):
- if not len(args) or args[0] in [iPlayableService.evStart, iPlayableService.evEnd]:
- Converter.changed(self)
+ def changed(self, what):
+ if what[0] != self.CHANGED_SPECIFIC or what[1] in [iPlayableService.evStart]:
+ Converter.changed(self, what)
cutlist = property(getCutlist)
text = property(getText)
- def changed(self, *args):
- cutlist_refresh = len(args) and args[0] in [iPlayableService.evCuesheetChanged, iPlayableService.evStart, iPlayableService.evEnd]
- time_refresh = not len(args) or args[0] in [iPlayableService.evStart, iPlayableService.evEnd]
+ def changed(self, what):
+ cutlist_refresh = what[0] != self.CHANGED_SPECIFIC or what[1] in [iPlayableService.evCuesheetChanged]
+ time_refresh = what[0] == self.CHANGED_POLL or what[0] == self.CHANGED_SPECIFIC and what[1] in [iPlayableService.evCuesheetChanged]
if cutlist_refresh:
if self.type == self.TYPE_GAUGE:
self.downstream_elements.cutlist_changed()
if time_refresh:
- self.downstream_elements.changed()
+ self.downstream_elements.changed(what)
# a bidirectional connection
class Element:
+ CHANGED_DEFAULT = 0 # initial "pull" state
+ CHANGED_ALL = 1 # really everything changed
+ CHANGED_CLEAR = 2 # we're expecting a real update soon. don't bother polling NOW, but clear data.
+ CHANGED_SPECIFIC = 3 # second tuple will specify what exactly changed
+ CHANGED_POLL = 4 # a timer expired
+
def __init__(self):
self.downstream_elements = CList()
self.master = None
self.source = None
+ self.clearCache()
def connectDownstream(self, downstream):
self.downstream_elements.append(downstream)
def connectUpstream(self, upstream):
assert self.source is None
self.source = upstream
- self.changed()
+ self.changed((self.CHANGED_DEFAULT,))
def connect(self, upstream):
self.connectUpstream(upstream)
# default action: push downstream
def changed(self, *args, **kwargs):
+ self.clearCache()
self.downstream_elements.changed(*args, **kwargs)
+ self.clearCache()
def reconnectUpstream(self, new_upstream):
assert self.source is not None
self.source = new_upstream
+
+ def clearCache(self):
+ self.cache = None
def connect(self, source):
Renderer.connect(self, source)
- self.changed()
+ self.changed((self.CHANGED_DEFAULT,))
- def changed(self):
- self.text = self.source.text
+ def changed(self, what):
+ if what[0] == self.CHANGED_CLEAR:
+ self.text = ""
+ else:
+ self.text = self.source.text
GUI_WIDGET = ePositionGauge
def postWidgetCreate(self, instance):
- self.changed()
+ self.changed((self.CHANGED_DEFAULT,))
self.cutlist_changed()
instance.setInOutList(self.__cutlist)
- def changed(self):
- (self.length, self.position) = (self.source.length or 0, self.source.position or 0)
+ def changed(self, what):
+ if what[0] == self.CHANGED_CLEAR:
+ (self.length, self.position) = 0
+ else:
+ (self.length, self.position) = (self.source.length or 0, self.source.position or 0)
def cutlist_changed(self):
self.cutlist = self.source.cutlist or [ ]
GUI_WIDGET = eSlider
- def changed(self):
+ def changed(self, what):
+ if what[0] == self.CHANGED_CLEAR:
+ (self.range, self.value) = ((0, 1), 0)
+ return
+
range = self.source.range or 100
value = self.source.value
if value is None:
Source.__init__(self)
if poll > 0:
self.poll_timer = eTimer()
- self.poll_timer.timeout.get().append(self.changed)
+ self.poll_timer.timeout.get().append(self.poll)
self.poll_timer.start(poll)
def getBoolean(self):
return self.fixed
boolean = property(getBoolean)
+
+ def poll(self):
+ self.changed((self.CHANGED_ALL,))
def __init__(self):
Source.__init__(self)
self.clock_timer = eTimer()
- self.clock_timer.timeout.get().append(self.changed)
+ self.clock_timer.timeout.get().append(self.poll)
self.clock_timer.start(1000)
def getClock(self):
return time.time()
time = property(getClock)
+
+ def poll(self):
+ self.changed((self.CHANGED_POLL,))
from enigma import iPlayableService
from Source import Source
+from time import time
+
class CurrentService(PerServiceBase, Source):
def __init__(self, navcore):
Source.__init__(self)
self.navcore = navcore
def serviceEvent(self, event):
- self.changed(event)
+ self.changed((self.CHANGED_SPECIFIC, event))
def getCurrentService(self):
- return self.navcore.getCurrentService()
+ if self.cache is None:
+ self.cache = self.navcore.getCurrentService()
+ return self.cache
service = property(getCurrentService)
from enigma import iPlayableService
from Source import Source
+from time import time
+
class EventInfo(PerServiceBase, Source, object):
NOW = 0
NEXT = 1
Source.__init__(self)
PerServiceBase.__init__(self, navcore,
{
- iPlayableService.evStart: self.changed,
- iPlayableService.evUpdatedEventInfo: self.changed,
- iPlayableService.evEnd: self.changed
- })
+ iPlayableService.evStart: self.gotEvent,
+ iPlayableService.evUpdatedEventInfo: self.gotEvent,
+ iPlayableService.evEnd: self.gotEvent
+ }, with_event=True)
self.now_or_next = now_or_next
def getEvent(self):
- service = self.navcore.getCurrentService()
- info = service and service.info()
- return info and info.getEvent(self.now_or_next)
+ if self.cache is None:
+ service = self.navcore.getCurrentService()
+ info = service and service.info()
+ self.cache = (True, info and info.getEvent(self.now_or_next)) # we always store a tuple for negative caching
+
+ return self.cache[1]
event = property(getEvent)
+
+ def gotEvent(self, what):
+ if what in [iPlayableService.evStart, iPlayableService.evEnd]:
+ self.changed((self.CHANGED_CLEAR,))
+ else:
+ self.changed((self.CHANGED_ALL,))
iFrontendInformation.bitErrorRate,
iFrontendInformation.lockState] ]
- self.changed()
+ self.changed((self.CHANGED_ALL, ))
def getFrontendInfo(self):
if self.frontend_source:
def setList(self, list):
self.__list = list
- self.changed()
+ self.changed((self.CHANGED_ALL,))
list = property(lambda self: self.__list, setList)