ED/EDMarketConnector
1
0
Fork 0
mirror of https://github.com/EDCD/EDMarketConnector.git synced 2025-04-14 08:17:13 +03:00
Code Issues Projects Releases Wiki Activity

monitor.py: Detailed logging EDLogs.start()

Browse Source
This commit is contained in:
Athanasius 2020-10-14 11:53:31 +01:00
parent 4a84d9c341
commit 9be7f14573
1 changed files with 12 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
monitor.py
View File

@ -126,10 +126,13 @@ class EDLogs(FileSystemEventHandler): # type: ignore # See below
}
def start(self, root: 'tkinter.Tk'):
"""Start journal monitoring."""
logger.debug('Begin...')
self.root = root
journal_dir = config.get('journaldir') or config.default_journal_dir
if journal_dir is None:
logger.debug('journal_dir was None, setting ""')
journal_dir = ''
# TODO(A_D): this is ignored for type checking due to all the different types config.get returns
@ -168,26 +171,34 @@ class EDLogs(FileSystemEventHandler): # type: ignore # See below
# any non-standard logdir might be on a network drive and poll instead.
polling = bool(config.get('journaldir')) and platform != 'win32'
if not polling and not self.observer:
logger.debug('Not polling, no observer, starting an observer...')
self.observer = Observer()
self.observer.daemon = True
self.observer.start()
logger.debug('Done')
elif polling and self.observer:
logger.debug('Polling, but observer, so stopping observer...')
self.observer.stop()
self.observer = None
logger.debug('Done')
if not self.observed and not polling:
logger.debug('Not observed and not polling, setting observed...')
self.observed = self.observer.schedule(self, self.currentdir)
logger.debug('Done')
logger.info(f'{"Polling" if polling else "Monitoring"} Journal Folder: "{self.currentdir}"')
logger.info(f'Start Journal File: "{self.logfile}"')
if not self.running():
logger.debug('Starting Journal worker')
logger.debug('Starting Journal worker thread...')
self.thread = threading.Thread(target=self.worker, name='Journal worker')
self.thread.daemon = True
self.thread.start()
logger.debug('Done')
logger.debug('Done.')
return True
def stop(self):