OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 #include "remoting/protocol/client_control_dispatcher.h" | 5 #include "remoting/protocol/client_control_dispatcher.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include "base/bind_helpers.h" | 9 #include "base/bind_helpers.h" |
10 #include "base/callback.h" | 10 #include "base/callback.h" |
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
59 } // namespace | 59 } // namespace |
60 | 60 |
61 ClientControlDispatcher::ClientControlDispatcher() | 61 ClientControlDispatcher::ClientControlDispatcher() |
62 : ChannelDispatcherBase(kControlChannelName) {} | 62 : ChannelDispatcherBase(kControlChannelName) {} |
63 ClientControlDispatcher::~ClientControlDispatcher() {} | 63 ClientControlDispatcher::~ClientControlDispatcher() {} |
64 | 64 |
65 void ClientControlDispatcher::InjectClipboardEvent( | 65 void ClientControlDispatcher::InjectClipboardEvent( |
66 const ClipboardEvent& event) { | 66 const ClipboardEvent& event) { |
67 ControlMessage message; | 67 ControlMessage message; |
68 message.mutable_clipboard_event()->CopyFrom(event); | 68 message.mutable_clipboard_event()->CopyFrom(event); |
69 writer()->Write(SerializeAndFrameMessage(message), base::Closure()); | 69 message_pipe()->Send(&message, base::Closure()); |
70 } | 70 } |
71 | 71 |
72 void ClientControlDispatcher::NotifyClientResolution( | 72 void ClientControlDispatcher::NotifyClientResolution( |
73 const ClientResolution& resolution) { | 73 const ClientResolution& resolution) { |
74 ControlMessage message; | 74 ControlMessage message; |
75 message.mutable_client_resolution()->CopyFrom(resolution); | 75 message.mutable_client_resolution()->CopyFrom(resolution); |
76 writer()->Write(SerializeAndFrameMessage(message), base::Closure()); | 76 message_pipe()->Send(&message, base::Closure()); |
77 } | 77 } |
78 | 78 |
79 void ClientControlDispatcher::ControlVideo(const VideoControl& video_control) { | 79 void ClientControlDispatcher::ControlVideo(const VideoControl& video_control) { |
80 ControlMessage message; | 80 ControlMessage message; |
81 message.mutable_video_control()->CopyFrom(video_control); | 81 message.mutable_video_control()->CopyFrom(video_control); |
82 writer()->Write(SerializeAndFrameMessage(message), base::Closure()); | 82 message_pipe()->Send(&message, base::Closure()); |
83 } | 83 } |
84 | 84 |
85 void ClientControlDispatcher::ControlAudio(const AudioControl& audio_control) { | 85 void ClientControlDispatcher::ControlAudio(const AudioControl& audio_control) { |
86 ControlMessage message; | 86 ControlMessage message; |
87 message.mutable_audio_control()->CopyFrom(audio_control); | 87 message.mutable_audio_control()->CopyFrom(audio_control); |
88 writer()->Write(SerializeAndFrameMessage(message), base::Closure()); | 88 message_pipe()->Send(&message, base::Closure()); |
89 } | 89 } |
90 | 90 |
91 void ClientControlDispatcher::SetCapabilities( | 91 void ClientControlDispatcher::SetCapabilities( |
92 const Capabilities& capabilities) { | 92 const Capabilities& capabilities) { |
93 ControlMessage message; | 93 ControlMessage message; |
94 message.mutable_capabilities()->CopyFrom(capabilities); | 94 message.mutable_capabilities()->CopyFrom(capabilities); |
95 writer()->Write(SerializeAndFrameMessage(message), base::Closure()); | 95 message_pipe()->Send(&message, base::Closure()); |
96 } | 96 } |
97 | 97 |
98 void ClientControlDispatcher::RequestPairing( | 98 void ClientControlDispatcher::RequestPairing( |
99 const PairingRequest& pairing_request) { | 99 const PairingRequest& pairing_request) { |
100 ControlMessage message; | 100 ControlMessage message; |
101 message.mutable_pairing_request()->CopyFrom(pairing_request); | 101 message.mutable_pairing_request()->CopyFrom(pairing_request); |
102 writer()->Write(SerializeAndFrameMessage(message), base::Closure()); | 102 message_pipe()->Send(&message, base::Closure()); |
103 } | 103 } |
104 | 104 |
105 void ClientControlDispatcher::DeliverClientMessage( | 105 void ClientControlDispatcher::DeliverClientMessage( |
106 const ExtensionMessage& message) { | 106 const ExtensionMessage& message) { |
107 ControlMessage control_message; | 107 ControlMessage control_message; |
108 control_message.mutable_extension_message()->CopyFrom(message); | 108 control_message.mutable_extension_message()->CopyFrom(message); |
109 writer()->Write(SerializeAndFrameMessage(control_message), base::Closure()); | 109 message_pipe()->Send(&control_message, base::Closure()); |
110 } | 110 } |
111 | 111 |
112 void ClientControlDispatcher::OnIncomingMessage( | 112 void ClientControlDispatcher::OnIncomingMessage( |
113 scoped_ptr<CompoundBuffer> buffer) { | 113 scoped_ptr<CompoundBuffer> buffer) { |
114 DCHECK(client_stub_); | 114 DCHECK(client_stub_); |
115 DCHECK(clipboard_stub_); | 115 DCHECK(clipboard_stub_); |
116 | 116 |
117 scoped_ptr<ControlMessage> message = | 117 scoped_ptr<ControlMessage> message = |
118 ParseMessage<ControlMessage>(buffer.get()); | 118 ParseMessage<ControlMessage>(buffer.get()); |
119 if (!message) | 119 if (!message) |
(...skipping 10 matching lines...) Expand all Loading... |
130 client_stub_->SetPairingResponse(message->pairing_response()); | 130 client_stub_->SetPairingResponse(message->pairing_response()); |
131 } else if (message->has_extension_message()) { | 131 } else if (message->has_extension_message()) { |
132 client_stub_->DeliverHostMessage(message->extension_message()); | 132 client_stub_->DeliverHostMessage(message->extension_message()); |
133 } else { | 133 } else { |
134 LOG(WARNING) << "Unknown control message received."; | 134 LOG(WARNING) << "Unknown control message received."; |
135 } | 135 } |
136 } | 136 } |
137 | 137 |
138 } // namespace protocol | 138 } // namespace protocol |
139 } // namespace remoting | 139 } // namespace remoting |
OLD | NEW |