src/socket.cpp
@@ -115,7 +115,7 @@ } //maybe reimplment, using async cbs? bool ShmSocket::SyncRecv(bhome_msg::MsgI &msg, bhome::msg::BHMsgHead &head, const int timeout_ms) bool ShmSocket::SyncRecv(bhome_msg::MsgI &msg, bhome_msg::BHMsgHead &head, const int timeout_ms) { // std::lock_guard<std::mutex> lock(mutex_); // seems no need to lock mutex_. bool got = (timeout_ms == 0) ? mq().TryRecv(msg) : mq().Recv(msg, timeout_ms);