| Index: remoting/protocol/rtp_video_reader.h
|
| diff --git a/remoting/protocol/rtp_video_reader.h b/remoting/protocol/rtp_video_reader.h
|
| index 8b0d3bdae35d373fb6050201cda9eb97f746ae5f..e2eaf20e0518107ee85955eb93f8e980930cab2b 100644
|
| --- a/remoting/protocol/rtp_video_reader.h
|
| +++ b/remoting/protocol/rtp_video_reader.h
|
| @@ -5,7 +5,9 @@
|
| #ifndef REMOTING_PROTOCOL_RTP_VIDEO_READER_H_
|
| #define REMOTING_PROTOCOL_RTP_VIDEO_READER_H_
|
|
|
| +#include "base/compiler_specific.h"
|
| #include "base/time.h"
|
| +#include "base/memory/scoped_ptr.h"
|
| #include "remoting/protocol/rtcp_writer.h"
|
| #include "remoting/protocol/rtp_reader.h"
|
| #include "remoting/protocol/video_reader.h"
|
| @@ -13,6 +15,8 @@
|
| namespace remoting {
|
| namespace protocol {
|
|
|
| +class RtcpWriter;
|
| +class RtpReader;
|
| class Session;
|
|
|
| class RtpVideoReader : public VideoReader {
|
| @@ -21,7 +25,9 @@ class RtpVideoReader : public VideoReader {
|
| virtual ~RtpVideoReader();
|
|
|
| // VideoReader interface.
|
| - virtual void Init(protocol::Session* session, VideoStub* video_stub);
|
| + virtual void Init(protocol::Session* session,
|
| + VideoStub* video_stub,
|
| + const InitializedCallback& callback) OVERRIDE;
|
|
|
| private:
|
| friend class RtpVideoReaderTest;
|
| @@ -44,6 +50,8 @@ class RtpVideoReader : public VideoReader {
|
|
|
| typedef std::deque<PacketsQueueEntry> PacketsQueue;
|
|
|
| + void OnChannelReady(const std::string& name, net::Socket* socket);
|
| +
|
| void OnRtpPacket(const RtpPacket* rtp_packet);
|
| void CheckFullPacket(const PacketsQueue::iterator& pos);
|
| void RebuildVideoPacket(const PacketsQueue::iterator& from,
|
| @@ -56,7 +64,12 @@ class RtpVideoReader : public VideoReader {
|
| // |kReceiverReportsIntervalMs|.
|
| void SendReceiverReportIf();
|
|
|
| + bool initialized_;
|
| + InitializedCallback initialized_callback_;
|
| +
|
| + scoped_ptr<net::Socket> rtp_channel_;
|
| RtpReader rtp_reader_;
|
| + scoped_ptr<net::Socket> rtcp_channel_;
|
| RtcpWriter rtcp_writer_;
|
|
|
| PacketsQueue packets_queue_;
|
|
|