github/supysonic
1
0
Fork 0
mirror of https://github.com/spl0k/supysonic.git synced 2024-12-22 17:06:17 +00:00
Code Issues Releases Wiki Activity

Added a config variable to define if the watcher should be started

Browse Source
This commit is contained in:
spl0k 2019-04-13 17:14:03 +02:00
parent 55e9db61d8
commit 3924ada03e
4 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
config.sample
View File

@ -35,6 +35,9 @@ log_level = WARNING
; Default: /tmp/supysonic/supysonic.sock ; Default: /tmp/supysonic/supysonic.sock
socket = /var/run/supysonic.sock socket = /var/run/supysonic.sock
; Defines if the file watcher should be started. Default: yes
run_watcher = yes
; Delay before triggering scanning operation after a change have been detected ; Delay before triggering scanning operation after a change have been detected
; This prevents running too many scans when multiple changes are detected for a ; This prevents running too many scans when multiple changes are detected for a
; single file over a short time span. Default: 5 ; single file over a short time span. Default: 5

6
docs/configuration.md
View File

@ -132,6 +132,9 @@ between the daemon and clients that rely on it (eg. CLI, folder admin web page,
etc.). Note that using an IP address here isn't supported. etc.). Note that using an IP address here isn't supported.
Default: /tmp/supysonic/supysonic.sock Default: /tmp/supysonic/supysonic.sock
`run_watcher`: whether or not to start the watcher that will listen for library
changes. Default: yes
`wait_delay`: delay before triggering the scanning operation after a change `wait_delay`: delay before triggering the scanning operation after a change
have been detected. This prevents running too many scans when multiple changes have been detected. This prevents running too many scans when multiple changes
are detected for a single file over a short time span. Default: 5 seconds. are detected for a single file over a short time span. Default: 5 seconds.
@ -149,6 +152,9 @@ If left empty, any logging will be sent to stderr.
; Default: /tmp/supysonic/supysonic.sock ; Default: /tmp/supysonic/supysonic.sock
socket = /var/run/supysonic.sock socket = /var/run/supysonic.sock
; Defines if the file watcher should be started. Default: yes
run_watcher = yes
; Delay before triggering scanning operation after a change have been detected ; Delay before triggering scanning operation after a change have been detected
; This prevents running too many scans when multiple changes are detected for a ; This prevents running too many scans when multiple changes are detected for a
; single file over a short time span. Default: 5 ; single file over a short time span. Default: 5

1
supysonic/config.py
View File

@ -40,6 +40,7 @@ class DefaultConfig(object):
} }
DAEMON = { DAEMON = {
'socket': os.path.join(tempdir, 'supysonic.sock'), 'socket': os.path.join(tempdir, 'supysonic.sock'),
'run_watcher': True,
'wait_delay': 5, 'wait_delay': 5,
'log_file': None, 'log_file': None,
'log_level': 'WARNING' 'log_level': 'WARNING'

8
supysonic/daemon.py
View File

@ -62,7 +62,8 @@ class Daemon(object):
def __handle_connection(self, connection): def __handle_connection(self, connection):
try: try:
module, cmd, args = connection.recv() module, cmd, args = connection.recv()
if module == WATCHER: logger.debug('Received %s %s %s', module, cmd, args)
if module == WATCHER and self.__watcher is not None:
if cmd == W_ADD: if cmd == W_ADD:
self.__watcher.add_folder(*args) self.__watcher.add_folder(*args)
elif cmd == W_DEL: elif cmd == W_DEL:
@ -74,8 +75,9 @@ class Daemon(object):
self.__listener = Listener(address = self.__address, authkey = get_secret_key('daemon_key')) self.__listener = Listener(address = self.__address, authkey = get_secret_key('daemon_key'))
logger.info("Listening to %s", self.__listener.address) logger.info("Listening to %s", self.__listener.address)
self.__watcher = SupysonicWatcher(config) if config.DAEMON['run_watcher']:
self.__watcher.start() self.__watcher = SupysonicWatcher(config)
self.__watcher.start()
while True: while True:
conn = self.__listener.accept() conn = self.__listener.accept()