Mercurial > code > home > repos > homeauto

comparison service/arduinoNode/arduinoNode.py @ 1685:6b80a6c58907

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
minor changes to several services
author drewp@bigasterisk.com
date Mon, 27 Sep 2021 23:12:43 -0700
parents 686079900c20
children
comparison
equal deleted inserted replaced
1684:c41af73a410f 1685:6b80a6c58907
176 176
177 def _pollWork(self): 177 def _pollWork(self):
178 t1 = time.time() 178 t1 = time.time()
179 self.ser.write("\x60\x00") # "poll everything" 179 self.ser.write("\x60\x00") # "poll everything"
180 for i in self._polledDevs: 180 for i in self._polledDevs:
181 with i._stats.poll.time(): 181 with i.stats.poll.time():
182 try: 182 try:
183 now = time.time() 183 now = time.time()
184 new = i.readFromPoll(self.ser.read) 184 new = i.readFromPoll(self.ser.read)
185 if isinstance(new, dict): # new style 185 if isinstance(new, dict): # new style
186 oneshot = new['oneshot'] 186 oneshot = new['oneshot']
248 if stmt[:2] == pat[:2]: 248 if stmt[:2] == pat[:2]:
249 stmtsForDev.append(stmt) 249 stmtsForDev.append(stmt)
250 unused.discard(stmt) 250 unused.discard(stmt)
251 if stmtsForDev: 251 if stmtsForDev:
252 log.info("output goes to action handler for %s" % dev.uri) 252 log.info("output goes to action handler for %s" % dev.uri)
253 with dev._stats.output.time(): 253 with dev.stats.output.time():
254 self.ser.write("\x60" + chr(self._devCommandNum[dev.uri])) 254 self.ser.write("\x60" + chr(self._devCommandNum[dev.uri]))
255 dev.sendOutput(stmtsForDev, self.ser.write, self.ser.read) 255 dev.sendOutput(stmtsForDev, self.ser.write, self.ser.read)
256 if self.ser.read(1) != 'k': 256 if self.ser.read(1) != 'k':
257 raise ValueError( 257 raise ValueError(
258 "%s sendOutput/generateActionCode didn't use " 258 "%s sendOutput/generateActionCode didn't use "