speech_recognition/FunASR
1
0
Fork 0
mirror of https://github.com/modelscope/FunASR synced 2025-09-15 14:48:36 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix NoneType bug for ws_client.py microphone mode

Browse Source
This commit is contained in:
zhaomingwork 2023-05-12 23:30:05 +00:00
parent 99387140ba
commit 3dcaa9df2f
1 changed files with 35 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
funasr/runtime/python/websocket/ws_client.py
View File

@ -237,48 +237,42 @@ def one_thread(id,chunk_begin,chunk_size):
if __name__ == '__main__':
process_list = []
for i in range(args.test_thread_num):
p = Process(target=one_thread,args=(i, 0, 0))
p.start()
process_list.append(p)
# for microphone
if args.audio_in is None:
p = Process(target=one_thread,args=(0, 0, 0))
p.start()
p.join()
print('end')
else:
# calculate the number of wavs for each preocess
if args.audio_in.endswith(".scp"):
f_scp = open(args.audio_in)
wavs = f_scp.readlines()
else:
wavs = [args.audio_in]
total_len=len(wavs)
if total_len>=args.test_thread_num:
chunk_size=int((total_len)/args.test_thread_num)
remain_wavs=total_len-chunk_size*args.test_thread_num
else:
chunk_size=0
for i in process_list:
p.join()
process_list = []
chunk_begin=0
for i in range(args.test_thread_num):
now_chunk_size= chunk_size
if remain_wavs>0:
now_chunk_size=chunk_size+1
remain_wavs=remain_wavs-1
# process i handle wavs at chunk_begin and size of now_chunk_size
p = Process(target=one_thread,args=(i,chunk_begin,now_chunk_size))
chunk_begin=chunk_begin+now_chunk_size
p.start()
process_list.append(p)
print('end')
for i in process_list:
p.join()
print('end')
#
# if __name__ == '__main__':
# # calculate the number of wavs for each preocess
# if args.audio_in.endswith(".scp"):
# f_scp = open(args.audio_in)
# wavs = f_scp.readlines()
# else:
# wavs = [args.audio_in]
# total_len=len(wavs)
# if total_len>=args.test_thread_num:
# chunk_size=int((total_len)/args.test_thread_num)
# remain_wavs=total_len-chunk_size*args.test_thread_num
# else:
# chunk_size=0
#
# process_list = []
# chunk_begin=0
# for i in range(args.test_thread_num):
# now_chunk_size= chunk_size
# if remain_wavs>0:
# now_chunk_size=chunk_size+1
# remain_wavs=remain_wavs-1
# # process i handle wavs at chunk_begin and size of now_chunk_size
# p = Process(target=one_thread,args=(i,chunk_begin,now_chunk_size))
# chunk_begin=chunk_begin+now_chunk_size
# p.start()
# process_list.append(p)
#
# for i in process_list:
# p.join()
#
# print('end')
#