Mercurial > templog
annotate py/sensor_ds18b20.py @ 518:0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
from the web UI. makes it seem more magical.
| author | Matt Johnston <matt@ucc.asn.au> |
|---|---|
| date | Fri, 19 Dec 2014 21:52:50 +0800 |
| parents | d05b1612e19e |
| children | d9e81a563923 |
| rev | line source |
|---|---|
| 439 | 1 #!/usr/bin/env python2.7 |
| 2 | |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
3 import os |
|
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
4 import re |
|
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
5 |
| 443 | 6 import gevent |
| 447 | 7 import gevent.threadpool |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
8 |
| 443 | 9 import config |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
10 from utils import D,L,W,E,EX |
| 443 | 11 |
| 12 class DS18B20s(gevent.Greenlet): | |
| 13 | |
| 14 THERM_RE = re.compile('.* YES\n.*t=(.*)\n', re.MULTILINE) | |
| 439 | 15 |
| 443 | 16 def __init__(self, server): |
| 17 gevent.Greenlet.__init__(self) | |
| 18 self.server = server | |
| 447 | 19 self.readthread = gevent.threadpool.ThreadPool(1) |
| 20 self.master_dir = config.SENSOR_BASE_DIR | |
| 443 | 21 |
|
449
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
22 def do(self): |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
23 vals = {} |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
24 for n in self.sensor_names(): |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
25 value = self.do_sensor(n) |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
26 if value is not None: |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
27 vals[n] = value |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
28 |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
29 itemp = self.do_internal() |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
30 if itemp: |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
31 vals['internal'] = itemp |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
32 |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
33 self.server.add_reading(vals) |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
34 |
| 443 | 35 def _run(self): |
| 36 while True: | |
| 37 self.do() | |
|
518
0b5ff341d124
sleep on a semaphore so it can start/stop immediately when there's a SIGHUP
Matt Johnston <matt@ucc.asn.au>
parents:
477
diff
changeset
|
38 self.server.sleep(config.SENSOR_SLEEP) |
| 443 | 39 |
| 447 | 40 def read_wait(self, f): |
| 41 # handles a blocking file read with a gevent threadpool. A | |
| 42 # real python thread performs the read while other gevent | |
| 43 # greenlets keep running. | |
| 44 # the ds18b20 takes ~750ms to read, which is noticable | |
| 45 # interactively. | |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
46 return self.readthread.apply(f.read) |
| 439 | 47 |
| 447 | 48 def do_sensor(self, s, contents = None): |
| 49 """ contents can be set by the caller for testing """ | |
| 443 | 50 try: |
| 51 if contents is None: | |
| 447 | 52 fn = os.path.join(self.master_dir, s, 'w1_slave') |
| 443 | 53 f = open(fn, 'r') |
| 447 | 54 contents = self.read_wait(f) |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
55 |
| 443 | 56 match = self.THERM_RE.match(contents) |
| 57 if match is None: | |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
58 D("no match") |
| 443 | 59 return None |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
60 temp = int(match.groups(1)[0]) / 1000.0 |
| 474 | 61 if temp > 80: |
| 62 E("Problem reading sensor '%s': %f" % (s, temp)) | |
| 63 return None | |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
64 return temp |
| 443 | 65 except Exception, e: |
| 66 EX("Problem reading sensor '%s': %s" % (s, str(e))) | |
| 67 return None | |
| 439 | 68 |
|
449
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
69 def do_internal(self): |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
70 try: |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
71 return int(open(config.INTERNAL_TEMPERATURE, 'r').read()) / 1000.0 |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
72 except Exception, e: |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
73 EX("Problem reading internal sensor: %s" % str(e)) |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
74 return None |
|
e99559bf188f
internal temperature sensor
Matt Johnston <matt@ucc.asn.au>
parents:
448
diff
changeset
|
75 |
| 443 | 76 |
| 77 def sensor_names(self): | |
| 78 """ Returns a sequence of sensorname """ | |
| 447 | 79 slaves_path = os.path.join(self.master_dir, "w1_master_slaves") |
| 477 | 80 contents = open(slaves_path, 'r').read() |
| 81 if 'not found' in contents: | |
| 82 E("No W1 sensors found") | |
| 83 return [] | |
| 84 names = contents.split() | |
|
448
fe729664a5e6
working better. logging works properly, cleanup fridge.off() happens.
Matt Johnston <matt@ucc.asn.au>
parents:
447
diff
changeset
|
85 return names |
| 439 | 86 |
| 87 def wort_name(self): | |
| 443 | 88 return config.WORT_NAME |
| 439 | 89 |
| 90 def fridge_name(self): | |
| 443 | 91 return config.FRIDGE_NAME |