2 # Repository abstraction for queuing |
2 # Repository abstraction for queuing |
3 # |
3 # |
4 |
4 |
5 import weakref |
5 import weakref |
6 import keyring |
6 import keyring |
7 import borgend |
7 import loggers |
8 import config |
8 import config |
9 from scheduler import QueueThread, QueuedEvent |
9 from scheduler import QueueThread, QueuedEvent |
10 |
10 |
11 logger=borgend.logger.getChild(__name__) |
11 logger=loggers.get(__name__) |
12 |
12 |
13 class FIFOEvent(QueuedEvent): |
13 class FIFOEvent(QueuedEvent): |
14 def __init__(self, cond, name=None): |
14 def __init__(self, cond, name=None): |
15 self._goodtogo=False |
15 self._goodtogo=False |
16 super().__init__(cond, name=name) |
16 super().__init__(cond, name=name) |