del m_client.close

funasr/runtime/websocket/funasr-wss-client.cpp

@@ -32,9 +32,9 @@
  */
 void WaitABit() {
     #ifdef WIN32
-        Sleep(500);
+        Sleep(200);
     #else
-        usleep(500);
+        usleep(200);
     #endif
 }
 std::atomic<int> wav_index(0);
@@ -108,16 +108,16 @@ class WebsocketClient {
             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();
+				// 	}
+				// }
         }
     }