|
|
@ -113,7 +113,7 @@ class TestUpdated(unittest.TestCase): |
|
|
|
|
|
|
|
|
|
|
|
def _wait_for_update(self, timeout=30, clear_param=False): |
|
|
|
def _wait_for_update(self, timeout=30, clear_param=False): |
|
|
|
if clear_param: |
|
|
|
if clear_param: |
|
|
|
self.params.delete("LastUpdateTime") |
|
|
|
self.params.remove("LastUpdateTime") |
|
|
|
|
|
|
|
|
|
|
|
self._update_now() |
|
|
|
self._update_now() |
|
|
|
t = self._read_param("LastUpdateTime", timeout=timeout) |
|
|
|
t = self._read_param("LastUpdateTime", timeout=timeout) |
|
|
@ -166,7 +166,7 @@ class TestUpdated(unittest.TestCase): |
|
|
|
last_update_time = datetime.datetime.fromisoformat(t) |
|
|
|
last_update_time = datetime.datetime.fromisoformat(t) |
|
|
|
td = datetime.datetime.utcnow() - last_update_time |
|
|
|
td = datetime.datetime.utcnow() - last_update_time |
|
|
|
self.assertLess(td.total_seconds(), 10) |
|
|
|
self.assertLess(td.total_seconds(), 10) |
|
|
|
self.params.delete("LastUpdateTime") |
|
|
|
self.params.remove("LastUpdateTime") |
|
|
|
|
|
|
|
|
|
|
|
# wait a bit for the rest of the params to be written |
|
|
|
# wait a bit for the rest of the params to be written |
|
|
|
time.sleep(0.1) |
|
|
|
time.sleep(0.1) |
|
|
@ -232,7 +232,7 @@ class TestUpdated(unittest.TestCase): |
|
|
|
|
|
|
|
|
|
|
|
# run for a cycle with no update |
|
|
|
# run for a cycle with no update |
|
|
|
self._wait_for_update(clear_param=True) |
|
|
|
self._wait_for_update(clear_param=True) |
|
|
|
self.params.delete("LastUpdateTime") |
|
|
|
self.params.remove("LastUpdateTime") |
|
|
|
first_mtime = os.path.getmtime(overlay_init_fn) |
|
|
|
first_mtime = os.path.getmtime(overlay_init_fn) |
|
|
|
|
|
|
|
|
|
|
|
# touch a file in the basedir |
|
|
|
# touch a file in the basedir |
|
|
|