aboutsummaryrefslogtreecommitdiff
path: root/cast/standalone_sender/looping_file_cast_agent.cc
diff options
context:
space:
mode:
Diffstat (limited to 'cast/standalone_sender/looping_file_cast_agent.cc')
-rw-r--r--cast/standalone_sender/looping_file_cast_agent.cc10
1 files changed, 4 insertions, 6 deletions
diff --git a/cast/standalone_sender/looping_file_cast_agent.cc b/cast/standalone_sender/looping_file_cast_agent.cc
index a7e99fdb..727941aa 100644
--- a/cast/standalone_sender/looping_file_cast_agent.cc
+++ b/cast/standalone_sender/looping_file_cast_agent.cc
@@ -24,10 +24,8 @@ using DeviceMediaPolicy = SenderSocketFactory::DeviceMediaPolicy;
LoopingFileCastAgent::LoopingFileCastAgent(TaskRunner* task_runner)
: task_runner_(task_runner) {
- router_ = MakeSerialDelete<VirtualConnectionRouter>(task_runner_,
- &connection_manager_);
message_port_ =
- MakeSerialDelete<CastSocketMessagePort>(task_runner_, router_.get());
+ MakeSerialDelete<CastSocketMessagePort>(task_runner_, &router_);
socket_factory_ =
MakeSerialDelete<SenderSocketFactory>(task_runner_, this, task_runner_);
connection_factory_ = SerialDeletePtr<TlsConnectionFactory>(
@@ -49,7 +47,7 @@ void LoopingFileCastAgent::Connect(ConnectionSettings settings) {
task_runner_->PostTask([this, policy] {
wake_lock_ = ScopedWakeLock::Create(task_runner_);
socket_factory_->Connect(connection_settings_->receiver_endpoint, policy,
- router_.get());
+ &router_);
});
}
@@ -75,7 +73,7 @@ void LoopingFileCastAgent::OnConnected(SenderSocketFactory* factory,
OSP_LOG_INFO << "Received connection from peer at: " << endpoint;
message_port_->SetSocket(socket->GetWeakPtr());
- router_->TakeSocket(this, std::move(socket));
+ router_.TakeSocket(this, std::move(socket));
CreateAndStartSession();
}
@@ -144,7 +142,7 @@ void LoopingFileCastAgent::StopCurrentSession() {
current_session_.reset();
environment_.reset();
file_sender_.reset();
- router_->CloseSocket(message_port_->GetSocketId());
+ router_.CloseSocket(message_port_->GetSocketId());
message_port_->SetSocket(nullptr);
}