Method tts_receiver_thread_func

web_demo/server/server.py:817–847

[Multiprocessing] Receiving output from the TTS process (only messages belonging to the current session)

()

            log("info", "TTS sender thread stopped")

        def tts_receiver_thread_func():
            """[Multiprocessing] Receiving output from the TTS process (only messages belonging to the current session)"""
            log("info", f"TTS receiver thread started for session {this_uuid}")
            
            while not close:
                try:
                    try:
                        uuid_str, speech_array = tts_output_queue.get(timeout=0.1)
                    except:
                        continue
                    
                    with tts_state_lock:
                        current_uuid = this_uuid
                    
                    if uuid_str != current_uuid:
                        log("info", f"Discarding TTS output from old session {uuid_str[:8]}... (current: {current_uuid[:8]}...)")
                        continue
                    
                    with audio_buffer_lock:
                        all_generated_audio.append(speech_array.copy())
                        audio_buffer_list.append(speech_array.copy())
                    
                    timestamp = datetime.now().strftime("%H:%M:%S.%f")[:-3]
                    log("info", f"[{timestamp}] Received TTS audio: {speech_array.shape[-1]} samples")
                    
                except Exception as e:
                    log("error", f"TTS receiver thread error: {e}")
                    import traceback
                    traceback.print_exc()
            
            log("info", "TTS receiver thread stopped")

        def encode_thread_func():
            """Encoding thread: Take complete frames from audio_buffer, encode them into Opus, and place them into opus_bytes_queue"""