debug for broken pipe
This commit is contained in:
parent
dbe11390f8
commit
4a5a549cb3
@ -27,7 +27,7 @@ from ..folder import GetSourceFromFolder, MediaStore, MediaWatcher
|
|||||||
from ..playlist import GetSourceFromPlaylist
|
from ..playlist import GetSourceFromPlaylist
|
||||||
from ..utils import (ff_proc, ffmpeg_stderr_reader, log, lower_third,
|
from ..utils import (ff_proc, ffmpeg_stderr_reader, log, lower_third,
|
||||||
messenger, playlist, pre, pre_audio_codec, stdin_args,
|
messenger, playlist, pre, pre_audio_codec, stdin_args,
|
||||||
terminate_processes)
|
sync_op, terminate_processes)
|
||||||
|
|
||||||
COPY_BUFSIZE = 1024 * 1024 if system() == 'Windows' else 65424
|
COPY_BUFSIZE = 1024 * 1024 if system() == 'Windows' else 65424
|
||||||
|
|
||||||
@ -111,8 +111,13 @@ def output():
|
|||||||
break
|
break
|
||||||
ff_proc.encoder.stdin.write(buf)
|
ff_proc.encoder.stdin.write(buf)
|
||||||
|
|
||||||
except BrokenPipeError:
|
except BrokenPipeError as err:
|
||||||
messenger.error('Broken Pipe!')
|
messenger.debug(79 * '-')
|
||||||
|
messenger.debug(f'error: "{err}"')
|
||||||
|
messenger.debug(f'delta: "{sync_op.time_delta}"')
|
||||||
|
messenger.debug(f'node: "{node}"')
|
||||||
|
messenger.debug(f'dec_cmd: "{dec_cmd}"')
|
||||||
|
messenger.debug(79 * '-')
|
||||||
terminate_processes(watcher)
|
terminate_processes(watcher)
|
||||||
|
|
||||||
except SystemExit:
|
except SystemExit:
|
||||||
|
@ -118,7 +118,6 @@ def output():
|
|||||||
ff_proc.encoder.stdin.write(buf)
|
ff_proc.encoder.stdin.write(buf)
|
||||||
|
|
||||||
except BrokenPipeError as err:
|
except BrokenPipeError as err:
|
||||||
messenger.error('Broken Pipe!')
|
|
||||||
messenger.debug(79 * '-')
|
messenger.debug(79 * '-')
|
||||||
messenger.debug(f'error: "{err}"')
|
messenger.debug(f'error: "{err}"')
|
||||||
messenger.debug(f'delta: "{sync_op.time_delta}"')
|
messenger.debug(f'delta: "{sync_op.time_delta}"')
|
||||||
|
Loading…
Reference in New Issue
Block a user