Index: webrtc/video/rtp_streams_synchronizer.h |
diff --git a/webrtc/video/rtp_streams_synchronizer.h b/webrtc/video/rtp_streams_synchronizer.h |
new file mode 100644 |
index 0000000000000000000000000000000000000000..082bec7b6e0f4fd3c5d582a0ebc5ebb170b42bdd |
--- /dev/null |
+++ b/webrtc/video/rtp_streams_synchronizer.h |
@@ -0,0 +1,73 @@ |
+/* |
+ * Copyright (c) 2012 The WebRTC project authors. All Rights Reserved. |
+ * |
+ * Use of this source code is governed by a BSD-style license |
+ * that can be found in the LICENSE file in the root of the source |
+ * tree. An additional intellectual property rights grant can be found |
+ * in the file PATENTS. All contributing project authors may |
+ * be found in the AUTHORS file in the root of the source tree. |
+ */ |
+ |
+// RtpStreamsSynchronizer is responsible for synchronization audio and video for |
+// a given voice engine channel and video receive stream. |
+ |
+#ifndef WEBRTC_VIDEO_RTP_STREAMS_SYNCHRONIZER_H_ |
+#define WEBRTC_VIDEO_RTP_STREAMS_SYNCHRONIZER_H_ |
+ |
+#include <memory> |
+ |
+#include "webrtc/base/criticalsection.h" |
+#include "webrtc/base/thread_checker.h" |
+#include "webrtc/modules/include/module.h" |
+#include "webrtc/video/rtp_stream_receiver.h" |
+#include "webrtc/video/stream_synchronization.h" |
+ |
+namespace webrtc { |
+ |
+class Clock; |
+class VideoFrame; |
+class VoEVideoSync; |
+ |
+namespace vcm { |
+class VideoReceiver; |
+} // namespace vcm |
+ |
+class RtpStreamsSynchronizer : public Module { |
+ public: |
+ RtpStreamsSynchronizer(vcm::VideoReceiver* vcm, |
+ RtpStreamReceiver* rtp_stream_receiver); |
+ |
+ void ConfigureSync(int voe_channel_id, |
+ VoEVideoSync* voe_sync_interface); |
+ |
+ // Implements Module. |
+ int64_t TimeUntilNextProcess() override; |
+ void Process() override; |
+ |
+ // Gets the sync offset between the current played out audio frame and the |
+ // video |frame|. Returns true on success, false otherwise. |
+ bool GetStreamSyncOffsetInMs(const VideoFrame& frame, |
+ int64_t* stream_offset_ms) const; |
+ |
+ private: |
+ Clock* const clock_; |
+ vcm::VideoReceiver* const video_receiver_; |
+ RtpReceiver* const video_rtp_receiver_; |
+ RtpRtcp* const video_rtp_rtcp_; |
+ |
+ rtc::CriticalSection crit_; |
+ int voe_channel_id_ GUARDED_BY(crit_); |
+ VoEVideoSync* voe_sync_interface_ GUARDED_BY(crit_); |
+ RtpReceiver* audio_rtp_receiver_ GUARDED_BY(crit_); |
+ RtpRtcp* audio_rtp_rtcp_ GUARDED_BY(crit_); |
+ std::unique_ptr<StreamSynchronization> sync_ GUARDED_BY(crit_); |
+ StreamSynchronization::Measurements audio_measurement_ GUARDED_BY(crit_); |
+ StreamSynchronization::Measurements video_measurement_ GUARDED_BY(crit_); |
+ |
+ rtc::ThreadChecker process_thread_checker_; |
+ int64_t last_sync_time_ ACCESS_ON(&process_thread_checker_); |
+}; |
+ |
+} // namespace webrtc |
+ |
+#endif // WEBRTC_VIDEO_RTP_STREAMS_SYNCHRONIZER_H_ |