Mercurial > code > home > repos > homeauto
diff lib/patchsource.py @ 1232:b50a13ef20ba
exportStats for sending scales data to influxdb
Ignore-this: 715ff40fed97559efa37edf0efa58220
darcs-hash:bcdd9713c4bf9c2ebe732ae1d30edc44f1be704f
| author | drewp <drewp@bigasterisk.com> |
|---|---|
| date | Sun, 07 Apr 2019 03:56:17 -0700 |
| parents | ee168d55524a |
| children | 24c004aac998 |
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)