Commit 0b965e47 authored by Jose Lopes's avatar Jose Lopes Committed by Commit Bot

media: CastEnvironment::PostDelayedTask receives once closure.

This is part of the base::Callback migration.

Context: https://cs.chromium.org/chromium/src/docs/callback.md?rcl=9fcc3764aea8f97e9f6de4a9ee61d554e67edcda&l=40

Bug: 714018
Change-Id: I794495614c086cef21f5c9fd75fa8599bf04e1da
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/2087212
Commit-Queue: Jose Lopes <jabolopes@google.com>
Reviewed-by: default avatarYuri Wiitala <miu@chromium.org>
Reviewed-by: default avatarXiaohan Wang <xhwang@chromium.org>
Reviewed-by: default avatardanakj <danakj@chromium.org>
Cr-Commit-Position: refs/heads/master@{#747609}
parent fa963b0d
...@@ -36,9 +36,10 @@ bool CastEnvironment::PostTask(ThreadId identifier, ...@@ -36,9 +36,10 @@ bool CastEnvironment::PostTask(ThreadId identifier,
bool CastEnvironment::PostDelayedTask(ThreadId identifier, bool CastEnvironment::PostDelayedTask(ThreadId identifier,
const base::Location& from_here, const base::Location& from_here,
const base::Closure& task, base::OnceClosure task,
base::TimeDelta delay) { base::TimeDelta delay) {
return GetTaskRunner(identifier)->PostDelayedTask(from_here, task, delay); return GetTaskRunner(identifier)
->PostDelayedTask(from_here, std::move(task), delay);
} }
scoped_refptr<SingleThreadTaskRunner> CastEnvironment::GetTaskRunner( scoped_refptr<SingleThreadTaskRunner> CastEnvironment::GetTaskRunner(
......
...@@ -48,7 +48,7 @@ class CastEnvironment : public base::RefCountedThreadSafe<CastEnvironment> { ...@@ -48,7 +48,7 @@ class CastEnvironment : public base::RefCountedThreadSafe<CastEnvironment> {
bool PostDelayedTask(ThreadId identifier, bool PostDelayedTask(ThreadId identifier,
const base::Location& from_here, const base::Location& from_here,
const base::Closure& task, base::OnceClosure task,
base::TimeDelta delay); base::TimeDelta delay);
bool CurrentlyOn(ThreadId identifier); bool CurrentlyOn(ThreadId identifier);
......
...@@ -245,8 +245,9 @@ void FrameReceiver::EmitAvailableEncodedFrames() { ...@@ -245,8 +245,9 @@ void FrameReceiver::EmitAvailableEncodedFrames() {
is_waiting_for_consecutive_frame_ = true; is_waiting_for_consecutive_frame_ = true;
cast_environment_->PostDelayedTask( cast_environment_->PostDelayedTask(
CastEnvironment::MAIN, FROM_HERE, CastEnvironment::MAIN, FROM_HERE,
base::Bind(&FrameReceiver::EmitAvailableEncodedFramesAfterWaiting, base::BindOnce(
AsWeakPtr()), &FrameReceiver::EmitAvailableEncodedFramesAfterWaiting,
AsWeakPtr()),
playout_time - now); playout_time - now);
} }
return; return;
...@@ -324,7 +325,7 @@ void FrameReceiver::ScheduleNextCastMessage() { ...@@ -324,7 +325,7 @@ void FrameReceiver::ScheduleNextCastMessage() {
time_to_send, base::TimeDelta::FromMilliseconds(kMinSchedulingDelayMs)); time_to_send, base::TimeDelta::FromMilliseconds(kMinSchedulingDelayMs));
cast_environment_->PostDelayedTask( cast_environment_->PostDelayedTask(
CastEnvironment::MAIN, FROM_HERE, CastEnvironment::MAIN, FROM_HERE,
base::Bind(&FrameReceiver::SendNextCastMessage, AsWeakPtr()), base::BindOnce(&FrameReceiver::SendNextCastMessage, AsWeakPtr()),
time_to_send); time_to_send);
} }
...@@ -339,7 +340,7 @@ void FrameReceiver::ScheduleNextRtcpReport() { ...@@ -339,7 +340,7 @@ void FrameReceiver::ScheduleNextRtcpReport() {
cast_environment_->PostDelayedTask( cast_environment_->PostDelayedTask(
CastEnvironment::MAIN, FROM_HERE, CastEnvironment::MAIN, FROM_HERE,
base::Bind(&FrameReceiver::SendNextRtcpReport, AsWeakPtr()), base::BindOnce(&FrameReceiver::SendNextRtcpReport, AsWeakPtr()),
base::TimeDelta::FromMilliseconds(kRtcpReportIntervalMs)); base::TimeDelta::FromMilliseconds(kRtcpReportIntervalMs));
} }
......
...@@ -110,8 +110,8 @@ void FrameSender::ScheduleNextRtcpReport() { ...@@ -110,8 +110,8 @@ void FrameSender::ScheduleNextRtcpReport() {
cast_environment_->PostDelayedTask( cast_environment_->PostDelayedTask(
CastEnvironment::MAIN, FROM_HERE, CastEnvironment::MAIN, FROM_HERE,
base::BindRepeating(&FrameSender::SendRtcpReport, base::BindOnce(&FrameSender::SendRtcpReport, weak_factory_.GetWeakPtr(),
weak_factory_.GetWeakPtr(), true), true),
base::TimeDelta::FromMilliseconds(kRtcpReportIntervalMs)); base::TimeDelta::FromMilliseconds(kRtcpReportIntervalMs));
} }
...@@ -192,8 +192,7 @@ void FrameSender::ScheduleNextResendCheck() { ...@@ -192,8 +192,7 @@ void FrameSender::ScheduleNextResendCheck() {
time_to_next = std::max(time_to_next, kMinSchedulingDelay); time_to_next = std::max(time_to_next, kMinSchedulingDelay);
cast_environment_->PostDelayedTask( cast_environment_->PostDelayedTask(
CastEnvironment::MAIN, FROM_HERE, CastEnvironment::MAIN, FROM_HERE,
base::BindRepeating(&FrameSender::ResendCheck, base::BindOnce(&FrameSender::ResendCheck, weak_factory_.GetWeakPtr()),
weak_factory_.GetWeakPtr()),
time_to_next); time_to_next);
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment