Threading target which handles all updates for a given wait interval
(cls, interval, backends, timeout)
| 784 | |
| 785 | @classmethod |
| 786 | def update(cls, interval, backends, timeout): |
| 787 | """ |
| 788 | Threading target which handles all updates for a given wait interval |
| 789 | """ |
| 790 | start = time.time() |
| 791 | condition = threading.Condition() |
| 792 | while time.time() - start < timeout: |
| 793 | log.debug( |
| 794 | "Performing fileserver updates for items with an update interval of %d", |
| 795 | interval, |
| 796 | ) |
| 797 | cls._do_update(backends) |
| 798 | log.debug( |
| 799 | "Completed fileserver updates for items with an update " |
| 800 | "interval of %d, waiting %d seconds", |
| 801 | interval, |
| 802 | interval, |
| 803 | ) |
| 804 | with condition: |
| 805 | condition.wait(interval) |
| 806 | |
| 807 | def run(self): |
| 808 | """ |
no test coverage detected