Set the initial resolution of an RDP session to the client screen resolution if it is available.

remoting/client/chromoting_client.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "remoting/client/chromoting_client.h"
 
 #include "base/bind.h"
+#include "remoting/base/capabilities.h"
 #include "remoting/client/audio_decode_scheduler.h"
 #include "remoting/client/audio_player.h"
 #include "remoting/client/client_context.h"
 #include "remoting/client/client_user_interface.h"
 #include "remoting/client/rectangle_update_decoder.h"
 #include "remoting/proto/audio.pb.h"
 #include "remoting/proto/video.pb.h"
 #include "remoting/protocol/authentication_method.h"
 #include "remoting/protocol/connection_to_host.h"
+#include "remoting/protocol/host_stub.h"
 #include "remoting/protocol/negotiating_client_authenticator.h"
 #include "remoting/protocol/session_config.h"
 #include "remoting/protocol/transport.h"
 
 namespace remoting {
 
 using protocol::AuthenticationMethod;
 
 ChromotingClient::ChromotingClient(
     const ClientConfig& config,
     ClientContext* client_context,
     protocol::ConnectionToHost* connection,
     ClientUserInterface* user_interface,
     scoped_refptr<FrameConsumerProxy> frame_consumer,
     scoped_ptr<AudioPlayer> audio_player)
     : config_(config),
       task_runner_(client_context->main_task_runner()),
       connection_(connection),
       user_interface_(user_interface),
+      host_capabilities_received_(false),
       weak_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) {
   rectangle_decoder_ =
       new RectangleUpdateDecoder(client_context->main_task_runner(),
                                  client_context->decode_task_runner(),
                                  frame_consumer);
   audio_decode_scheduler_.reset(new AudioDecodeScheduler(
       client_context->main_task_runner(),
       client_context->audio_decode_task_runner(),
       audio_player.Pass()));
 }
@@ skipping 35 matching lines @@
 
 void ChromotingClient::OnDisconnected(const base::Closure& shutdown_task) {
   shutdown_task.Run();
 }
 
 ChromotingStats* ChromotingClient::GetStats() {
   DCHECK(task_runner_->BelongsToCurrentThread());
   return rectangle_decoder_->GetStats();
 }
 
+void ChromotingClient::SetCapabilities(
+    const protocol::Capabilities& capabilities) {
+  DCHECK(task_runner_->BelongsToCurrentThread());
+
+  // Only accept the first |protocol::Capabilities| message.
+  if (host_capabilities_received_) {
+    LOG(WARNING) << "protocol::Capabilities has been received already.";
+    return;
+  }
+
+  host_capabilities_received_ = true;
+  if (capabilities.has_capabilities())
+    host_capabilities_ = capabilities.capabilities();
+
+  VLOG(1) << "Host capabilities: " << host_capabilities_;
+
+  // Calculate the set of capabilities enabled by both client and host and pass
+  // it to the webapp.
+  user_interface_->SetCapabilities(
+      IntersectCapabilities(config_.capabilities, host_capabilities_));
+}
+
 void ChromotingClient::InjectClipboardEvent(
     const protocol::ClipboardEvent& event) {
   DCHECK(task_runner_->BelongsToCurrentThread());
+
   user_interface_->GetClipboardStub()->InjectClipboardEvent(event);
 }
 
 void ChromotingClient::SetCursorShape(
     const protocol::CursorShapeInfo& cursor_shape) {
+  DCHECK(task_runner_->BelongsToCurrentThread());
+
   user_interface_->GetCursorShapeStub()->SetCursorShape(cursor_shape);
 }
 
 void ChromotingClient::OnConnectionState(
     protocol::ConnectionToHost::State state,
     protocol::ErrorCode error) {
   DCHECK(task_runner_->BelongsToCurrentThread());
   VLOG(1) << "ChromotingClient::OnConnectionState(" << state << ")";
   if (state == protocol::ConnectionToHost::AUTHENTICATED)
     Initialize();
   user_interface_->OnConnectionState(state, error);
 }
 
 void ChromotingClient::OnConnectionReady(bool ready) {
   VLOG(1) << "ChromotingClient::OnConnectionReady(" << ready << ")";
   user_interface_->OnConnectionReady(ready);
 }
 
 void ChromotingClient::Initialize() {
   DCHECK(task_runner_->BelongsToCurrentThread());
 
   // Initialize the decoder.
   rectangle_decoder_->Initialize(connection_->config());
   if (connection_->config().is_audio_enabled())
     audio_decode_scheduler_->Initialize(connection_->config());
+
+  // Negotiate capabilities with the host.
+  if (connection_->config().SupportsCapabilities()) {
+    VLOG(1) << "Client capabilities: " << config_.capabilities;
+
+    protocol::Capabilities capabilities;
+    capabilities.set_capabilities(config_.capabilities);
+    connection_->host_stub()->SetCapabilities(capabilities);
+  } else {
+    VLOG(1) << "The host does not support any capabilities.";
+
+    host_capabilities_received_ = true;
+    user_interface_->SetCapabilities(host_capabilities_);
+  }
 }
 
 }  // namespace remoting