Chromium Code Reviews| Index: remoting/test/it2me_standalone_host.cc |
| diff --git a/remoting/test/it2me_standalone_host.cc b/remoting/test/it2me_standalone_host.cc |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..edf0eb5c1bf3c77e54e8cbb038087b61df092bca |
| --- /dev/null |
| +++ b/remoting/test/it2me_standalone_host.cc |
| @@ -0,0 +1,97 @@ |
| +// Copyright 2016 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/test/it2me_standalone_host.h" |
| + |
| +#include <iostream> |
| +#include <vector> |
| + |
| +#include "base/bind.h" |
| +#include "base/location.h" |
| +#include "base/memory/ptr_util.h" |
| +#include "base/memory/ref_counted.h" |
| +#include "base/time/time.h" |
| +#include "remoting/base/auto_thread_task_runner.h" |
| +#include "remoting/host/chromoting_host_context.h" |
| +#include "remoting/host/host_extension.h" |
| +#include "remoting/protocol/pairing_registry.h" |
| +#include "remoting/protocol/protocol_mock_objects.h" |
| +#include "remoting/protocol/session_config.h" |
| + |
| +namespace remoting { |
| +namespace test { |
| + |
| +namespace { |
| + |
| +void OutputFakeConnectionEventLogger(const FakeConnectionEventLogger* logger) { |
|
joedow
2016/05/04 22:58:49
Also, why const FakeConnectionEventLogger* instead
joedow
2016/05/04 22:58:49
DCHECK(logger)?
Hzj_jie
2016/05/05 00:47:36
Done.
Hzj_jie
2016/05/05 00:47:36
Bind does not accept reference, but we do not need
|
| + std::cout << *logger; |
| +} |
| + |
| +} // namespace |
| + |
| +using ::remoting::protocol::MockSession; |
| + |
| +It2MeStandaloneHost::It2MeStandaloneHost() |
| + : context_(ChromotingHostContext::Create( |
| + new AutoThreadTaskRunner( |
| + message_loop_.task_runner(), run_loop_.QuitClosure()))), |
| + factory_(context_->file_task_runner(), |
|
joedow
2016/05/04 22:58:49
Perhaps use scoped_refptr as an alias for 'context
Hzj_jie
2016/05/05 00:47:36
Done.
|
| + context_->video_capture_task_runner(), |
| + context_->input_task_runner(), |
| + context_->ui_task_runner()), |
| + connection_(base::WrapUnique(new testing::NiceMock<MockSession>())), |
| + session_jid_("user@domain/rest-of-jid"), |
|
joedow
2016/05/04 22:58:49
Move constant ("user@domain/rest-of-jid") to anony
Hzj_jie
2016/05/05 00:47:36
Done.
|
| +#if defined(OS_LINUX) |
| + // We cannot support audio capturing for linux, since a pipe name is |
| + // needed to initialize AudioCapturerLinux. |
| + config_(protocol::SessionConfig::ForTest()), |
| +#else |
| + config_(protocol::SessionConfig::ForTestWithAudio()), |
| +#endif |
| + stubs_(&connection_) { |
| + factory_.set_enable_user_interface(false); |
| + EXPECT_CALL(*static_cast<MockSession*>(connection_.session()), jid()) |
| + .WillRepeatedly(testing::ReturnRef(session_jid_)); |
| + EXPECT_CALL(*static_cast<MockSession*>(connection_.session()), config()) |
| + .WillRepeatedly(testing::ReturnRef(*config_)); |
| + connection_.set_audio_stub(stubs_.audio_stub()); |
| + connection_.set_video_stub(stubs_.video_stub()); |
| + connection_.set_client_stub(stubs_.client_stub()); |
| + connection_.set_host_stub(stubs_.host_stub()); |
| + connection_.set_video_encode_task_runner( |
| + context_->video_encode_task_runner()); |
| +} |
| + |
| +It2MeStandaloneHost::~It2MeStandaloneHost() {} |
| + |
| +void It2MeStandaloneHost::Run() { |
| + // Must run in the same thread as |
| + // It2MeDesktopEnvironmentFactory->caller_task_runner() |
| + context_->file_task_runner()->PostTask( |
| + FROM_HERE, |
| + base::Bind(&It2MeStandaloneHost::Connect, base::Unretained(this))); |
| + run_loop_.Run(); |
| +} |
| + |
| +void It2MeStandaloneHost::StartOutputTimer() { |
| + timer_.Start(FROM_HERE, base::TimeDelta::FromSeconds(1), |
| + base::Bind(&OutputFakeConnectionEventLogger, &stubs_)); |
| +} |
| + |
| +void It2MeStandaloneHost::Connect() { |
| + session_.reset(new ClientSession( |
| + &handler_, |
| + context_->audio_task_runner(), |
| + std::unique_ptr<protocol::ConnectionToClient>(&connection_), |
| + &factory_, |
| + base::TimeDelta(), |
| + scoped_refptr<protocol::PairingRegistry>(), |
| + std::vector<HostExtension*>())); |
| + session_->OnConnectionAuthenticated(&connection_); |
| + session_->OnConnectionChannelsConnected(&connection_); |
| + session_->CreateVideoStreams(&connection_); |
| +} |
| + |
| +} // namespace test |
| +} // namespace remoting |