Open/close pool at begin/end of import session

This commit is contained in:
ybnd 2020-01-30 09:34:37 +01:00
parent 388d2d2c0d
commit 79c5535cf6

View file

@ -1204,6 +1204,8 @@ class ReplayGainPlugin(BeetsPlugin):
# On-import analysis.
if self.config['auto']:
self.register_listener('import_begin', self.import_begin)
self.register_listener('import', self.import_end)
self.import_stages = [self.imported]
# Formats to use R128.
@ -1442,6 +1444,16 @@ class ReplayGainPlugin(BeetsPlugin):
self.pool.close()
self.pool.join()
def import_begin(self, session):
"""Handle `import_begin` event -> open pool
"""
self.open_pool(self.config['threads'].get(int))
def import_end(self, paths):
"""Handle `import` event -> close pool
"""
self.close_pool()
def imported(self, session, task):
"""Add replay gain info to items or albums of ``task``.
"""