Add 'CAN-binder/libs/openxc-message-format/' from commit 'd9f54f97578429773421abce98d...

[apps/agl-service-can-low-level.git] / CAN-binder / low-can-binding / can / can-bus.cpp

diff --git a/CAN-binder/low-can-binding/can/can-bus.cpp b/CAN-binder/low-can-binding/can/can-bus.cpp
index 0de8aeb..5f45624 100644 (file)
--- a/CAN-binder/low-can-binding/can/can-bus.cpp
+++ b/CAN-binder/low-can-binding/can/can-bus.cpp
@@ -80,7 +80,9 @@ int can_bus_t::can_reader()
                                {
                                        can_message_t msg;
                                        s.second->get_socket() >> msg;
-                                       push_new_can_message(msg);
+                                       std::lock_guard<std::mutex> can_message_lock(get_can_message_mutex());
+                                       { push_new_can_message(msg); }
+                                       get_new_can_message_cv().notify_one();
                                        }
                                }
                }