Don't use barcodes in ProtocolPerfTests

remoting/host/client_session.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/host/client_session.h"
 
 #include <algorithm>
 #include <utility>
 
 #include "base/command_line.h"
@@ skipping 275 matching lines @@
   if (audio_capturer) {
     audio_stream_ = connection_->StartAudioStream(std::move(audio_capturer));
   }
 
   video_stream_->SetObserver(this);
 
   // Apply video-control parameters to the new stream.
   video_stream_->SetLosslessEncode(lossless_video_encode_);
   video_stream_->SetLosslessColor(lossless_video_color_);
 
-  // Pause capturing if necessary.
-  video_stream_->Pause(pause_video_);
+  // Pause video stream first. It's unpaused OnConnectionChannelsConnected()
+  // after all channels are connected.
+  video_stream_->Pause(true);
 }
 
 void ClientSession::OnConnectionChannelsConnected() {
   DCHECK(CalledOnValidThread());
 
   DCHECK(!channels_connected_);
   channels_connected_ = true;
 
   // Negotiate capabilities with the client.
   VLOG(1) << "Host capabilities: " << host_capabilities_;
   protocol::Capabilities capabilities;
   capabilities.set_capabilities(host_capabilities_);
   connection_->client_stub()->SetCapabilities(capabilities);
 
   // Start the event executor.
   input_injector_->Start(CreateClipboardProxy());
   SetDisableInputs(false);
 
   // Create MouseShapePump to send mouse cursor shape.
   mouse_shape_pump_.reset(
       new MouseShapePump(desktop_environment_->CreateMouseCursorMonitor(),
                          connection_->client_stub()));
 
   if (pending_video_layout_message_) {
     connection_->client_stub()->SetVideoLayout(*pending_video_layout_message_);
     pending_video_layout_message_.reset();
   }
 
+  if (video_stream_)
+    video_stream_->Pause(pause_video_);
+
   // Notify the event handler that all our channels are now connected.
   event_handler_->OnSessionChannelsConnected(this);
 }
 
 void ClientSession::OnConnectionClosed(protocol::ErrorCode error) {
   DCHECK(CalledOnValidThread());
 
   HOST_LOG << "Client disconnected: " << client_jid_ << "; error = " << error;
 
   // Ignore any further callbacks.
@@ skipping 61 matching lines @@
   DCHECK(CalledOnValidThread());
   DCHECK(desktop_environment_);
   return desktop_environment_->GetDesktopSessionId();
 }
 
 ClientSessionControl* ClientSession::session_control() {
   DCHECK(CalledOnValidThread());
   return this;
 }
 
+void ClientSession::SetEventTimestampsSourceForTests(
+    scoped_refptr<protocol::InputEventTimestampsSource>
+        event_timestamp_source) {
+  DCHECK(CalledOnValidThread());
+  video_stream_->SetEventTimestampsSource(event_timestamp_source);
+}
+
 std::unique_ptr<protocol::ClipboardStub> ClientSession::CreateClipboardProxy() {
   DCHECK(CalledOnValidThread());
-
   return base::MakeUnique<protocol::ClipboardThreadProxy>(
       client_clipboard_factory_.GetWeakPtr(),
       base::ThreadTaskRunnerHandle::Get());
 }
 
 void ClientSession::OnVideoSizeChanged(protocol::VideoStream* video_stream,
                                        const webrtc::DesktopSize& size,
                                        const webrtc::DesktopVector& dpi) {
   DCHECK(CalledOnValidThread());
 
@@ skipping 29 matching lines @@
         connection_->client_stub()->SetVideoLayout(layout);
       } else {
         pending_video_layout_message_.reset(new protocol::VideoLayout(layout));
       }
       break;
     }
   }
 }
 
 }  // namespace remoting