Chromium Code Reviews| 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 { |
|
mflodman
2016/08/04 08:24:05
This is not really a new file, rather vie_sync_mod
|
| + 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_ |