This commit is contained in:
yumoqing 2024-09-14 12:08:08 +08:00
parent bd8aefd87a
commit 6e923dbc74

View File

@ -47,21 +47,16 @@ class AudioTrackVad(MediaStreamTrack):
return audio_bytes return audio_bytes
async def recv(self): async def recv(self):
oldf = await self.track.recv() frame = await self.track.recv()
self.sample_rate = oldf.sample_rate self.sample_rate = frame.sample_rate
duration = (oldf.samples * 1000) / oldf.sample_rate duration = (frame.samples * 1000) / frame.sample_rate
# print(f'{self.__class__.__name__}.recv(): {duration=}, {oldf.samples=}, {oldf.sample_rate=}') # print(f'{self.__class__.__name__}.recv(): {duration=}, {frame.samples=}, {frame.sample_rate=}')
try: try:
for f in frames: await self.vad_check(f)
if self.debug: except Exception as e:
self.debug = False print(f'{e=}')
# print(f'{type(f)}, {f.samples=}, {f.format.bytes=}, {f.sample_rate=}, {f.format=}, {f.is_corrupt=}, {f.layout=}, {f.planes=}, {f.side_data=}') print_exc()
try: return
await self.vad_check(f)
except Exception as e:
print(f'{e=}')
print_exc()
return
if self.task: if self.task:
self.task.cancel() self.task.cancel()
if self.running: if self.running: