diff --git a/av_transport/av_trans_control_center/services/src/av_sync_manager.cpp b/av_transport/av_trans_control_center/services/src/av_sync_manager.cpp
index 5991dc2f6fbf3b3494b5416873aadaa58f20fa91..8540ae7bc40eb126a7bccb97e61f981dd72ae9fd 100644
--- a/av_transport/av_trans_control_center/services/src/av_sync_manager.cpp
+++ b/av_transport/av_trans_control_center/services/src/av_sync_manager.cpp
@@ -184,6 +184,7 @@ bool AVSyncManager::MergeGroupInfo(std::string &syncGroupInfo)
 
 bool AVSyncManager::MergeGroupInfoInner(std::set<std::string> &groupInfoSet)
 {
+    std::lock_guard<std::mutex> lock(listMutex_);
     for (const auto &item : streamInfoList_) {
         if ((item.sceneType == SCENE_TYPE_D_MIC) || (item.sceneType == SCENE_TYPE_D_SPEAKER)) {
             cJSON *masterStr = cJSON_CreateObject();
diff --git a/av_transport/av_trans_engine/filters/av_trans_input/av_trans_bus_input_filter.cpp b/av_transport/av_trans_engine/filters/av_trans_input/av_trans_bus_input_filter.cpp
index 0dfcccd790b35709c1d4457c4868c15a23a0376e..7fe79d7130dd37578fd82836c265d1b675b556f1 100644
--- a/av_transport/av_trans_engine/filters/av_trans_input/av_trans_bus_input_filter.cpp
+++ b/av_transport/av_trans_engine/filters/av_trans_input/av_trans_bus_input_filter.cpp
@@ -401,6 +401,7 @@ void AVTransBusInputFilter::OnStreamReceived(const StreamData *data, const Strea
         return;
     }
     std::string message(reinterpret_cast<const char *>(ext->buf), ext->bufLen);
+    TRUE_RETURN(message.length() > MAX_MESSAGES_LEN, "Message length is iilegal.");
     AVTRANS_LOGD("Receive message : %{public}s", message.c_str());
 
     cJSON *resMsg = cJSON_Parse(message.c_str());