| 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/host/client_session.h" | 5 #include "remoting/host/client_session.h" |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 | 8 |
| 9 #include "base/message_loop_proxy.h" | 9 #include "base/message_loop_proxy.h" |
| 10 #include "remoting/host/video_frame_capturer.h" | 10 #include "remoting/host/video_frame_capturer.h" |
| (...skipping 21 matching lines...) Expand all Loading... |
| 32 remote_input_filter_(&input_tracker_), | 32 remote_input_filter_(&input_tracker_), |
| 33 mouse_input_filter_(&remote_input_filter_), | 33 mouse_input_filter_(&remote_input_filter_), |
| 34 client_clipboard_factory_(clipboard_echo_filter_.client_filter()), | 34 client_clipboard_factory_(clipboard_echo_filter_.client_filter()), |
| 35 capturer_(capturer), | 35 capturer_(capturer), |
| 36 max_duration_(max_duration) { | 36 max_duration_(max_duration) { |
| 37 connection_->SetEventHandler(this); | 37 connection_->SetEventHandler(this); |
| 38 | 38 |
| 39 // TODO(sergeyu): Currently ConnectionToClient expects stubs to be | 39 // TODO(sergeyu): Currently ConnectionToClient expects stubs to be |
| 40 // set before channels are connected. Make it possible to set stubs | 40 // set before channels are connected. Make it possible to set stubs |
| 41 // later and set them only when connection is authenticated. | 41 // later and set them only when connection is authenticated. |
| 42 connection_->set_clipboard_stub(this); | 42 connection_->set_clipboard_stub(&auth_clipboard_filter_); |
| 43 connection_->set_host_stub(this); | 43 connection_->set_host_stub(this); |
| 44 connection_->set_input_stub(this); | 44 connection_->set_input_stub(this); |
| 45 clipboard_echo_filter_.set_host_stub(host_clipboard_stub_); | 45 clipboard_echo_filter_.set_host_stub(host_clipboard_stub_); |
| 46 } | 46 } |
| 47 | 47 |
| 48 ClientSession::~ClientSession() { | 48 ClientSession::~ClientSession() { |
| 49 } | 49 } |
| 50 | 50 |
| 51 void ClientSession::InjectClipboardEvent( | |
| 52 const protocol::ClipboardEvent& event) { | |
| 53 DCHECK(CalledOnValidThread()); | |
| 54 | |
| 55 // TODO(wez): Disable clipboard in both directions on local activity, and | |
| 56 // replace these tests with a HostInputFilter (or ClipboardFilter). | |
| 57 if (auth_input_filter_.input_stub() == NULL) | |
| 58 return; | |
| 59 if (disable_input_filter_.input_stub() == NULL) | |
| 60 return; | |
| 61 | |
| 62 clipboard_echo_filter_.host_filter()->InjectClipboardEvent(event); | |
| 63 } | |
| 64 | |
| 65 void ClientSession::InjectKeyEvent(const protocol::KeyEvent& event) { | 51 void ClientSession::InjectKeyEvent(const protocol::KeyEvent& event) { |
| 66 DCHECK(CalledOnValidThread()); | 52 DCHECK(CalledOnValidThread()); |
| 67 auth_input_filter_.InjectKeyEvent(event); | 53 auth_input_filter_.InjectKeyEvent(event); |
| 68 } | 54 } |
| 69 | 55 |
| 70 void ClientSession::InjectMouseEvent(const protocol::MouseEvent& event) { | 56 void ClientSession::InjectMouseEvent(const protocol::MouseEvent& event) { |
| 71 DCHECK(CalledOnValidThread()); | 57 DCHECK(CalledOnValidThread()); |
| 72 | 58 |
| 73 // Ensure that the MouseInputFilter is clamping to the current dimensions. | 59 // Ensure that the MouseInputFilter is clamping to the current dimensions. |
| 74 mouse_input_filter_.set_output_size(capturer_->size_most_recent()); | 60 mouse_input_filter_.set_output_size(capturer_->size_most_recent()); |
| (...skipping 17 matching lines...) Expand all Loading... |
| 92 if (video_control.has_enable()) { | 78 if (video_control.has_enable()) { |
| 93 VLOG(1) << "Received VideoControl (enable=" | 79 VLOG(1) << "Received VideoControl (enable=" |
| 94 << video_control.enable() << ")"; | 80 << video_control.enable() << ")"; |
| 95 } | 81 } |
| 96 } | 82 } |
| 97 | 83 |
| 98 void ClientSession::OnConnectionAuthenticated( | 84 void ClientSession::OnConnectionAuthenticated( |
| 99 protocol::ConnectionToClient* connection) { | 85 protocol::ConnectionToClient* connection) { |
| 100 DCHECK(CalledOnValidThread()); | 86 DCHECK(CalledOnValidThread()); |
| 101 DCHECK_EQ(connection_.get(), connection); | 87 DCHECK_EQ(connection_.get(), connection); |
| 88 |
| 102 is_authenticated_ = true; | 89 is_authenticated_ = true; |
| 103 auth_input_filter_.set_input_stub(&disable_input_filter_); | 90 auth_input_filter_.set_input_stub(&disable_input_filter_); |
| 91 auth_clipboard_filter_.set_clipboard_stub(&disable_clipboard_filter_); |
| 92 |
| 104 clipboard_echo_filter_.set_client_stub(connection_->client_stub()); | 93 clipboard_echo_filter_.set_client_stub(connection_->client_stub()); |
| 94 |
| 105 if (max_duration_ > base::TimeDelta()) { | 95 if (max_duration_ > base::TimeDelta()) { |
| 106 // TODO(simonmorris): Let Disconnect() tell the client that the | 96 // TODO(simonmorris): Let Disconnect() tell the client that the |
| 107 // disconnection was caused by the session exceeding its maximum duration. | 97 // disconnection was caused by the session exceeding its maximum duration. |
| 108 max_duration_timer_.Start(FROM_HERE, max_duration_, | 98 max_duration_timer_.Start(FROM_HERE, max_duration_, |
| 109 this, &ClientSession::Disconnect); | 99 this, &ClientSession::Disconnect); |
| 110 } | 100 } |
| 101 |
| 111 event_handler_->OnSessionAuthenticated(this); | 102 event_handler_->OnSessionAuthenticated(this); |
| 112 } | 103 } |
| 113 | 104 |
| 114 void ClientSession::OnConnectionChannelsConnected( | 105 void ClientSession::OnConnectionChannelsConnected( |
| 115 protocol::ConnectionToClient* connection) { | 106 protocol::ConnectionToClient* connection) { |
| 116 DCHECK(CalledOnValidThread()); | 107 DCHECK(CalledOnValidThread()); |
| 117 DCHECK_EQ(connection_.get(), connection); | 108 DCHECK_EQ(connection_.get(), connection); |
| 118 SetDisableInputs(false); | 109 SetDisableInputs(false); |
| 119 event_handler_->OnSessionChannelsConnected(this); | 110 event_handler_->OnSessionChannelsConnected(this); |
| 120 } | 111 } |
| 121 | 112 |
| 122 void ClientSession::OnConnectionClosed( | 113 void ClientSession::OnConnectionClosed( |
| 123 protocol::ConnectionToClient* connection, | 114 protocol::ConnectionToClient* connection, |
| 124 protocol::ErrorCode error) { | 115 protocol::ErrorCode error) { |
| 125 DCHECK(CalledOnValidThread()); | 116 DCHECK(CalledOnValidThread()); |
| 126 DCHECK_EQ(connection_.get(), connection); | 117 DCHECK_EQ(connection_.get(), connection); |
| 127 if (!is_authenticated_) | 118 if (!is_authenticated_) |
| 128 event_handler_->OnSessionAuthenticationFailed(this); | 119 event_handler_->OnSessionAuthenticationFailed(this); |
| 129 auth_input_filter_.set_input_stub(NULL); | 120 auth_input_filter_.set_input_stub(NULL); |
| 121 auth_clipboard_filter_.set_clipboard_stub(NULL); |
| 130 | 122 |
| 131 // Ensure that any pressed keys or buttons are released. | 123 // Ensure that any pressed keys or buttons are released. |
| 132 input_tracker_.ReleaseAll(); | 124 input_tracker_.ReleaseAll(); |
| 133 | 125 |
| 134 // TODO(sergeyu): Log failure reason? | 126 // TODO(sergeyu): Log failure reason? |
| 135 event_handler_->OnSessionClosed(this); | 127 event_handler_->OnSessionClosed(this); |
| 136 } | 128 } |
| 137 | 129 |
| 138 void ClientSession::OnSequenceNumberUpdated( | 130 void ClientSession::OnSequenceNumberUpdated( |
| 139 protocol::ConnectionToClient* connection, int64 sequence_number) { | 131 protocol::ConnectionToClient* connection, int64 sequence_number) { |
| (...skipping 24 matching lines...) Expand all Loading... |
| 164 void ClientSession::LocalMouseMoved(const SkIPoint& mouse_pos) { | 156 void ClientSession::LocalMouseMoved(const SkIPoint& mouse_pos) { |
| 165 DCHECK(CalledOnValidThread()); | 157 DCHECK(CalledOnValidThread()); |
| 166 remote_input_filter_.LocalMouseMoved(mouse_pos); | 158 remote_input_filter_.LocalMouseMoved(mouse_pos); |
| 167 } | 159 } |
| 168 | 160 |
| 169 void ClientSession::SetDisableInputs(bool disable_inputs) { | 161 void ClientSession::SetDisableInputs(bool disable_inputs) { |
| 170 DCHECK(CalledOnValidThread()); | 162 DCHECK(CalledOnValidThread()); |
| 171 | 163 |
| 172 if (disable_inputs) { | 164 if (disable_inputs) { |
| 173 disable_input_filter_.set_input_stub(NULL); | 165 disable_input_filter_.set_input_stub(NULL); |
| 166 disable_clipboard_filter_.set_clipboard_stub(NULL); |
| 174 input_tracker_.ReleaseAll(); | 167 input_tracker_.ReleaseAll(); |
| 175 } else { | 168 } else { |
| 176 disable_input_filter_.set_input_stub(&mouse_input_filter_); | 169 disable_input_filter_.set_input_stub(&mouse_input_filter_); |
| 170 disable_clipboard_filter_.set_clipboard_stub( |
| 171 clipboard_echo_filter_.host_filter()); |
| 177 } | 172 } |
| 178 } | 173 } |
| 179 | 174 |
| 180 scoped_ptr<protocol::ClipboardStub> ClientSession::CreateClipboardProxy() { | 175 scoped_ptr<protocol::ClipboardStub> ClientSession::CreateClipboardProxy() { |
| 181 DCHECK(CalledOnValidThread()); | 176 DCHECK(CalledOnValidThread()); |
| 182 | 177 |
| 183 return scoped_ptr<protocol::ClipboardStub>( | 178 return scoped_ptr<protocol::ClipboardStub>( |
| 184 new protocol::ClipboardThreadProxy( | 179 new protocol::ClipboardThreadProxy( |
| 185 client_clipboard_factory_.GetWeakPtr(), | 180 client_clipboard_factory_.GetWeakPtr(), |
| 186 base::MessageLoopProxy::current())); | 181 base::MessageLoopProxy::current())); |
| 187 } | 182 } |
| 188 | 183 |
| 189 } // namespace remoting | 184 } // namespace remoting |
| OLD | NEW |