OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #ifndef REMOTING_PROTOCOL_HOST_VIDEO_DISPATCHER_H_ | 5 #ifndef REMOTING_PROTOCOL_HOST_VIDEO_DISPATCHER_H_ |
6 #define REMOTING_PROTOCOL_HOST_VIDEO_DISPATCHER_H_ | 6 #define REMOTING_PROTOCOL_HOST_VIDEO_DISPATCHER_H_ |
7 | 7 |
| 8 #include <deque> |
8 #include <string> | 9 #include <string> |
9 | 10 |
10 #include "base/compiler_specific.h" | 11 #include "base/compiler_specific.h" |
11 #include "remoting/protocol/buffered_socket_writer.h" | 12 #include "remoting/proto/video.pb.h" |
12 #include "remoting/protocol/channel_dispatcher_base.h" | 13 #include "remoting/protocol/channel_dispatcher_base.h" |
13 #include "remoting/protocol/video_stub.h" | 14 #include "remoting/protocol/protobuf_message_parser.h" |
| 15 #include "remoting/protocol/video_sender.h" |
14 | 16 |
15 namespace remoting { | 17 namespace remoting { |
16 namespace protocol { | 18 namespace protocol { |
17 | 19 |
18 class HostVideoDispatcher : public ChannelDispatcherBase, public VideoStub { | 20 class HostVideoDispatcher : public ChannelDispatcherBase, public VideoSender { |
19 public: | 21 public: |
20 HostVideoDispatcher(); | 22 HostVideoDispatcher(); |
21 ~HostVideoDispatcher() override; | 23 ~HostVideoDispatcher() override; |
22 | 24 |
23 // VideoStub interface. | 25 // VideoStub interface. |
24 void ProcessVideoPacket(scoped_ptr<VideoPacket> packet, | 26 void ProcessVideoPacket(scoped_ptr<VideoPacket> packet, |
25 const base::Closure& done) override; | 27 const base::Closure& done) override; |
| 28 bool SupportsAcks() override; |
26 | 29 |
27 private: | 30 private: |
| 31 struct PendingFrame { |
| 32 PendingFrame(int frame_id, const base::Closure& done); |
| 33 |
| 34 int32_t frame_id; |
| 35 base::Closure done; |
| 36 }; |
| 37 |
| 38 void OnVideoAck(scoped_ptr<VideoAck> ack, const base::Closure& done); |
| 39 |
| 40 int32_t frame_id_; |
| 41 ProtobufMessageParser<VideoAck> parser_; |
| 42 |
| 43 std::deque<PendingFrame> pending_frames_; |
| 44 |
28 DISALLOW_COPY_AND_ASSIGN(HostVideoDispatcher); | 45 DISALLOW_COPY_AND_ASSIGN(HostVideoDispatcher); |
29 }; | 46 }; |
30 | 47 |
31 } // namespace protocol | 48 } // namespace protocol |
32 } // namespace remoting | 49 } // namespace remoting |
33 | 50 |
34 #endif // REMOTING_PROTOCOL_HOST_VIDEO_DISPATCHER_H_ | 51 #endif // REMOTING_PROTOCOL_HOST_VIDEO_DISPATCHER_H_ |
OLD | NEW |