equal
deleted
inserted
replaced
100 |
100 |
101 def cancel(self): |
101 def cancel(self): |
102 with self.lock: |
102 with self.lock: |
103 self._stop() |
103 self._stop() |
104 |
104 |
105 def feed(self): |
105 def feed(self, rearm=True): |
106 with self.lock: |
106 with self.lock: |
107 self._stop() |
107 self._stop() |
108 self._start(rearm=True) |
108 self._start(rearm) |
109 |
109 |
110 def trigger(self): |
110 def trigger(self): |
111 self._callback() |
111 self._callback() |
112 self.feed() |
112 # wait for initial timeout on re-start |
|
113 self.feed(rearm=False) |
113 |
114 |
114 class HMIProtocol(WebSocketServerProtocol): |
115 class HMIProtocol(WebSocketServerProtocol): |
115 |
116 |
116 def __init__(self, *args, **kwargs): |
117 def __init__(self, *args, **kwargs): |
117 self._hmi_session = None |
118 self._hmi_session = None |