From 8b6aaac4ae866ec488c972d57abce501f859b8a9 Mon Sep 17 00:00:00 2001
From: 雾聪 <wucong.lyb@alibaba-inc.com>
Date: 星期三, 23 八月 2023 22:46:03 +0800
Subject: [PATCH] set sleep to 10ms
---
funasr/runtime/websocket/funasr-wss-client.cpp | 22 +++++++++++-----------
1 files changed, 11 insertions(+), 11 deletions(-)
diff --git a/funasr/runtime/websocket/funasr-wss-client.cpp b/funasr/runtime/websocket/funasr-wss-client.cpp
index bf1140b..235e709 100644
--- a/funasr/runtime/websocket/funasr-wss-client.cpp
+++ b/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;
--
Gitblit v1.9.1