Mercurial > code > home > repos > homeauto
diff lib/patchsource.py @ 429:fcd2c026f51e
exportStats for sending scales data to influxdb
Ignore-this: 715ff40fed97559efa37edf0efa58220
| author | drewp@bigasterisk.com |
|---|---|
| date | Sun, 07 Apr 2019 03:56:17 -0700 |
| parents | 7716b1810d6c |
| children | 124c921ad52d |
line wrap: on
line diff
--- a/lib/patchsource.py Thu Apr 04 02:22:04 2019 -0700 +++ b/lib/patchsource.py Sun Apr 07 03:56:17 2019 -0700 @@ -109,10 +109,11 @@ todo: generate connection stmts in here """ - def __init__(self, url, listener): + def __init__(self, url, listener, reconnectSecs=60): self.url = url self._stopped = False self._listener = listener + self.reconnectSecs = reconnectSecs self._reconnect() def _reconnect(self): @@ -136,8 +137,8 @@ self._ps.stop() def _onConnectionFailed(self, arg): - reactor.callLater(60, self._reconnect) + reactor.callLater(self.reconnectSecs, self._reconnect) def _onConnectionLost(self, arg): - reactor.callLater(60, self._reconnect) + reactor.callLater(self.reconnectSecs, self._reconnect)