(page, triggered) = page_chooser.choose_next_page()
if triggered:
- print(('chooser[%s] - WE ARE TRIGGERED.' % utils.timestamp()))
+ print('chooser[%s] - WE ARE TRIGGERED.' % utils.timestamp())
if page != last_page:
- print(('chooser[%s] - EMERGENCY PAGE %s LOAD NEEDED' % (
- utils.timestamp(), page)))
- f = open(os.path.join(constants.pages_dir,
- "current.shtml"), "w")
- emit_wrapped(f, page)
- f.close()
+ print('chooser[%s] - EMERGENCY PAGE %s LOAD NEEDED' % (
+ utils.timestamp(), page))
+ try:
+ f = open(os.path.join(constants.pages_dir,
+ 'current.shtml'), 'w')
+ emit_wrapped(f, page)
+ f.close()
+ except:
+ print('chooser[%s] - page does not exist?!' % (
+ utils.timestamp()))
+ continue
+ last_page = page
+ swap_page_target = now + constants.refresh_period_sec
- # Notify XMLHTTP clients that they need to refresh now.
+ # Also notify XMLHTTP clients that they need to refresh now.
path = os.path.join(constants.pages_dir,
- "reload_immediately.html")
+ 'reload_immediately.html')
f = open(path, 'w')
- f.write("Reload, suckers!")
+ f.write('Reload, suckers!')
f.close()
+
+ # Fix this hack... maybe read the webserver logs and see if it
+ # actually was picked up?
time.sleep(0.750)
os.remove(path)
- last_page = page
- swap_page_target = now + constants.refresh_period_sec
elif now >= swap_page_target:
if (page == last_page):
print(('chooser[%s] - nominal choice got the same page...' % (
utils.timestamp())))
continue
- print(('chooser[%s] - nominal choice of %s' % (utils.timestamp(), page)))
+ print('chooser[%s] - nominal choice of %s' % (utils.timestamp(), page))
try:
f = open(os.path.join(constants.pages_dir,
- "current.shtml"), "w")
+ 'current.shtml'), 'w')
emit_wrapped(f, page)
f.close()
- last_page = page
- swap_page_target = now + constants.refresh_period_sec
except:
- print(('chooser[%s] - page does not exist?!' % (utils.timestamp())))
+ print('chooser[%s] - page does not exist?!' % (utils.timestamp()))
continue
- time.sleep(1.0)
+ last_page = page
+ swap_page_target = now + constants.refresh_period_sec
+ time.sleep(1)
def pick_background_color():
now = datetime.now()
def thread_invoke_renderers():
while True:
- print("Renderer thread[%s]: invoking all renderers in catalog..." % (
+ print("renderer[%s]: invoking all renderers in catalog..." % (
utils.timestamp()))
for r in renderer_catalog.get_renderers():
+ now = time.time()
+ print("renderer[%s]: Rendering %s" % (utils.timestamp(), r.get_name()))
try:
r.render()
except Exception as e:
traceback.print_exc()
- print(("renderer[%s] unknown exception, swallowing it." % (
- utils.timestamp())))
+ print("renderer[%s] unknown exception in %s, swallowing it." % (
+ utils.timestamp(), r.get_name()))
except Error as e:
traceback.print_exc()
- print(("renderer[%s] unknown error, swallowing it." % (
- utils.timestamp())))
+ print("renderer[%s] unknown error in %s, swallowing it." % (
+ utils.timestamp(), r.get_name()))
+ delta = time.time() - now
+ print("renderer[%s]: Back from %s, that took %5.2fs." % (
+ utils.timestamp(), r.get_name(), delta))
+ print("renderer[%s]: thread having a little break for %ds..." % (
+ utils.timestamp(), constants.render_period_sec))
time.sleep(constants.render_period_sec)
if __name__ == "__main__":
while True:
if (changer_thread == None or
not changer_thread.is_alive()):
- print(("chooser[%s] - (Re?)initializing chooser thread..." % utils.timestamp()))
+ print("MAIN[%s] - (Re?)initializing chooser thread..." % (
+ utils.timestamp()))
changer_thread = Thread(target = thread_change_current, args=())
changer_thread.start()
if (renderer_thread == None or
not renderer_thread.is_alive()):
- print(("renderer[%s] - (Re?)initializing render thread..." % utils.timestamp()))
+ print("MAIN[%s] - (Re?)initializing render thread..." % (
+ utils.timestamp()))
renderer_thread = Thread(target = thread_invoke_renderers, args=())
renderer_thread.start()
- time.sleep(10000)
+ time.sleep(60)
print("Should never get here.")