| 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..9dbaff3b4da3ffe0563892bd24479f83a45d9949
|
| --- /dev/null
|
| +++ b/remoting/test/it2me_standalone_host.cc
|
| @@ -0,0 +1,100 @@
|
| +// 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/logging.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) {
|
| + DCHECK(logger);
|
| + std::cout << *logger;
|
| +}
|
| +
|
| +constexpr char kSessionJid[] = "user@domain/rest-of-jid";
|
| +
|
| +} // namespace
|
| +
|
| +using ::remoting::protocol::MockSession;
|
| +
|
| +It2MeStandaloneHost::It2MeStandaloneHost()
|
| + : context_(ChromotingHostContext::Create(
|
| + new AutoThreadTaskRunner(
|
| + message_loop_.task_runner(), run_loop_.QuitClosure()))),
|
| + main_task_runner_(context_->file_task_runner()),
|
| + factory_(main_task_runner_,
|
| + context_->video_capture_task_runner(),
|
| + context_->input_task_runner(),
|
| + context_->ui_task_runner()),
|
| + connection_(base::WrapUnique(new testing::NiceMock<MockSession>())),
|
| + session_jid_(kSessionJid),
|
| +#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
|
| + event_logger_(&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(event_logger_.audio_stub());
|
| + connection_.set_video_stub(event_logger_.video_stub());
|
| + connection_.set_client_stub(event_logger_.client_stub());
|
| + connection_.set_host_stub(event_logger_.host_stub());
|
| + connection_.set_video_encode_task_runner(
|
| + context_->video_encode_task_runner());
|
| +}
|
| +
|
| +It2MeStandaloneHost::~It2MeStandaloneHost() {}
|
| +
|
| +void It2MeStandaloneHost::Run() {
|
| + main_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, &event_logger_));
|
| +}
|
| +
|
| +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
|
|
|