雾聪
2023-09-07 b26d3de5fa022f4a44648fee24546aff4e1cf5bc
funasr/runtime/websocket/websocket-server-2pass.cpp
@@ -299,9 +299,10 @@
      iter++;
    }
    for (auto hdl : to_remove) {
      remove_hdl(hdl, data_map);
      //LOG(INFO) << "remove one connection ";
      {
        unique_lock lock(m_lock);
        remove_hdl(hdl, data_map);
      }
    }
  }
}
@@ -443,10 +444,10 @@
      LOG(ERROR) << "FunTpassInit init failed";
      exit(-1);
    }
   LOG(INFO) << "initAsr run check_and_clean_connection";
   std::thread clean_thread(&WebSocketServer::check_and_clean_connection,this);
   clean_thread.detach();
   LOG(INFO) << "initAsr run check_and_clean_connection finished";
    LOG(INFO) << "initAsr run check_and_clean_connection";
    std::thread clean_thread(&WebSocketServer::check_and_clean_connection,this);
    clean_thread.detach();
    LOG(INFO) << "initAsr run check_and_clean_connection finished";
  } catch (const std::exception& e) {
    LOG(INFO) << e.what();