雾聪
2023-08-23 8b6aaac4ae866ec488c972d57abce501f859b8a9
set sleep to 10ms
1个文件已修改
22 ■■■■ 已修改文件
funasr/runtime/websocket/funasr-wss-client.cpp 22 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
funasr/runtime/websocket/funasr-wss-client.cpp
@@ -108,16 +108,16 @@
            case websocketpp::frame::opcode::text:
                total_num=total_num+1;
                LOG(INFO)<< "Thread: " << this_thread::get_id() <<",on_message = " << payload;
                // LOG(INFO) << "total_num=" << total_num << " wav_index=" <<wav_index;
                // if((total_num+1)==wav_index)
                // {
                //     LOG(INFO) << "close client";
                //     websocketpp::lib::error_code ec;
                //     m_client.close(m_hdl, websocketpp::close::status::going_away, "", ec);
                //     if (ec){
                //         LOG(ERROR)<< "Error closing connection " << ec.message();
                //     }
                // }
                LOG(INFO) << "total_num=" << total_num << " wav_index=" <<wav_index;
                if((total_num+1)==wav_index)
                {
                    LOG(INFO) << "close client";
                    websocketpp::lib::error_code ec;
                    m_client.close(m_hdl, websocketpp::close::status::going_away, "", ec);
                    if (ec){
                        LOG(ERROR)<< "Error closing connection " << ec.message();
                    }
                }
        }
    }
@@ -321,7 +321,7 @@
        jsonresult["is_speaking"] = false;
        m_client.send(m_hdl, jsonresult.dump(), websocketpp::frame::opcode::text,
                      ec);
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
        std::this_thread::sleep_for(std::chrono::milliseconds(10));
    }
    websocketpp::client<T> m_client;