Lock before push_back the deque for thread safety (k2-fsa#445)

Co-authored-by: hiedean <[email protected]>
XiaYucca · Nov 24, 2023 · 969a69b · 969a69b
1 parent 5b32d6d
commit 969a69b
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/sherpa-onnx/csrc/online-websocket-server-impl.cc b/sherpa-onnx/csrc/online-websocket-server-impl.cc
@@ -304,7 +304,10 @@ void OnlineWebsocketServer::OnMessage(connection_hdl hdl,
       int32_t num_samples = payload.size() / sizeof(float);
       std::vector<float> samples(p, p + num_samples);
 
-      c->samples.push_back(std::move(samples));
+      {
+        std::lock_guard<std::mutex> lock(c->mutex);
+        c->samples.push_back(std::move(samples));
+      }
 
       asio::post(io_work_, [this, c]() { decoder_.AcceptWaveform(c); });
       break;