Mercurial > templog
view server/ts.py @ 426:b3b85cd4f09b
fridge-too-hot mode
author | Matt Johnston <matt@ucc.asn.au> |
---|---|
date | Thu, 11 Oct 2012 19:19:35 +0800 |
parents | 1603d0310dd0 |
children | de950be796dd |
line wrap: on
line source
#!/usr/bin/env python2.7 # time that the bluetooth takes to get going? EXTRA_WAKEUP = -3 FETCH_TRIES = 3 # avoid turning off the bluetooth etc. TESTING = False import sys # for wrt sys.path.append('/root/python') import httplib import time import traceback import binascii import hmac import zlib import urllib import urllib2 import logging L = logging.info W = logging.warning E = logging.error import config from utils import monotonic_time, retry, readline, crc16 import utils import bluetooth def get_socket(addr): s = bluetooth.BluetoothSocket( bluetooth.RFCOMM ) L("connecting") s.connect((addr, 1)) s.setblocking(False) s.settimeout(1) return s def flush(sock): while readline(sock): pass @retry() def fetch(sock): flush(sock) sock.send("fetch\n") crc = 0 lines = [] l = readline(sock) if l != 'START\n': W("Bad expected START line '%s'\n" % str(l).rstrip('\n')) return None crc = crc16(l, crc) while True: l = readline(sock) crc = crc16(l, crc) if l == 'END\n': break lines.append(l.rstrip('\n')) for d in lines: L("Received: %s" % d) l = readline(sock) recv_crc = None try: k, v = l.rstrip('\n').split('=') if k == 'CRC': recv_crc = int(v) if recv_crc < 0 or recv_crc > 0xffff: recv_crc = None except ValueError: pass if recv_crc is None: W("Bad expected CRC line '%s'\n" % l.rstrip('\n')) return None if recv_crc != crc: W("Bad CRC: calculated 0x%x vs received 0x%x\n" % (crc, recv_crc)) return None return lines @retry() def turn_off(sock): if TESTING: return 99 L("Sending btoff") flush(sock) sock.send("btoff\n"); # read newline l = readline(sock) if not l: W("Bad response to btoff") return None if not l.startswith('next_wake'): W("Bad response to btoff '%s'" % l) return None L("Next wake line %s" % l) toks = dict(v.split('=') for v in l.split(',')) rem = int(toks['rem']) tick_secs = int(toks['tick_secs']) tick_wake = int(toks['tick_wake']) + 1 next_wake = int(toks['next_wake']) rem_secs = float(rem) / tick_wake * tick_secs next_wake_secs = next_wake - rem_secs L("next_wake_secs %f\n", next_wake_secs) return next_wake_secs @retry() def clear_meas(sock): flush(sock) sock.send("clear\n"); l = readline(sock) if l and l.rstrip() == 'cleared': return True E("Bad response to clear '%s'" % str(l)) return False def send_results(lines): enc_lines = binascii.b2a_base64(zlib.compress('\n'.join(lines))) mac = hmac.new(config.HMAC_KEY, enc_lines).hexdigest() url_data = urllib.urlencode( {'lines': enc_lines, 'hmac': mac} ) con = urllib2.urlopen(config.UPDATE_URL, url_data) result = con.read(100) if result == 'OK': return True else: W("Bad result '%s'" % result) return False def do_comms(sock): L("do_comms") d = None # serial could be unreliable, try a few times d = fetch(sock) if not d: return res = send_results(d) if not res: return clear_meas(sock) next_wake = 600 #next_wake = turn_off(sock) sock.close() return next_wake testcount = 0 def sleep_for(secs): until = monotonic_time() + secs while True: length = until - monotonic_time() if length <= 0: return time.sleep(length) def setup_logging(): logging.basicConfig(format='%(asctime)s %(message)s', datefmt='%m/%d/%Y %I:%M:%S %p', level=logging.INFO) def main(): setup_logging() L("Running templog rfcomm server") if '--daemon' in sys.argv: utils.cheap_daemon() next_wake_time = 0 while True: sock = None try: sock = get_socket(config.BTADDR) except Exception, e: #logging.exception("Error connecting") pass if sock: try: avr_wake = do_comms(sock) next_wake_time = time.time() + avr_wake except Exception, e: logging.exception("Error in do_comms") next_wake_interval = next_wake_time - time.time() + EXTRA_WAKEUP sleep_time = config.SLEEP_TIME if next_wake_interval > 0: sleep_time = min(next_wake_interval, sleep_time) if next_wake_interval < 0 and next_wake_interval > -30: L("not sleeping, next_wake_interval overdue %f" % next_wake_interval) continue L("Sleeping for %d, next wake interval %f" % (sleep_time, next_wake_interval)) sleep_for(sleep_time) if __name__ == '__main__': main()