wx44wx/pipecat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Only showing the timout warning to receive frame if the client is connected.

Browse Source
This commit is contained in:
Filipi Fuchter
2025-03-12 15:13:59 -03:00
parent 0d05312071
commit 93d8ddf4f2
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/pipecat/transports/network/small_webrtc.py
View File

@@ -187,9 +187,10 @@ class SmallWebRTCClient:
try: try:
frame = await asyncio.wait_for(self._video_input_track.recv(), timeout=1.0) frame = await asyncio.wait_for(self._video_input_track.recv(), timeout=1.0)
except asyncio.TimeoutError: except asyncio.TimeoutError:
if self._webrtcConnection.is_connected():
logger.warning("Timeout: No video frame received within the specified time.") logger.warning("Timeout: No video frame received within the specified time.")
frame = None
self._webrtcConnection.ask_to_renegotiate() self._webrtcConnection.ask_to_renegotiate()
frame = None
if frame is None or not isinstance(frame, VideoFrame): if frame is None or not isinstance(frame, VideoFrame):
# If no valid frame, sleep for a bit # If no valid frame, sleep for a bit
@@ -233,6 +234,7 @@ class SmallWebRTCClient:
try: try:
frame = await asyncio.wait_for(self._audio_input_track.recv(), timeout=1.0) frame = await asyncio.wait_for(self._audio_input_track.recv(), timeout=1.0)
except asyncio.TimeoutError: except asyncio.TimeoutError:
if self._webrtcConnection.is_connected():
logger.warning("Timeout: No audio frame received within the specified time.") logger.warning("Timeout: No audio frame received within the specified time.")
frame = None frame = None