del m_client.close

雾聪

2023-08-23 259a1c70282cbef477688f0925a20c22d5b8c243

 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 @@
            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();
            //    }
            // }
        }
    }