Restore lock stream datas

src/device/device.cc

@@ -351,12 +351,14 @@ void Device::WaitForStreams() {
 std::vector<device::StreamData> Device::GetStreamDatas(const Stream &stream) {
   CHECK(video_streaming_);
   CHECK_NOTNULL(streams_);
+  std::lock_guard<std::mutex> _(mtx_streams_);
   return streams_->GetStreamDatas(stream);
 }
 
 device::StreamData Device::GetLatestStreamData(const Stream &stream) {
   CHECK(video_streaming_);
   CHECK_NOTNULL(streams_);
+  std::lock_guard<std::mutex> _(mtx_streams_);
   return streams_->GetLatestStreamData(stream);
 }
 
@@ -424,10 +426,13 @@ void Device::StartVideoStreaming() {
             return;
           }
           // auto &&time_beg = times::now();
+          {
+            std::lock_guard<std::mutex> _(mtx_streams_);
             if (streams_->PushStream(Capabilities::STEREO, data)) {
               CallbackPushedStreamData(Stream::LEFT);
               CallbackPushedStreamData(Stream::RIGHT);
             }
+          }
           continuation();
           // VLOG(2) << "Stereo video callback cost "
           //     << times::count<times::milliseconds>(times::now() - time_beg)

src/device/device.h

@@ -18,6 +18,7 @@
 #include <limits>
 #include <map>
 #include <memory>
+#include <mutex>
 #include <string>
 #include <vector>
 
@@ -272,6 +273,8 @@ class MYNTEYE_API Device {
 
   std::map<Capabilities, StreamRequest> stream_config_requests_;
 
+  std::mutex mtx_streams_;
+
   std::shared_ptr<Channels> channels_;
 
   std::shared_ptr<Motions> motions_;