Mercurial > templog
annotate py/tempserver.py @ 531:fd0fd9f947a1
improve exception handling
| author | Matt Johnston <matt@ucc.asn.au> |
|---|---|
| date | Sat, 11 Apr 2015 21:09:13 +0800 |
| parents | 73257bae83ea |
| children | 19569cb5ed46 |
| rev | line source |
|---|---|
| 447 | 1 #!/home/matt/templog/venv/bin/python |
| 439 | 2 |
| 3 import sys | |
| 4 import os | |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
5 import logging |
| 498 | 6 import time |
| 7 import signal | |
| 527 | 8 import asyncio |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
9 |
| 471 | 10 import lockfile.pidlockfile |
|
461
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
11 import daemon |
| 439 | 12 |
| 13 import utils | |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
14 from utils import L,D,EX,W |
| 444 | 15 import fridge |
| 16 import config | |
| 530 | 17 import sensor |
| 444 | 18 import params |
| 459 | 19 import uploader |
| 444 | 20 |
| 439 | 21 |
| 22 class Tempserver(object): | |
| 23 def __init__(self): | |
| 24 self.readings = [] | |
| 444 | 25 self.current = (None, None) |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
26 self.fridge = None |
| 531 | 27 self._wakeup = asyncio.Condition() |
| 439 | 28 |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
29 def __enter__(self): |
| 444 | 30 self.params = params.Params() |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
31 self.fridge = fridge.Fridge(self) |
| 459 | 32 self.uploader = uploader.Uploader(self) |
| 444 | 33 self.params.load() |
| 528 | 34 self.set_sensors(sensor.make_sensor(self)) |
| 527 | 35 asyncio.get_event_loop().add_signal_handler(signal.SIGHUP, self._reload_signal) |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
36 return self |
| 439 | 37 |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
38 def __exit__(self, exc_type, exc_value, traceback): |
|
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
39 L("Exiting, cleanup handler"); |
|
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
40 self.fridge.off() |
| 439 | 41 |
| 444 | 42 def run(self): |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
43 |
|
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
44 if self.fridge is None: |
|
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
45 raise Exception("Tempserver.run() must be within 'with Tempserver() as server'") |
|
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
46 |
|
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
47 # XXX do these go here or in __enter_() ? |
|
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
48 self.start_time = self.now() |
| 527 | 49 tasks = ( |
| 50 self.fridge.run(), | |
| 51 self.sensors.run(), | |
| 52 self.uploader.run(), | |
| 53 ) | |
| 531 | 54 |
| 527 | 55 loop = asyncio.get_event_loop() |
| 531 | 56 result_tasks = loop.run_until_complete(asyncio.wait(tasks, return_when=asyncio.FIRST_EXCEPTION)) |
| 57 # use the results so that exceptions get thrown | |
| 58 [t.result() for x in result_tasks for t in x] | |
| 444 | 59 |
| 60 def now(self): | |
| 61 return utils.monotonic_time() | |
| 62 | |
| 443 | 63 def set_sensors(self, sensors): |
| 447 | 64 if hasattr(self, 'sensors'): |
| 443 | 65 self.sensors.kill() |
| 66 self.sensors = sensors | |
| 67 self.wort_name = sensors.wort_name() | |
| 68 self.fridge_name = sensors.fridge_name() | |
| 439 | 69 |
| 70 def take_readings(self): | |
| 71 ret = self.readings | |
| 72 self.readings = [] | |
| 73 return ret | |
| 74 | |
| 75 def pushfront(self, readings): | |
| 76 """ used if a caller of take_readings() fails """ | |
| 459 | 77 self.readings = readings + self.readings |
| 439 | 78 |
| 443 | 79 # a reading is a map of {sensorname: value}. temperatures |
| 80 # are float degrees | |
| 439 | 81 def add_reading(self, reading): |
| 82 """ adds a reading at the current time """ | |
| 454 | 83 D("add_reading(%s)" % str(reading)) |
| 444 | 84 self.readings.append( (reading, self.now())) |
| 443 | 85 self.current = (reading.get(self.wort_name, None), |
| 86 reading.get(self.fridge_name, None)) | |
| 459 | 87 if len(self.readings) > config.MAX_READINGS: |
| 88 self.readings = self.readings[-config.MAX_READINGS:] | |
| 439 | 89 |
| 90 def current_temps(self): | |
| 443 | 91 """ returns (wort_temp, fridge_temp) tuple """ |
| 531 | 92 D("current: %s" % str(self.current)) |
| 447 | 93 return self.current |
| 444 | 94 |
| 531 | 95 @asyncio.coroutine |
|
518
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
514
diff
changeset
|
96 def sleep(self, timeout): |
|
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
514
diff
changeset
|
97 """ sleeps for timeout seconds, though wakes if the server's config is updated """ |
| 531 | 98 # XXX fixme - we should wake on _wakeup but asyncio Condition with wait_for is a bit broken? |
| 99 # https://groups.google.com/forum/#!topic/python-tulip/eSm7rZAe9LM | |
| 100 # For now we just sleep, ignore the _wakeup | |
| 101 yield from asyncio.sleep(timeout) | |
|
518
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
514
diff
changeset
|
102 |
| 531 | 103 @asyncio.coroutine |
|
518
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
514
diff
changeset
|
104 def _reload_signal(self): |
|
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
514
diff
changeset
|
105 try: |
|
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
514
diff
changeset
|
106 self.params.load() |
|
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
514
diff
changeset
|
107 L("Reloaded.") |
| 531 | 108 yield from self._wakeup.acquire() |
| 109 self._wakeup.notify_all() | |
| 110 self._wakeup.release() | |
| 528 | 111 except Error as e: |
|
518
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
514
diff
changeset
|
112 W("Problem reloading: %s" % str(e)) |
|
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
514
diff
changeset
|
113 |
| 444 | 114 def setup_logging(): |
| 115 logging.basicConfig(format='%(asctime)s %(message)s', | |
| 116 datefmt='%m/%d/%Y %I:%M:%S %p', | |
| 531 | 117 level=logging.DEBUG) |
| 118 logging.getLogger("asyncio").setLevel(logging.DEBUG) | |
| 444 | 119 |
|
461
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
120 def start(): |
|
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
121 with Tempserver() as server: |
|
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
122 server.run() |
|
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
123 |
| 444 | 124 def main(): |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
125 setup_logging() |
| 444 | 126 |
|
473
bd29ddb360a5
fix to absolute path for lockfile, --daemon does chdir("/")
Matt Johnston <matt@ucc.asn.au>
parents:
471
diff
changeset
|
127 heredir = os.path.abspath(os.path.dirname(__file__)) |
|
bd29ddb360a5
fix to absolute path for lockfile, --daemon does chdir("/")
Matt Johnston <matt@ucc.asn.au>
parents:
471
diff
changeset
|
128 pidpath = os.path.join(heredir, 'tempserver.pid') |
| 471 | 129 pidf = lockfile.pidlockfile.PIDLockFile(pidpath, threaded=False) |
| 499 | 130 do_hup = '--hup' in sys.argv |
| 471 | 131 try: |
| 514 | 132 pidf.acquire(1) |
| 471 | 133 pidf.release() |
| 528 | 134 except (lockfile.AlreadyLocked, lockfile.LockTimeout) as e: |
| 471 | 135 pid = pidf.read_pid() |
| 499 | 136 if do_hup: |
| 137 try: | |
| 138 os.kill(pid, signal.SIGHUP) | |
| 529 | 139 print("Sent SIGHUP to process %d" % pid, file=sys.stderr) |
| 499 | 140 sys.exit(0) |
| 141 except OSError: | |
| 529 | 142 print("Process %d isn't running?" % pid, file=sys.stderr) |
| 499 | 143 sys.exit(1) |
| 144 | |
| 529 | 145 print("Locked by PID %d" % pid, file=sys.stderr) |
| 499 | 146 |
| 498 | 147 stale = False |
| 471 | 148 if pid > 0: |
| 498 | 149 if '--new' in sys.argv: |
| 150 try: | |
| 151 os.kill(pid, 0) | |
| 152 except OSError: | |
| 153 stale = True | |
| 154 | |
| 155 if not stale: | |
| 529 | 156 print("Stopping old tempserver pid %d" % pid, file=sys.stderr) |
| 498 | 157 os.kill(pid, signal.SIGTERM) |
| 158 time.sleep(2) | |
| 159 pidf.acquire(0) | |
| 160 pidf.release() | |
| 161 else: | |
| 162 try: | |
| 163 os.kill(pid, 0) | |
| 164 # must still be running PID | |
| 165 raise e | |
| 166 except OSError: | |
| 167 stale = True | |
| 168 | |
| 169 if stale: | |
| 170 # isn't still running, steal the lock | |
| 529 | 171 print("Unlinking stale lockfile %s for pid %d" % (pidpath, pid), file=sys.stderr) |
| 498 | 172 pidf.break_lock() |
|
461
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
173 |
| 499 | 174 if do_hup: |
| 529 | 175 print("Doesn't seem to be running", file=sys.stderr) |
| 499 | 176 sys.exit(1) |
| 177 | |
| 444 | 178 if '--daemon' in sys.argv: |
|
461
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
179 logpath = os.path.join(os.path.dirname(__file__), 'tempserver.log') |
|
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
180 logf = open(logpath, 'a+') |
|
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
181 with daemon.DaemonContext(pidfile=pidf, stdout=logf, stderr = logf): |
|
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
182 start() |
|
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
183 else: |
|
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
184 with pidf: |
|
1eb68df9f8ab
Add daemon mode with locking, add "disabled" parameter
Matt Johnston <matt@ucc.asn.au>
parents:
459
diff
changeset
|
185 start() |
| 444 | 186 |
| 187 if __name__ == '__main__': | |
| 188 main() |