|
|
@@ -809,13 +809,13 @@ class Storage: |
|
|
|
while True: |
|
|
|
await asyncio.wait({asyncio.create_task(flushExitEvent.wait())}, timeout = self.config['storage']['flushTime']) |
|
|
|
self.logger.debug('Flushing files') |
|
|
|
flushedFiles = [] |
|
|
|
for channel, (fn, f, fLastWriteTime) in self.files.items(): |
|
|
|
if fLastWriteTime > lastFlushTime: |
|
|
|
self.logger.debug(f'Flushing {channel} {fn}') |
|
|
|
flushedFiles.append(f'{channel} {fn}') |
|
|
|
f.flush() |
|
|
|
else: |
|
|
|
self.logger.debug(f'Flushing {channel} {fn} unnecessary') |
|
|
|
self.logger.debug('Flushing done') |
|
|
|
if flushedFiles: |
|
|
|
self.logger.debug(f'Flushed: {", ".join(flushedFiles)}') |
|
|
|
if flushExitEvent.is_set(): |
|
|
|
break |
|
|
|
lastFlushTime = time.time() |
|
|
|