Cutlery/calibre
1
0
Fork 0
mirror of https://github.com/kovidgoyal/calibre.git synced 2025-07-09 03:04:10 -04:00
Code Issues Packages Projects Releases Wiki Activity

Allow interleaved waits in develop_loop

Browse Source
This commit is contained in:
Kovid Goyal 2023-01-28 13:39:08 +05:30
parent 46731246c6
commit 32155c172c
No known key found for this signature in database
GPG Key ID: 06BC317B515ACE7C
1 changed files with 17 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/calibre/utils/windows/winspeech.py
View File

@ -62,7 +62,7 @@ def encode_to_file_object(text, output) -> int:
return sz return sz
def develop_loop(wait_for, *commands): def develop_loop(*commands):
p = start_worker() p = start_worker()
q = Queue() q = Queue()
@ -84,18 +84,20 @@ def develop_loop(wait_for, *commands):
send('1 echo Synthesizer started') send('1 echo Synthesizer started')
send('1 volume 0.1') send('1 volume 0.1')
for command in commands: for command in commands:
send(command) if isinstance(command, str):
while True: send(command)
m = q.get() else:
if m['related_to'] != wait_for: while True:
continue m = q.get()
if m['payload_type'] == 'media_state_changed' and m['state'] == 'ended': if m['related_to'] != command:
break continue
if m['payload_type'] == 'saved': if m['payload_type'] == 'media_state_changed' and m['state'] == 'ended':
break break
if m['payload_type'] == 'error': if m['payload_type'] == 'saved':
exit_code = 1 break
break if m['payload_type'] == 'error':
exit_code = 1
break
send(f'333 echo Synthesizer exiting with exit code: {exit_code}') send(f'333 echo Synthesizer exiting with exit code: {exit_code}')
send(f'334 exit {exit_code}') send(f'334 exit {exit_code}')
ec = p.wait(1) ec = p.wait(1)
@ -122,7 +124,7 @@ def develop_speech(text='Lucca Brazzi sleeps with the fishes.', mark_words=True)
with SharedMemory(size=max_buffer_size(text)) as shm: with SharedMemory(size=max_buffer_size(text)) as shm:
sz = encode_to_file_object(text, shm) sz = encode_to_file_object(text, shm)
develop_loop(2, f'2 speak {st} shm {sz} {shm.name}') develop_loop(f'2 speak {st} shm {sz} {shm.name}', 2)
def develop_save(text='Lucca Brazzi sleeps with the fishes.', filename="speech.wav"): def develop_save(text='Lucca Brazzi sleeps with the fishes.', filename="speech.wav"):
@ -130,4 +132,4 @@ def develop_save(text='Lucca Brazzi sleeps with the fishes.', filename="speech.w
st = 'ssml' if '<speak' in text else 'text' st = 'ssml' if '<speak' in text else 'text'
with SharedMemory(size=max_buffer_size(text)) as shm: with SharedMemory(size=max_buffer_size(text)) as shm:
sz = encode_to_file_object(text, shm) sz = encode_to_file_object(text, shm)
develop_loop(2, f'2 save {st} {sz} {shm.name} {filename}') develop_loop(f'2 save {st} {sz} {shm.name} {filename}', 2)