[debug] handle buffer lock, incase coredump

funasr/runtime/grpc/paraformer-server.cc

@@ -42,7 +42,9 @@ void GrpcEngine::DecodeThreadFunc() {
                                                  sampling_rate_,
                                                  encoding_,
                                                  mode_);
+      p_mutex_->lock();
       audio_buffer_ = audio_buffer_.substr(step);
+      p_mutex_->unlock();
 
       if (result) {
         std::string online_message = FunASRGetResult(result, 0);
@@ -121,7 +123,9 @@ void GrpcEngine::OnSpeechStart() {
 }
 
 void GrpcEngine::OnSpeechData() {
+  p_mutex_->lock();
   audio_buffer_ += request_->audio_data();
+  p_mutex_->unlock();
 }
 
 void GrpcEngine::OnSpeechEnd() {

funasr/runtime/grpc/paraformer-server.h

@@ -6,6 +6,7 @@
 
 #include <string>
 #include <thread>
+#include <mutex>
 #include <unistd.h>
 
 #include "grpcpp/server_builder.h"
@@ -52,6 +53,8 @@ class GrpcEngine {
   std::string encoding_;
   ASR_TYPE mode_ = ASR_TWO_PASS;
   int step_duration_ms_ = 100;
+
+  std::unique_ptr<std::mutex> p_mutex_= std::make_unique<std::mutex>(); // mutex is not moveable
 };
 
 class GrpcService final : public ASR::Service {