0

task posting v3: moving away from SequencedTaskRunnerHandle

To continue the migration away from TaskRunnerHandles, the codebase
was refactored using the following scripts:
shell script:
https://paste.googleplex.com/4673967729147904
python:
https://paste.googleplex.com/5302682490241024

This will do a few sed-like modifications, changing calls to methods of
SequencedTaskRunnerHandle to calls to methods of
SequencedTaskRunner::CurrentDefaultHandle, and swapping includes.

Bug: 1026641
AX-Relnotes: n/a.
Change-Id: I49e50a2bd1e78b00e7c067219fff96d2e0bc0b46
Reviewed-on: https://chromium-review.googlesource.com/c/chromium/src/+/3983373
Commit-Queue: Gabriel Charette <gab@chromium.org>
Owners-Override: Gabriel Charette <gab@chromium.org>
Reviewed-by: Gabriel Charette <gab@chromium.org>
Cr-Commit-Position: refs/heads/main@{#1071032}
This commit is contained in:
Sean Maher
2022-11-14 15:53:25 +00:00
committed by Gabriel Charette
parent 63c6d362fe
commit 52fa5a7f26
815 changed files with 2513 additions and 2249 deletions
android_webview/nonembedded/net
ash
cc/tiles
chrome/browser
ash
fusebox
web_applications
web_applications
chromecast
chromeos
ash
components
dbus
lacros
metrics
printing
process_proxy
services
machine_learning
system
codelabs/cpp101
components
account_manager_core
arc
intent_helper
autofill
background_fetch
browser_sync
browsing_topics
cast
cast_streaming
commerce
component_updater
cronet
download
embedder_support
enterprise
browser
exo
feed
feedback
history
image_fetcher
language
leveldb_proto
memory_pressure
metrics
mirroring
named_mojo_ipc_server
net_log
network_hints
omnibox
open_from_clipboard
optimization_guide
paint_preview
password_manager
pdf
performance_manager
permissions
policy
prefs
reporting
rlz
safe_browsing
safe_search_api
segmentation_platform
services
signin
public
storage_monitor
subresource_filter
sync
sync_bookmarks
sync_sessions
update_client
value_store
variations
viz
webapps
browser
webdata
content
browser
attribution_reporting
background_fetch
browser_context_impl.ccbrowser_main_loop.cc
buckets
cache_storage
child_process_launcher_helper.cc
code_cache
data_decoder_browsertest.cc
devtools
direct_sockets
download
file_system_access
indexed_db
interest_group
loader
media
native_io
network_context_client_base_impl.cc
payments
preloading
quota
renderer_host
service_worker
storage_service_restart_browsertest.ccstorage_service_sandbox_browsertest.cc
tracing
web_package
webauth
webid
worker_host
child
public
services
test
web_test
crypto
dbus
device
extensions/browser
fuchsia_web/webengine/browser
google_apis/gcm/engine
gpu/command_buffer/service
headless/lib/browser
ipc
media
audio
base
capture
cast
filters
fuchsia
gpu
learning
mojo
video
mojo
net
pdf
remoting
sandbox/policy/win
services
audio
cert_verifier
data_decoder
device
image_annotation
metrics
network
proxy_resolver_win
resource_coordinator
memory_instrumentation
public
cpp
memory_instrumentation
service_manager
shape_detection
tracing
viz
storage/browser
ui
weblayer/browser

@ -12,8 +12,8 @@
#include "base/memory/scoped_refptr.h"
#include "base/memory/weak_ptr.h"
#include "base/sequence_checker.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/task_traits.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "components/update_client/network.h"
namespace base {
@ -80,7 +80,7 @@ class NetworkFetcherTask {
private:
SEQUENCE_CHECKER(sequence_checker_);
scoped_refptr<base::SequencedTaskRunner> task_runner_ =
base::SequencedTaskRunnerHandle::Get();
base::SequencedTaskRunner::GetCurrentDefault();
update_client::NetworkFetcher::ResponseStartedCallback
response_started_callback_;
update_client::NetworkFetcher::ProgressCallback progress_callback_;

@ -9,7 +9,6 @@
#include "base/no_destructor.h"
#include "base/task/current_thread.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "chromeos/components/sensors/buildflags.h"
#if BUILDFLAG(USE_IIOSERVICE)
#include "ash/accelerometer/accelerometer_provider_mojo.h"
@ -126,7 +125,7 @@ void AccelerometerProviderInterface::SetECLidAngleDriverStatusForTesting(
}
AccelerometerProviderInterface::AccelerometerProviderInterface()
: ui_task_runner_(base::SequencedTaskRunnerHandle::Get()) {
: ui_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
DCHECK(base::CurrentUIThread::IsSet());
}

@ -29,11 +29,11 @@
#include "base/run_loop.h"
#include "base/scoped_observation.h"
#include "base/strings/strcat.h"
#include "base/task/sequenced_task_runner.h"
#include "base/test/bind.h"
#include "base/test/metrics/histogram_tester.h"
#include "base/test/scoped_feature_list.h"
#include "base/test/scoped_run_loop_timeout.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "build/buildflag.h"
#include "chromeos/ash/components/assistant/buildflags.h"
@ -82,7 +82,7 @@ class AmbientUiVisibilityBarrier : public AmbientUiModelObserver {
if (visibility == target_visibility_ && run_loop_quit_closure_) {
// Post task so that any existing tasks get run before WaitWithTimeout()
// completes.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, std::move(run_loop_quit_closure_));
}
}

@ -34,9 +34,9 @@
#include "base/strings/string_number_conversions.h"
#include "base/strings/string_util.h"
#include "base/system/sys_info.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "net/traffic_annotation/network_traffic_annotation.h"
#include "services/network/public/cpp/shared_url_loader_factory.h"
#include "third_party/abseil-cpp/absl/types/optional.h"
@ -315,7 +315,7 @@ void AmbientPhotoController::TryReadPhotoFromCache() {
// Try to resume normal workflow with backoff.
const base::TimeDelta delay =
resume_fetch_image_backoff_.GetTimeUntilRelease();
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&AmbientPhotoController::StartPreparingNextTopic,
weak_factory_.GetWeakPtr()),

@ -19,7 +19,7 @@
#include "base/check.h"
#include "base/containers/flat_map.h"
#include "base/location.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "ui/display/display.h"
#include "ui/display/screen.h"
#include "ui/gfx/geometry/size.h"
@ -328,7 +328,7 @@ void AmbientTopicQueue::RunPendingWaitCallbacks(WaitResult wait_result) {
for (WaitCallback& wait_cb : pending_wait_cbs_) {
// Run the callbacks asynchronously in case the callback's implementation
// invokes WaitForTopicsAvailable() again.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(wait_cb), wait_result));
}
pending_wait_cbs_.clear();

@ -36,7 +36,6 @@
#include "base/test/bind.h"
#include "base/test/scoped_run_loop_timeout.h"
#include "base/threading/scoped_blocking_call.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "chromeos/dbus/power/fake_power_manager_client.h"
#include "chromeos/dbus/power/power_manager_client.h"
@ -67,7 +66,7 @@ class TestAmbientPhotoCacheImpl : public AmbientPhotoCache {
: base::StringPrintf("test_image_%i", download_count_));
download_count_++;
// Pretend to respond asynchronously.
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE, base::BindOnce(std::move(callback), std::move(data)),
photo_download_delay_);
}
@ -76,7 +75,7 @@ class TestAmbientPhotoCacheImpl : public AmbientPhotoCache {
int cache_index,
base::OnceCallback<void(bool)> callback) override {
if (!download_data_) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), /*success=*/false));
return;
}
@ -87,7 +86,7 @@ class TestAmbientPhotoCacheImpl : public AmbientPhotoCache {
files_.insert(
std::pair<int, ::ambient::PhotoCacheEntry>(cache_index, cache_entry));
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), /*success=*/true));
}
@ -102,7 +101,7 @@ class TestAmbientPhotoCacheImpl : public AmbientPhotoCache {
decoded_image_.reset();
// Pretend to respond asynchronously.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), image));
}

@ -34,7 +34,7 @@
#include "base/check.h"
#include "base/location.h"
#include "base/logging.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "cc/metrics/frame_sequence_tracker.h"
#include "cc/paint/skottie_color_map.h"
@ -324,7 +324,7 @@ void AmbientAnimationView::AnimationCycleEnded(
// in progress. Changing translation properties of the UI while a paint
// operation is in progress results in a fatal error deep in the UI stack.
// Thus, post a task to apply jitter rather than invoking it synchronously.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&AmbientAnimationView::ApplyJitter,
weak_factory_.GetWeakPtr()));
last_jitter_timestamp_ = now;

@ -19,6 +19,7 @@
#include "ash/style/dark_light_mode_controller_impl.h"
#include "base/bind.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "components/prefs/pref_service.h"
#include "services/media_session/public/cpp/media_session_service.h"
@ -274,7 +275,7 @@ void MediaStringView::ScheduleScrolling(bool is_initial) {
if (!GetVisible())
return;
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&MediaStringView::StartScrolling,
weak_factory_.GetWeakPtr(), is_initial));
}

@ -10,7 +10,7 @@
#include "ash/app_list/model/app_list_item.h"
#include "ash/public/cpp/app_list/app_list_controller.h"
#include "base/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "ui/base/models/simple_menu_model.h"
@ -31,7 +31,7 @@ void TestAppListClient::StartZeroStateSearch(base::OnceClosure on_done,
// Simulate production behavior, which collects the results asynchronously.
// Bounce through OnZeroStateSearchDone() to count calls, so that tests can
// assert that the callback happened.
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&TestAppListClient::OnZeroStateSearchDone,
weak_factory_.GetWeakPtr(), std::move(on_done)),

@ -33,6 +33,7 @@
#include "base/metrics/histogram_functions.h"
#include "base/strings/string_util.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/services/assistant/public/cpp/features.h"
#include "components/prefs/pref_registry_simple.h"
#include "components/prefs/pref_service.h"
@ -524,7 +525,7 @@ void AssistantInteractionControllerImpl::OnSuggestionPressed(
// and destroy |suggestion| in the process. Failure to post in this case
// would cause any subsequent observers of this suggestion chip event to
// receive a deleted pointer.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&AssistantController::OpenUrl,
AssistantController::Get()->GetWeakPtr(),

@ -8,7 +8,7 @@
#include <utility>
#include <vector>
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "base/unguessable_token.h"
#include "chromeos/ash/services/assistant/public/cpp/assistant_service.h"
@ -288,7 +288,7 @@ void TestAssistantService::StartInteraction(
}
// Pretend to respond asynchronously.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&TestAssistantService::InteractionStarted,
weak_factory_.GetWeakPtr(), type, source, query));

@ -11,7 +11,7 @@
#include "base/bind.h"
#include "base/metrics/histogram_functions.h"
#include "base/ranges/algorithm.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/token.h"
#include "ui/base/clipboard/clipboard.h"
#include "ui/base/clipboard/clipboard_buffer.h"
@ -106,7 +106,7 @@ void ClipboardHistory::OnClipboardDataChanged() {
// address bar in the browser. First a short form of the URL is copied,
// followed immediately by the long-form URL.
commit_data_weak_factory_.InvalidateWeakPtrs();
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&ClipboardHistory::MaybeCommitData,
commit_data_weak_factory_.GetWeakPtr(), *clipboard_data,
@ -123,7 +123,7 @@ void ClipboardHistory::OnClipboardDataChanged() {
// debounce multiple operations through the async web clipboard API. See
// https://crbug.com/1167403.
clipboard_histogram_weak_factory_.InvalidateWeakPtrs();
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&ClipboardHistory::OnClipboardOperation,
clipboard_histogram_weak_factory_.GetWeakPtr(),
@ -142,7 +142,7 @@ void ClipboardHistory::OnClipboardDataRead() {
// debounce multiple operations through the async web clipboard API. See
// https://crbug.com/1167403.
clipboard_histogram_weak_factory_.InvalidateWeakPtrs();
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&ClipboardHistory::OnClipboardOperation,
clipboard_histogram_weak_factory_.GetWeakPtr(),

@ -35,8 +35,8 @@
#include "base/strings/utf_string_conversions.h"
#include "base/synchronization/lock.h"
#include "base/task/bind_post_task.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/threading/thread_task_runner_handle.h"
#include "base/unguessable_token.h"
#include "base/values.h"
@ -439,7 +439,7 @@ void ClipboardHistoryControllerImpl::GetHistoryValues(
base::RepeatingClosure barrier = base::BarrierClosure(
bitmaps_to_be_encoded.size(),
base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(
&ClipboardHistoryControllerImpl::GetHistoryValuesWithEncodedPNGs,
weak_ptr_factory_.GetMutableWeakPtr(), item_id_filter,
@ -587,7 +587,7 @@ bool ClipboardHistoryControllerImpl::PasteClipboardItemById(
for (const auto& item : history()->GetItems()) {
if (item.id().ToString() == item_id) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(
&ClipboardHistoryControllerImpl::PasteClipboardHistoryItem,
@ -771,7 +771,7 @@ void ClipboardHistoryControllerImpl::PasteMenuItemData(
const ClipboardHistoryItem& selected_item =
context_menu_->GetItemFromCommandId(command_id);
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&ClipboardHistoryControllerImpl::PasteClipboardHistoryItem,
weak_ptr_factory_.GetWeakPtr(), active_window,

@ -17,10 +17,10 @@
#include "base/location.h"
#include "base/run_loop.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "base/test/metrics/histogram_tester.h"
#include "base/test/repeating_test_future.h"
#include "base/test/test_future.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/unguessable_token.h"
#include "testing/gmock/include/gmock/gmock.h"
#include "testing/gtest/include/gtest/gtest.h"
@ -39,8 +39,8 @@ namespace {
void FlushMessageLoop() {
base::RunLoop run_loop;
base::SequencedTaskRunnerHandle::Get()->PostTask(FROM_HERE,
run_loop.QuitClosure());
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, run_loop.QuitClosure());
run_loop.Run();
}

@ -12,6 +12,7 @@
#include "base/bind.h"
#include "base/metrics/histogram_macros.h"
#include "base/ranges/algorithm.h"
#include "base/task/sequenced_task_runner.h"
#include "ui/accessibility/ax_enums.mojom.h"
#include "ui/base/l10n/l10n_util.h"
#include "ui/base/ui_base_types.h"
@ -233,7 +234,7 @@ void ClipboardHistoryMenuModelAdapter::RemoveMenuItemWithCommandId(
// The current selected menu item may be accessed after item deletion. So
// postpone the menu item deletion.
++item_deletion_in_progress_count_;
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&ClipboardHistoryMenuModelAdapter::RemoveItemView,
weak_ptr_factory_.GetWeakPtr(), command_id));

@ -16,6 +16,7 @@
#include "ash/test/ash_test_base.h"
#include "base/callback.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "base/test/icu_test_util.h"
#include "testing/gmock/include/gmock/gmock.h"
#include "testing/gtest/include/gtest/gtest.h"
@ -31,8 +32,8 @@ namespace {
void FlushMessageLoop() {
base::RunLoop run_loop;
base::SequencedTaskRunnerHandle::Get()->PostTask(FROM_HERE,
run_loop.QuitClosure());
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, run_loop.QuitClosure());
run_loop.Run();
}

@ -22,6 +22,7 @@
#include "base/memory/singleton.h"
#include "base/memory/weak_ptr.h"
#include "base/notreached.h"
#include "base/task/sequenced_task_runner.h"
#include "ui/aura/window_observer.h"
#include "ui/aura/window_tree_host.h"
#include "ui/wm/public/activation_client.h"
@ -86,8 +87,8 @@ class WindowActivationObserver : public wm::ActivationChangeObserver,
return;
RemoveAllObservers();
// To avoid nested-activation, here we post the task to the queue.
base::SequencedTaskRunnerHandle::Get()->PostTask(FROM_HERE,
std::move(on_activated_));
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, std::move(on_activated_));
delete this;
}

@ -15,6 +15,7 @@
#include "base/callback_helpers.h"
#include "base/notreached.h"
#include "base/scoped_multi_source_observation.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ui/frame/default_frame_header.h"
#include "components/strings/grit/components_strings.h"
#include "components/vector_icons/vector_icons.h"
@ -281,7 +282,7 @@ void ArcSplashScreenDialogView::OnWindowActivated(ActivationReason reason,
forwarding_activation_ = true;
// Forward the activation to the dialog if available.
// To avoid nested-activation, here we post the task to the queue.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(
[](base::WeakPtr<ArcSplashScreenDialogView> view) {
if (!view)

@ -12,6 +12,7 @@
#include "base/bind.h"
#include "base/check.h"
#include "base/notreached.h"
#include "base/task/sequenced_task_runner.h"
#include "components/strings/grit/components_strings.h"
#include "ui/aura/client/aura_constants.h"
#include "ui/aura/window.h"
@ -308,7 +309,7 @@ void ResizeToggleMenu::ApplyResizeCompatMode(ResizeCompatMode mode) {
auto_close_closure_.Reset(base::BindOnce(&ResizeToggleMenu::CloseBubble,
weak_ptr_factory_.GetWeakPtr()));
constexpr auto kAutoCloseDelay = base::Seconds(2);
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE, auto_close_closure_.callback(), kAutoCloseDelay);
}

@ -9,7 +9,7 @@
#include "ash/components/arc/compat_mode/metrics.h"
#include "ash/shell.h"
#include "base/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "ui/aura/window_tree_host.h"
#include "ui/events/base_event_utils.h"
@ -157,7 +157,7 @@ void TouchModeMouseRewriter::SendScrollEvent(
ui::EventTimeForNow(), 0, 0, 0, 0, 0, 0);
std::ignore = SendEvent(continuation, &fling_start_event);
} else {
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&TouchModeMouseRewriter::SendScrollEvent,
weak_ptr_factory_.GetWeakPtr(), original_event,
@ -177,7 +177,7 @@ ui::EventDispatchDetails TouchModeMouseRewriter::RewriteMouseWheelEvent(
ui::ScrollEvent fling_cancel_event(
ui::ET_SCROLL_FLING_CANCEL, event.location_f(), event.root_location_f(),
event.time_stamp(), 0, 0, 0, 0, 0, 0);
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&TouchModeMouseRewriter::SendScrollEvent,
weak_ptr_factory_.GetWeakPtr(), event, continuation));
@ -200,7 +200,7 @@ ui::EventDispatchDetails TouchModeMouseRewriter::RewriteMouseClickEvent(
}
// Schedule the release event after |kLongPressInterval|.
release_event_scheduled_ = true;
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&TouchModeMouseRewriter::SendReleaseEvent,
weak_ptr_factory_.GetWeakPtr(), event, continuation),

@ -24,6 +24,7 @@
#include "base/ranges/algorithm.h"
#include "base/strings/strcat.h"
#include "base/strings/string_util.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "chromeos/ash/components/dbus/concierge/concierge_client.h"
#include "chromeos/ash/components/dbus/session_manager/session_manager_client.h"
@ -923,7 +924,7 @@ void ArcMetricsService::OnArcStarted() {
// Post tasks to record load average.
for (size_t index = 0; index < std::size(kLoadAverageHistograms); ++index) {
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&ArcMetricsService::MeasureLoadAverage,
weak_ptr_factory_.GetWeakPtr(), index),

@ -9,7 +9,7 @@
#include "base/callback_helpers.h"
#include "base/location.h"
#include "base/run_loop.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
namespace arc {
@ -30,7 +30,7 @@ void FakePolicyInstance::OnPolicyUpdated() {}
void FakePolicyInstance::OnCommandReceived(const std::string& command,
OnCommandReceivedCallback callback) {
command_payload_ = command;
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(std::move(callback), mojom::CommandResultType::SUCCESS));
}

@ -17,7 +17,7 @@
#include "base/metrics/histogram_functions.h"
#include "base/metrics/histogram_macros.h"
#include "base/posix/eintr_wrapper.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "build/build_config.h"
#include "media/base/media_log.h"
#include "media/base/video_frame.h"
@ -400,7 +400,7 @@ void GpuArcVideoDecodeAccelerator::InitializeTask(
VLOGF(2) << "Using VideoDecoder-backed VdVideoDecodeAccelerator.";
vda_ = media::VdVideoDecodeAccelerator::Create(
base::BindRepeating(&media::VideoDecoderPipeline::Create), this,
vda_config, base::SequencedTaskRunnerHandle::Get());
vda_config, base::SequencedTaskRunner::GetCurrentDefault());
} else {
VLOGF(2) << "Using original VDA";
auto vda_factory = media::GpuVideoDecodeAcceleratorFactory::Create(

@ -6,7 +6,7 @@
#include "ash/components/phonehub/feature_status.h"
#include "base/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/components/multidevice/logging/logging.h"
#include "chromeos/ash/services/secure_channel/public/cpp/client/connection_manager.h"
@ -97,7 +97,7 @@ void ConnectionSchedulerImpl::OnFeatureStatusChanged() {
<< " seconds.";
retry_backoff_.InformOfRequest(/*succeeded=*/false);
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&ConnectionSchedulerImpl::ScheduleConnectionNow,
weak_ptr_factory_.GetWeakPtr()),

@ -14,9 +14,9 @@
#include "base/files/file.h"
#include "base/files/platform_file.h"
#include "base/logging.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "services/tracing/public/cpp/perfetto/perfetto_config.h"
#include "third_party/perfetto/include/perfetto/tracing/core/trace_config.h"
#include "third_party/perfetto/include/perfetto/tracing/tracing.h"
@ -56,7 +56,7 @@ void AshTracingHandler::Start(AshTracingRequest* request) {
? testing_perfetto_session_creator()
: perfetto::Tracing::NewTrace();
tracing_session_->Setup(perfetto_config, request->GetPlatformFile());
auto runner = base::SequencedTaskRunnerHandle::Get();
auto runner = base::SequencedTaskRunner::GetCurrentDefault();
base::WeakPtr<AshTracingHandler> weak_ptr = weak_factory_.GetWeakPtr();
tracing_session_->SetOnStartCallback([runner, weak_ptr]() {
runner->PostTask(

@ -7,7 +7,7 @@
#include "ash/keyboard/ui/test/keyboard_test_util.h"
#include "ash/shell.h"
#include "ash/wm/window_util.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "ui/aura/window.h"
#include "ui/aura/window_tree_host.h"
#include "ui/base/ime/mock_input_method.h"
@ -29,8 +29,8 @@ aura::Window* TestKeyboardUI::LoadKeyboardWindow(LoadCallback callback) {
screen->GetPrimaryDisplay().bounds()));
// Simulate an asynchronous load.
base::SequencedTaskRunnerHandle::Get()->PostTask(FROM_HERE,
std::move(callback));
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(FROM_HERE,
std::move(callback));
return keyboard_window_.get();
}

@ -7,7 +7,7 @@
#include <utility>
#include "ash/keyboard/ui/test/keyboard_test_util.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "ui/display/display.h"
#include "ui/display/screen.h"
@ -46,8 +46,8 @@ aura::Window* TestKeyboardUIFactory::TestKeyboardUI::LoadKeyboardWindow(
KeyboardBoundsFromRootBounds(screen->GetPrimaryDisplay().bounds()));
// Simulate an asynchronous load.
base::SequencedTaskRunnerHandle::Get()->PostTask(FROM_HERE,
std::move(callback));
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(FROM_HERE,
std::move(callback));
return window_.get();
}

@ -13,7 +13,7 @@
#include "base/bind.h"
#include "base/callback.h"
#include "base/check.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "third_party/abseil-cpp/absl/types/optional.h"
#include "url/gurl.h"
@ -124,14 +124,14 @@ void FakeAmbientBackendControllerImpl::FetchScreenUpdateInfo(
}
// Pretend to respond asynchronously.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), update));
}
void FakeAmbientBackendControllerImpl::GetSettings(
GetSettingsCallback callback) {
// Pretend to respond asynchronously.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), CreateFakeSettings()));
}
@ -150,7 +150,7 @@ void FakeAmbientBackendControllerImpl::FetchPersonalAlbums(
const std::string& resume_token,
OnPersonalAlbumsFetchedCallback callback) {
// Pretend to respond asynchronously.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), CreateFakeAlbums()));
}

@ -7,7 +7,7 @@
#include "ash/public/cpp/test/test_image_downloader.h"
#include "base/bind.h"
#include "base/callback.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "components/account_id/account_id.h"
#include "ui/gfx/image/image_skia.h"
#include "ui/gfx/image/image_unittest_util.h"
@ -34,7 +34,7 @@ void TestImageDownloader::Download(
DownloadCallback callback) {
last_request_headers_ = additional_headers;
// Pretend to respond asynchronously.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(std::move(callback),
should_fail_ ? gfx::ImageSkia()

@ -13,7 +13,7 @@
#include "ash/quick_pair/fast_pair_handshake/fast_pair_handshake_lookup.h"
#include "base/bind.h"
#include "base/containers/contains.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "device/bluetooth/bluetooth_adapter_factory.h"
#include "device/bluetooth/bluetooth_low_energy_scan_filter.h"
@ -72,7 +72,7 @@ void FastPairScannerImpl::Factory::SetFactoryForTesting(
FastPairScannerImpl::Factory::~Factory() = default;
FastPairScannerImpl::FastPairScannerImpl()
: task_runner_(base::SequencedTaskRunnerHandle::Get()) {
: task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
device::BluetoothAdapterFactory::Get()->GetAdapter(base::BindOnce(
&FastPairScannerImpl::OnGetAdapter, weak_ptr_factory_.GetWeakPtr()));
}

@ -17,7 +17,7 @@
#include "base/bind.h"
#include "base/command_line.h"
#include "base/metrics/histogram_macros.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "components/viz/common/frame_sinks/copy_output_request.h"
#include "components/viz/common/frame_sinks/copy_output_result.h"
@ -261,7 +261,7 @@ void ScreenRotationAnimator::RequestCopyScreenRotationContainerLayer(
copy_output_request->set_area(
gfx::Rect(screen_rotation_container_layer->size()));
copy_output_request->set_result_task_runner(
base::SequencedTaskRunnerHandle::Get());
base::SequencedTaskRunner::GetCurrentDefault());
screen_rotation_container_layer->RequestCopyOfOutput(
std::move(copy_output_request));
}

@ -21,6 +21,7 @@
#include "base/memory/ptr_util.h"
#include "base/no_destructor.h"
#include "base/ranges/algorithm.h"
#include "base/task/sequenced_task_runner.h"
namespace ash {
namespace {
@ -277,7 +278,7 @@ class HoldingSpaceAnimationRegistry::ProgressIndicatorAnimationDelegate
// Once `animation` has finished, it can be removed from the registry. Note
// that this needs to be posted as it is illegal to delete `animation` from
// its update callback sequence.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(
[](const base::WeakPtr<ProgressIndicatorAnimationDelegate>&

@ -37,6 +37,7 @@
#include "base/containers/cxx20_erase.h"
#include "base/pickle.h"
#include "base/ranges/algorithm.h"
#include "base/task/sequenced_task_runner.h"
#include "components/prefs/pref_change_registrar.h"
#include "ui/aura/client/drag_drop_client.h"
#include "ui/base/clipboard/custom_data_helper.h"
@ -668,7 +669,7 @@ void HoldingSpaceTray::OnWidgetDragWillStart(views::Widget* widget) {
// items so as not to obstruct drop targets. Post the task to close the bubble
// so that we don't attempt to destroy the bubble widget before the associated
// drag event has been fully initialized.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&HoldingSpaceTray::CloseBubble,
weak_factory_.GetWeakPtr()));
}

@ -22,6 +22,7 @@
#include "base/containers/contains.h"
#include "base/containers/cxx20_erase_vector.h"
#include "base/memory/weak_ptr.h"
#include "base/task/sequenced_task_runner.h"
#include "net/base/mime_util.h"
#include "ui/accessibility/ax_action_data.h"
#include "ui/accessibility/ax_enums.mojom.h"
@ -788,7 +789,7 @@ void HoldingSpaceViewDelegate::OpenItemsAndScheduleClose(
DCHECK_GE(views.size(), 1u);
// This `PostTask()` will result in the destruction of the view delegate if it
// has not already been destroyed.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(
[](const base::WeakPtr<HoldingSpaceViewDelegate>& weak_ptr) {

@ -32,6 +32,7 @@
#include "ash/system/tray/tray_utils.h"
#include "base/bind.h"
#include "base/callback_helpers.h"
#include "base/task/sequenced_task_runner.h"
#include "ui/base/l10n/l10n_util.h"
#include "ui/base/resource/resource_bundle.h"
#include "ui/events/event.h"
@ -324,7 +325,7 @@ void PhoneHubTray::UpdateVisibility() {
}
void PhoneHubTray::TemporarilyDisableAnimation() {
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE, DisableShowAnimation().Release(), base::Seconds(5));
}

@ -11,7 +11,7 @@
#include "ash/system/progress_indicator/progress_indicator_animation_registry.h"
#include "ash/system/progress_indicator/progress_ring_animation.h"
#include "base/scoped_observation.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "third_party/skia/include/core/SkPath.h"
#include "third_party/skia/include/core/SkPathBuilder.h"
#include "third_party/skia/include/core/SkPathMeasure.h"
@ -183,7 +183,7 @@ class DefaultProgressIndicatorAnimationRegistry
// On completion, `animation` can be removed from the registry. This cannot
// be done directly from `animation`'s subscription callback, so post a task
// to delete `animation` as soon as possible.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(
[](const base::WeakPtr<DefaultProgressIndicatorAnimationRegistry>&

@ -4,7 +4,7 @@
#include "ash/system/progress_indicator/progress_indicator_animation.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "ui/compositor/scoped_animation_duration_scale_mode.h"
#include "ui/gfx/animation/slide_animation.h"
@ -57,7 +57,7 @@ void ProgressIndicatorAnimation::AnimationEnded(
// immediately. Otherwise the animation will loop endlessly without providing
// other code an opportunity to run.
if (ui::ScopedAnimationDurationScaleMode::duration_multiplier() == 0.f) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&ProgressIndicatorAnimation::StartInternal,
weak_factory_.GetWeakPtr(), /*is_cyclic_restart=*/true));

@ -34,6 +34,7 @@
#include "base/functional/callback_helpers.h"
#include "base/metrics/histogram_functions.h"
#include "base/scoped_multi_source_observation.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "ui/accessibility/ax_node_data.h"
#include "ui/aura/window.h"
@ -209,8 +210,8 @@ class TrayBackgroundView::TrayBackgroundViewSessionChangeHandler
// in the current task sequence are run.
void DisableShowAnimationInSequence() {
base::ScopedClosureRunner callback = tray_->DisableShowAnimation();
base::SequencedTaskRunnerHandle::Get()->PostTask(FROM_HERE,
callback.Release());
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, callback.Release());
}
TrayBackgroundView* const tray_;

@ -5,7 +5,7 @@
#include "ash/test/test_ash_web_view.h"
#include "base/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "ui/views/view.h"
namespace ash {
@ -37,7 +37,7 @@ void TestAshWebView::Navigate(const GURL& url) {
// Simulate navigation by notifying |observers_| of the expected event that
// would normally signal navigation completion. We do this asynchronously to
// more accurately simulate real-world conditions.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(
[](const base::WeakPtr<TestAshWebView>& self) {
if (self) {

@ -14,7 +14,7 @@
#include "base/logging.h"
#include "base/ranges/algorithm.h"
#include "base/strings/string_piece.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
namespace ash {
namespace {
@ -167,12 +167,12 @@ void OnlineWallpaperVariantInfoFetcher::FetchOnlineWallpaper(
NOTREACHED() << "No suitable wallpaper for "
<< (mode == ColorMode::kDarkMode ? "dark" : "lite")
<< " mode in collection";
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), absl::nullopt));
return;
}
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(
std::move(callback),

@ -9,6 +9,7 @@
#include "base/command_line.h"
#include "base/memory/ptr_util.h"
#include "base/task/bind_post_task.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/thread_task_runner_handle.h"
#include "chromeos/services/machine_learning/public/cpp/service_connection.h"
#include "components/device_event_log/device_event_log.h"
@ -168,7 +169,7 @@ void DocumentScannerServiceClient::LoadDocumentScanner() {
} else if (IsEnabledOnDlc()) {
DocumentScannerInstaller::GetInstance()->RegisterLibraryPathCallback(
base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(
&DocumentScannerServiceClient::LoadDocumentScannerInternal,
weak_ptr_factory_.GetWeakPtr())));

@ -5,7 +5,7 @@
#include "ash/webui/eche_app_ui/eche_connection_scheduler_impl.h"
#include "base/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/components/multidevice/logging/logging.h"
namespace ash {
@ -121,7 +121,7 @@ void EcheConnectionSchedulerImpl::ScheduleConnectionIfNeeded() {
<< " seconds.";
retry_backoff_.InformOfRequest(/*succeeded=*/false);
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&EcheConnectionSchedulerImpl::ScheduleConnectionNow,
weak_ptr_factory_.GetWeakPtr()),

@ -17,6 +17,7 @@
#include "base/cxx17_backports.h"
#include "base/logging.h"
#include "base/strings/string_number_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "components/viz/common/frame_sinks/copy_output_request.h"
#include "third_party/skia/include/core/SkColor.h"
#include "ui/aura/window.h"
@ -82,7 +83,7 @@ void TakeScreenshot(
std::move(on_screenshot_taken));
screenshot_request->set_area(request_bounds);
screenshot_request->set_result_task_runner(
base::SequencedTaskRunnerHandle::Get());
base::SequencedTaskRunner::GetCurrentDefault());
screenshot_layer->RequestCopyOfOutput(std::move(screenshot_request));
}

@ -11,8 +11,8 @@
#include "base/callback_helpers.h"
#include "base/run_loop.h"
#include "base/synchronization/condition_variable.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/threading/simple_thread.h"
#include "base/threading/thread_checker_impl.h"
#include "base/threading/thread_restrictions.h"
@ -190,7 +190,8 @@ DrawImage CreateBitmapDrawImage(gfx::Size size) {
class ImageControllerTest : public testing::Test {
public:
ImageControllerTest() : task_runner_(base::SequencedTaskRunnerHandle::Get()) {
ImageControllerTest()
: task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
image_ = CreateDiscardableDrawImage(gfx::Size(1, 1));
}
~ImageControllerTest() override = default;

@ -210,7 +210,7 @@ void RunMkDirCallback(
storage::FileSystemOperation::GET_METADATA_FIELD_LAST_MODIFIED;
auto outer_callback = base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&RunMkDirAndThenStatCallback, std::move(callback),
fs_context, read_only));
@ -500,7 +500,7 @@ void Server::MkDir(const fusebox_staging::MkDirRequestProto& request_proto,
}
auto outer_callback = base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&RunMkDirCallback, std::move(callback), common.fs_context,
common.fs_url, common.read_only));
@ -632,7 +632,7 @@ void Server::RmDir(const fusebox_staging::RmDirRequestProto& request_proto,
}
auto outer_callback =
base::BindPostTask(base::SequencedTaskRunnerHandle::Get(),
base::BindPostTask(base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&RunRmDirCallback, std::move(callback),
common.fs_context));

@ -404,8 +404,9 @@ void ChromeCameraAppUIDelegate::MaybeTriggerSurvey() {
void ChromeCameraAppUIDelegate::StartStorageMonitor(
base::RepeatingCallback<void(StorageMonitorStatus)> monitor_callback) {
auto monitor_callback_on_current_thread = base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(), monitor_callback, FROM_HERE);
auto monitor_callback_on_current_thread =
base::BindPostTask(base::SequencedTaskRunner::GetCurrentDefault(),
monitor_callback, FROM_HERE);
auto monitor_path = GetMyFilesFolder();
storage_task_runner_->PostTask(
FROM_HERE,

@ -10,8 +10,8 @@
#include "base/functional/callback_forward.h"
#include "base/functional/callback_helpers.h"
#include "base/strings/string_number_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "chrome/browser/web_applications/locks/app_lock.h"
#include "chrome/browser/web_applications/locks/full_system_lock.h"
#include "chrome/browser/web_applications/locks/lock.h"
@ -233,7 +233,7 @@ std::unique_ptr<AppLockDescription> WebAppLockManager::UpgradeAndAcquireLock(
// posted async. https://crbug.com/1354312
auto posted_callback = base::BindOnce(
base::IgnoreResult(&base::TaskRunner::PostTask),
base::SequencedTaskRunnerHandle::Get(), FROM_HERE,
base::SequencedTaskRunner::GetCurrentDefault(), FROM_HERE,
base::BindOnce(std::move(on_lock_acquired), std::move(result_lock)));
lock_manager_.AcquireLocks(GetAppIdLocks(app_ids),
result_lock_description->holder_->AsWeakPtr(),

@ -11,12 +11,12 @@
#include "base/callback.h"
#include "base/location.h"
#include "base/task/bind_post_task.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/thread_task_runner_handle.h"
// Helpers for using base::BindPostTask() with the TaskRunner for the current
// sequence, ie. base::SequencedTaskRunnerHandle::Get(), or current thread, ie,
// base::ThreadTaskRunnerHandle::Get().
// sequence, ie. base::SequencedTaskRunner::GetCurrentDefault(), or current
// thread, ie, base::ThreadTaskRunnerHandle::Get().
namespace chromecast {
template <typename T>
@ -39,7 +39,7 @@ template <typename T>
base::OnceCallback<T> BindToCurrentSequence(
base::OnceCallback<T> callback,
const base::Location& location = FROM_HERE) {
return base::BindPostTask(base::SequencedTaskRunnerHandle::Get(),
return base::BindPostTask(base::SequencedTaskRunner::GetCurrentDefault(),
std::move(callback), location);
}
@ -47,7 +47,7 @@ template <typename T>
base::RepeatingCallback<T> BindToCurrentSequence(
base::RepeatingCallback<T> callback,
const base::Location& location = FROM_HERE) {
return base::BindPostTask(base::SequencedTaskRunnerHandle::Get(),
return base::BindPostTask(base::SequencedTaskRunner::GetCurrentDefault(),
std::move(callback), location);
}

@ -12,7 +12,7 @@
#include "base/containers/flat_map.h"
#include "base/memory/ref_counted.h"
#include "base/no_destructor.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "base/values.h"
@ -151,7 +151,7 @@ class CastMetricsHelper {
// |tick_clock| just provided for unit test to construct; normally it should
// be nullptr when accessed through GetInstance.
CastMetricsHelper(scoped_refptr<base::SequencedTaskRunner> task_runner =
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
const base::TickClock* tick_clock = nullptr);
virtual ~CastMetricsHelper();

@ -115,7 +115,6 @@
#include "base/sequence_checker.h"
#include "base/synchronization/lock.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
namespace chromecast {
@ -216,8 +215,8 @@ class ObservableInternals
const T& AddObserver(Observer<T>* observer) {
DCHECK(observer);
DCHECK(base::SequencedTaskRunnerHandle::IsSet());
auto task_runner = base::SequencedTaskRunnerHandle::Get();
DCHECK(base::SequencedTaskRunner::HasCurrentDefault());
auto task_runner = base::SequencedTaskRunner::GetCurrentDefault();
base::AutoLock lock(lock_);
auto it = per_sequence_.begin();
@ -234,8 +233,8 @@ class ObservableInternals
void RemoveObserver(Observer<T>* observer) {
DCHECK(observer);
DCHECK(base::SequencedTaskRunnerHandle::IsSet());
auto task_runner = base::SequencedTaskRunnerHandle::Get();
DCHECK(base::SequencedTaskRunner::HasCurrentDefault());
auto task_runner = base::SequencedTaskRunner::GetCurrentDefault();
base::AutoLock lock(lock_);
for (size_t i = 0; i < per_sequence_.size(); ++i) {

@ -15,7 +15,6 @@
#include "base/posix/unix_domain_socket.h"
#include "base/task/bind_post_task.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/timer/timer.h"
#include "chromecast/media/audio/audio_io_thread.h"
#include "chromecast/media/audio/audio_output_service/constants.h"
@ -140,7 +139,7 @@ AudioSocketBroker::AudioSocketBroker(
const std::string& audio_output_service_path)
: DocumentService(render_frame_host, std::move(receiver)),
audio_output_service_path_(audio_output_service_path),
main_task_runner_(base::SequencedTaskRunnerHandle::Get()) {}
main_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {}
AudioSocketBroker::~AudioSocketBroker() = default;

@ -586,7 +586,7 @@ base::OnceClosure CastContentBrowserClient::SelectClientCertificate(
base::Unretained(this), requesting_url, session_id,
web_contents->GetPrimaryMainFrame()->GetProcess()->GetID(),
web_contents->GetPrimaryMainFrame()->GetRoutingID(),
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(
&content::ClientCertificateDelegate::ContinueWithCertificate,
base::Owned(delegate.release()))));

@ -12,7 +12,7 @@
#include "base/no_destructor.h"
#include "base/ranges/algorithm.h"
#include "base/strings/utf_string_conversions.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/trace_event/trace_event.h"
#include "base/values.h"
#include "chromecast/base/cast_features.h"
@ -154,7 +154,7 @@ CastWebContentsImpl::CastWebContentsImpl(content::WebContents* web_contents,
stop_notified_(false),
notifying_(false),
last_error_(net::OK),
task_runner_(base::SequencedTaskRunnerHandle::Get()),
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
weak_factory_(this) {
DCHECK(web_contents_);
DCHECK(web_contents_->GetController().IsInitialNavigation());

@ -14,7 +14,6 @@
#include "base/logging.h"
#include "base/notreached.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "chromecast/browser/cast_web_view_default.h"
#include "chromecast/browser/cast_web_view_factory.h"
@ -49,7 +48,7 @@ CastWebService::CastWebService(content::BrowserContext* browser_context,
override_web_view_factory_(nullptr),
overlay_renderer_cache_(
std::make_unique<LRURendererCache>(browser_context_, 1)),
task_runner_(base::SequencedTaskRunnerHandle::Get()),
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
weak_factory_(this) {
DCHECK(browser_context_);
DCHECK(task_runner_);

@ -8,7 +8,7 @@
#include "base/bind.h"
#include "base/logging.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chromecast/browser/renderer_prelauncher.h"
#include "content/public/browser/site_instance.h"
@ -81,7 +81,7 @@ void LRURendererCache::ReleaseRendererPrelauncher(const GURL& page_url) {
// the prior site (which is in the process of being released) has completed
// destruction; otherwise, its renderer process will overlap with the next
// pre-launched process, temporarily exceeding |max_renderers_|.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&LRURendererCache::StartNextPrelauncher,
weak_factory_.GetWeakPtr(), page_url));
}

@ -13,7 +13,7 @@
#include "base/metrics/sparse_histogram.h"
#include "base/metrics/user_metrics.h"
#include "base/notreached.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "base/values.h"
#include "chromecast/base/metrics/cast_histograms.h"
@ -73,7 +73,7 @@ void CastRuntimeMetricsRecorder::RecordSimpleActionWithValue(
CastRuntimeMetricsRecorder::CastRuntimeMetricsRecorder(
EventBuilderFactory* event_builder_factory)
: task_runner_(base::SequencedTaskRunnerHandle::Get()),
: task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
event_builder_factory_(event_builder_factory) {
DCHECK(event_builder_factory_);

@ -8,7 +8,7 @@
#include "base/logging.h"
#include "base/task/bind_post_task.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chromecast/cast_core/runtime/browser/message_port_handler.h"
namespace chromecast {
@ -16,7 +16,7 @@ namespace chromecast {
MessagePortServiceGrpc::MessagePortServiceGrpc(
cast::v2::CoreMessagePortApplicationServiceStub* core_app_stub)
: core_app_stub_(core_app_stub),
task_runner_(base::SequencedTaskRunnerHandle::Get()) {
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
DCHECK(core_app_stub_);
}

@ -6,7 +6,7 @@
#include "base/notreached.h"
#include "base/ranges/algorithm.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chromecast/browser/cast_content_window.h"
#include "chromecast/browser/cast_web_contents.h"
#include "chromecast/common/feature_constants.h"
@ -24,7 +24,7 @@ RuntimeApplicationBase::RuntimeApplicationBase(
cast_receiver::ApplicationClient& application_client)
: cast_session_id_(std::move(cast_session_id)),
app_config_(std::move(app_config)),
task_runner_(base::SequencedTaskRunnerHandle::Get()),
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
application_client_(application_client) {
DCHECK(task_runner_);
}

@ -8,7 +8,7 @@
#include "base/command_line.h"
#include "base/logging.h"
#include "base/task/bind_post_task.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "chromecast/browser/cast_web_service.h"
#include "chromecast/cast_core/cast_core_switches.h"
@ -34,7 +34,7 @@ RuntimeServiceImpl::RuntimeServiceImpl(
: Base(application_client),
runtime_id_(std::move(runtime_id)),
runtime_service_endpoint_(std::move(runtime_service_endpoint)),
task_runner_(base::SequencedTaskRunnerHandle::Get()),
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
web_service_(web_service),
metrics_recorder_(this) {
heartbeat_timer_.SetTaskRunner(task_runner_);

@ -12,8 +12,8 @@
#include "base/memory/ref_counted.h"
#include "base/memory/scoped_refptr.h"
#include "base/synchronization/lock.h"
#include "base/task/sequenced_task_runner.h"
#include "base/thread_annotations.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "chromecast/external_mojo/broker_service/broker_service.h"
#include "chromecast/external_mojo/external_service_support/external_service.h"
@ -48,7 +48,7 @@ class ExternalConnectorImpl::BrokerConnection
public:
explicit BrokerConnection(std::string broker_path)
: broker_path_(std::move(broker_path)),
task_runner_(base::SequencedTaskRunnerHandle::Get()) {
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
Connect();
}
@ -251,7 +251,7 @@ void ExternalConnectorImpl::BindInterface(
std::move(interface_pipe));
return;
}
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&ExternalConnectorImpl::BindInterfaceImmediately,
weak_factory_.GetWeakPtr(), service_name, interface_name,

@ -14,7 +14,6 @@
#include "base/synchronization/lock.h"
#include "base/task/sequenced_task_runner.h"
#include "base/thread_annotations.h"
#include "base/threading/sequenced_task_runner_handle.h"
namespace logging {
@ -69,7 +68,7 @@ class AudioLogMessage::BufferManager {
return;
}
task_runner_ = base::SequencedTaskRunnerHandle::Get();
task_runner_ = base::SequencedTaskRunner::GetCurrentDefault();
dispose_callback_ = base::BindRepeating(
&BufferManager::HandleDisposedBuffers, base::Unretained(this));

@ -11,7 +11,7 @@
#include "base/check.h"
#include "base/location.h"
#include "base/logging.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "chromecast/media/audio/audio_output_service/output_socket.h"
#include "chromecast/net/socket_util.h"
@ -85,7 +85,7 @@ void OutputConnection::HandleConnectResult(int result) {
return;
}
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&OutputConnection::Connect, weak_factory_.GetWeakPtr()),
delay);

@ -9,6 +9,7 @@
#include "base/check.h"
#include "base/logging.h"
#include "base/memory/weak_ptr.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/single_thread_task_runner.h"
#include "base/time/time.h"
#include "base/timer/timer.h"
@ -71,7 +72,8 @@ class AudioOutputServiceReceiver::Stream
pushed_eos_ = false;
cma_audio_.reset(new audio_output_service::CmaBackendShim(
weak_factory_.GetWeakPtr(), base::SequencedTaskRunnerHandle::Get(),
weak_factory_.GetWeakPtr(),
base::SequencedTaskRunner::GetCurrentDefault(),
receiver_->media_task_runner(), message.backend_params(),
receiver_->cma_backend_factory(), receiver_->connector()));
}
@ -195,7 +197,7 @@ class AudioOutputServiceReceiver::Stream
void ResetConnection() {
// Reset will cause the deletion of |this|, so it is better to post a task.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&Stream::OnAudioPlaybackError,
weak_factory_.GetWeakPtr()));
}

@ -11,7 +11,7 @@
#include "base/logging.h"
#include "base/notreached.h"
#include "base/numerics/ranges.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "chromecast/media/audio/audio_io_thread.h"
#include "chromecast/media/audio/audio_output_service/audio_output_service.pb.h"
@ -89,7 +89,7 @@ void CastAudioRenderer::Initialize(::media::DemuxerStream* stream,
DCHECK(!init_cb_);
DCHECK(!application_media_info_manager_remote_);
main_task_runner_ = base::SequencedTaskRunnerHandle::Get();
main_task_runner_ = base::SequencedTaskRunner::GetCurrentDefault();
init_cb_ = std::move(init_cb);
demuxer_stream_ = stream;

@ -12,7 +12,6 @@
#include "base/location.h"
#include "base/logging.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "chromecast/base/chromecast_switches.h"
#include "chromecast/media/audio/mixer_service/constants.h"
@ -94,7 +93,7 @@ void MixerConnection::ConnectCallback(int result) {
}
connecting_socket_.reset();
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&MixerConnection::Connect, weak_factory_.GetWeakPtr()),
delay);
@ -111,7 +110,7 @@ void MixerConnection::ConnectTimeout() {
}
connecting_socket_.reset();
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&MixerConnection::Connect, weak_factory_.GetWeakPtr()));
}

@ -14,7 +14,6 @@
#include "base/no_destructor.h"
#include "base/synchronization/lock.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "chromecast/base/chromecast_switches.h"
#include "chromecast/media/audio/mixer_service/constants.h"
#include "chromecast/media/audio/mixer_service/mixer_socket.h"
@ -127,7 +126,7 @@ class Receiver::InitialSocket : public MixerSocket::Delegate {
};
Receiver::Receiver()
: task_runner_(base::SequencedTaskRunnerHandle::Get()),
: task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
socket_service_(
GetEndpoint(),
GetSwitchValueNonNegativeInt(switches::kMixerServicePort,
@ -147,8 +146,9 @@ std::unique_ptr<MixerSocket> Receiver::LocalConnect() {
auto receiver_socket = std::make_unique<MixerSocket>();
auto caller_socket = std::make_unique<MixerSocket>();
receiver_socket->SetLocalCounterpart(caller_socket->GetWeakPtr(),
base::SequencedTaskRunnerHandle::Get());
receiver_socket->SetLocalCounterpart(
caller_socket->GetWeakPtr(),
base::SequencedTaskRunner::GetCurrentDefault());
caller_socket->SetLocalCounterpart(receiver_socket->GetWeakPtr(),
task_runner_);

@ -10,7 +10,7 @@
#include "base/location.h"
#include "base/logging.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "base/timer/timer.h"
#include "chromecast/media/audio/mixer_service/mixer_socket.h"
@ -85,7 +85,8 @@ class ReceiverCma::Stream : public MixerSocket::Delegate,
pushed_eos_ = false;
cma_audio_.reset(new mixer_service::CmaBackendShim(
weak_factory_.GetWeakPtr(), base::SequencedTaskRunnerHandle::Get(),
weak_factory_.GetWeakPtr(),
base::SequencedTaskRunner::GetCurrentDefault(),
message.output_stream_params(), receiver_->backend_manager()));
}

@ -7,7 +7,6 @@
#include "base/logging.h"
#include "base/notreached.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "net/base/address_list.h"
#include "net/base/ip_address.h"
#include "net/base/ip_endpoint.h"
@ -42,7 +41,7 @@ AudioSocketService::AudioSocketService(const std::string& endpoint,
: max_accept_loop_(max_accept_loop),
use_socket_descriptor_(false),
delegate_(delegate),
task_runner_(base::SequencedTaskRunnerHandle::Get()) {
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
DCHECK_GT(max_accept_loop_, 0);
DCHECK(delegate_);

@ -17,7 +17,6 @@
#include "base/posix/safe_strerror.h"
#include "base/posix/unix_domain_socket.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "chromecast/net/socket_util.h"
#include "net/base/net_errors.h"
#include "net/socket/stream_socket.h"
@ -54,7 +53,7 @@ AudioSocketService::AudioSocketService(const std::string& endpoint,
: max_accept_loop_(max_accept_loop),
use_socket_descriptor_(use_socket_descriptor),
delegate_(delegate),
task_runner_(base::SequencedTaskRunnerHandle::Get()) {
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
DCHECK_GT(max_accept_loop_, 0);
DCHECK(delegate_);

@ -14,7 +14,6 @@
#include "base/logging.h"
#include "base/strings/pattern.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "chromecast/media/audio/audio_fader.h"
#include "chromecast/media/audio/audio_log.h"
#include "chromecast/media/audio/mixer_service/mixer_service_transport.pb.h"
@ -304,7 +303,7 @@ AudioOutputRedirector::AudioOutputRedirector(
output_channel_layout_(
GetMediaChannelLayout(config_.output_channel_layout,
config_.num_output_channels)),
io_task_runner_(base::SequencedTaskRunnerHandle::Get()),
io_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
buffer_pool_(
base::MakeRefCounted<IOBufferPool>(kDefaultBufferSize,
std::numeric_limits<size_t>::max(),

@ -6,7 +6,7 @@
#include <utility>
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chromecast/media/audio/mixer_service/mixer_socket.h"
#include "chromecast/media/cma/backend/mixer/loopback_handler.h"
#include "chromecast/media/cma/backend/mixer/mixer_loopback_connection.h"
@ -28,10 +28,12 @@ std::unique_ptr<mixer_service::MixerSocket> CreateLoopbackConnectionForTest(
auto receiver_socket = std::make_unique<mixer_service::MixerSocket>();
auto caller_socket = std::make_unique<mixer_service::MixerSocket>();
receiver_socket->SetLocalCounterpart(caller_socket->GetWeakPtr(),
base::SequencedTaskRunnerHandle::Get());
caller_socket->SetLocalCounterpart(receiver_socket->GetWeakPtr(),
base::SequencedTaskRunnerHandle::Get());
receiver_socket->SetLocalCounterpart(
caller_socket->GetWeakPtr(),
base::SequencedTaskRunner::GetCurrentDefault());
caller_socket->SetLocalCounterpart(
receiver_socket->GetWeakPtr(),
base::SequencedTaskRunner::GetCurrentDefault());
auto mixer_side =
std::make_unique<MixerLoopbackConnection>(std::move(receiver_socket));

@ -5,8 +5,8 @@
#include "chromecast/media/gpu/cast_gpu_factory_impl.h"
#include "base/check.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/single_thread_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "chromecast/mojo/remote_interfaces.h"
#include "gpu/command_buffer/client/gles2_interface.h"
#include "gpu/config/gpu_info.h"
@ -154,8 +154,8 @@ bool CastGpuFactoryImpl::IsDecoderSupportKnown() {
}
void CastGpuFactoryImpl::NotifyDecoderSupportKnown(base::OnceClosure callback) {
base::SequencedTaskRunnerHandle::Get()->PostTask(FROM_HERE,
std::move(callback));
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(FROM_HERE,
std::move(callback));
}
std::unique_ptr<::media::VideoDecoder> CastGpuFactoryImpl::CreateVideoDecoder(
@ -186,8 +186,8 @@ bool CastGpuFactoryImpl::IsEncoderSupportKnown() {
}
void CastGpuFactoryImpl::NotifyEncoderSupportKnown(base::OnceClosure callback) {
base::SequencedTaskRunnerHandle::Get()->PostTask(FROM_HERE,
std::move(callback));
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(FROM_HERE,
std::move(callback));
}
std::unique_ptr<::media::VideoEncodeAccelerator>

@ -7,7 +7,6 @@
#include <utility>
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#define MAKE_SURE_ON_SEQUENCE(callback, ...) \
if (!task_runner_->RunsTasksInCurrentSequence()) { \
@ -21,7 +20,7 @@ namespace chromecast {
namespace media {
VideoGeometrySetterService::VideoGeometrySetterService()
: task_runner_(base::SequencedTaskRunnerHandle::Get()),
: task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
weak_factory_(this) {}
VideoGeometrySetterService::~VideoGeometrySetterService() {

@ -13,7 +13,7 @@
#include "base/check_op.h"
#include "base/location.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"
#include "net/socket/next_proto.h"
@ -85,7 +85,7 @@ class SocketBuffer {
}
void PostReadCallback(net::CompletionOnceCallback callback, int result) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&SocketBuffer::CallReadCallback,
weak_factory_.GetWeakPtr(),
std::move(callback), result));

@ -16,7 +16,6 @@
#include "base/check_op.h"
#include "base/location.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "chromecast/net/io_buffer_pool.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"
@ -81,7 +80,7 @@ SmallMessageSocket::SmallMessageSocket(Delegate* delegate,
std::unique_ptr<net::Socket> socket)
: delegate_(delegate),
socket_(std::move(socket)),
task_runner_(base::SequencedTaskRunnerHandle::Get()),
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
write_storage_(base::MakeRefCounted<net::GrowableIOBuffer>()),
write_buffer_(base::MakeRefCounted<BufferWrapper>()),
read_storage_(base::MakeRefCounted<net::GrowableIOBuffer>()),

@ -7,6 +7,7 @@
#include <tuple>
#include "base/check.h"
#include "base/task/sequenced_task_runner.h"
#include "content/public/renderer/render_frame.h"
#include "content/public/renderer/v8_value_converter.h"
#include "third_party/blink/public/common/browser_interface_broker_proxy.h"
@ -357,7 +358,7 @@ void CastDemoBindings::ReconnectMojo() {
void CastDemoBindings::OnMojoConnectionError() {
LOG(WARNING) << "Disconnected from Demo Mojo. Will retry every "
<< kDelayBetweenReconnectionInMillis << " milliseconds.";
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&CastDemoBindings::ReconnectMojo,
weak_factory_.GetWeakPtr()),

@ -7,7 +7,7 @@
#include "base/callback.h"
#include "base/check.h"
#include "base/logging.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
namespace chromecast {
@ -150,7 +150,7 @@ void ScreenPowerControllerAura::SetScreenPowerOn() {
}
void ScreenPowerControllerAura::SetScreenPowerOff() {
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&ScreenPowerControllerAura::OnDisplayOffTimeoutCompleted,
weak_factory_.GetWeakPtr()),
@ -172,7 +172,7 @@ void ScreenPowerControllerAura::OnScreenPoweredOn(bool succeeded) {
case PendingTask::kBrightnessOff:
// TODO(b/161268188): This can be simplified and the delays removed if
// backlight timing is handled by the kernel
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(
&ScreenPowerControllerAura::OnDisplayOnTimeoutCompleted,

@ -7,7 +7,7 @@
#include "base/callback_forward.h"
#include "base/run_loop.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "testing/gtest/include/gtest/gtest.h"
namespace ash {
@ -26,7 +26,7 @@ void CheckResult(base::OnceClosure quit,
}
// Check again in the future
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(CheckResult<T>, std::move(quit), expected_value,
value_callback),

@ -8,8 +8,8 @@
#include "base/logging.h"
#include "base/observer_list.h"
#include "base/process/process_metrics.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "chromeos/ash/components/dbus/resourced/fake_resourced_client.h"
#include "dbus/bus.h"
@ -248,7 +248,7 @@ void ResourcedClientImpl::HandleSetMemoryMarginBps(
// If Chrome startup was racing with resourced startup it's possible
// that the message was not delivered because resourced was not up yet.
// Let's redispatch the message in 30 seconds.
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&ResourcedClientImpl::SetMemoryMarginsBps,
weak_factory_.GetWeakPtr(), critical_margin,

@ -5,7 +5,7 @@
#include <utility>
#include "base/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/components/dbus/system_clock/fake_system_clock_client.h"
namespace ash {
@ -54,7 +54,7 @@ bool FakeSystemClockClient::CanSetTime() {
}
void FakeSystemClockClient::GetLastSyncInfo(GetLastSyncInfoCallback callback) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), network_synchronized_));
}
@ -66,7 +66,7 @@ void FakeSystemClockClient::WaitForServiceToBeAvailable(
return;
}
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), true));
}

@ -9,7 +9,7 @@
#include "base/bind.h"
#include "base/logging.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
namespace ash {
namespace disks {
@ -28,7 +28,7 @@ void OnMountDone(DiskMountManager* disk_mount_manager,
// Post a task to guarantee the callback isn't called inline with the
// Mount() call.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(std::move(callback), error_code, std::move(mount_point)));
}

@ -8,6 +8,7 @@
#include "base/location.h"
#include "base/logging.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/thread_restrictions.h"
#include "base/threading/thread_task_runner_handle.h"
#include "chromeos/ash/components/dbus/session_manager/session_manager_client.h"
@ -49,7 +50,7 @@ void LoginPerformer::OnAuthFailure(const AuthFailure& failure) {
<< ", error.state=" << failure.error().state();
last_login_failure_ = failure;
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&LoginPerformer::NotifyAuthFailure,
weak_factory_.GetWeakPtr(), failure));
}
@ -68,7 +69,7 @@ void LoginPerformer::OnAuthSuccess(const UserContext& user_context) {
metrics_recorder_->OnIsLoginOffline(is_login_offline);
VLOG(1) << "LoginSuccess hash: " << user_context.GetUserIDHash();
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&LoginPerformer::NotifyAuthSuccess,
weak_factory_.GetWeakPtr(), user_context));
}
@ -77,7 +78,7 @@ void LoginPerformer::OnOffTheRecordAuthSuccess() {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
metrics_recorder_->OnGuestLoignSuccess();
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&LoginPerformer::NotifyOffTheRecordAuthSuccess,
weak_factory_.GetWeakPtr()));
}
@ -87,7 +88,7 @@ void LoginPerformer::OnPasswordChangeDetected(const UserContext& user_context) {
password_changed_ = true;
password_changed_callback_count_++;
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&LoginPerformer::NotifyPasswordChangeDetected,
weak_factory_.GetWeakPtr(), user_context));
}
@ -96,7 +97,7 @@ void LoginPerformer::OnOldEncryptionDetected(const UserContext& user_context,
bool has_incomplete_migration) {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&LoginPerformer::NotifyOldEncryptionDetected,
weak_factory_.GetWeakPtr(), user_context,
has_incomplete_migration));
@ -127,7 +128,7 @@ void LoginPerformer::DoPerformLogin(const UserContext& user_context,
const AccountId& account_id = user_context.GetAccountId();
if (!IsUserAllowlisted(account_id, &wildcard_match,
user_context.GetUserType())) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&LoginPerformer::NotifyAllowlistCheckFailure,
weak_factory_.GetWeakPtr()));
return;
@ -224,7 +225,7 @@ void LoginPerformer::NotifyAuthSuccess(const UserContext& user_context) {
DCHECK(delegate_);
// After delegate_->OnAuthSuccess(...) is called, delegate_ releases
// LoginPerformer ownership. LP now manages it's lifetime on its own.
base::SequencedTaskRunnerHandle::Get()->DeleteSoon(FROM_HERE, this);
base::SequencedTaskRunner::GetCurrentDefault()->DeleteSoon(FROM_HERE, this);
delegate_->OnAuthSuccess(user_context);
}

@ -13,8 +13,8 @@
#include "base/memory/weak_ptr.h"
#include "base/strings/string_number_conversions.h"
#include "base/system/sys_info.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "chromeos/ash/components/dbus/debug_daemon/debug_daemon_client.h"
#include "third_party/abseil-cpp/absl/types/optional.h"
@ -74,7 +74,7 @@ class ZramWritebackBackendImpl : public ZramWritebackBackend {
if (!res) {
// If we did not receive a response, it's likely that debugd is not up
// yet. Let's try again in 30 seconds.
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&ZramWritebackBackendImpl::EnableWriteback,
weak_factory_.GetWeakPtr(), size_mb, std::move(cb)),

@ -14,11 +14,11 @@
#include "base/files/file_util.h"
#include "base/message_loop/message_pump_type.h"
#include "base/run_loop.h"
#include "base/task/sequenced_task_runner.h"
#include "base/test/bind.h"
#include "base/test/gmock_callback_support.h"
#include "base/test/multiprocess_test.h"
#include "base/test/task_environment.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/threading/thread.h"
#include "chromeos/ash/components/disks/disk_mount_manager.h"
#include "chromeos/ash/components/disks/mock_disk_mount_manager.h"
@ -108,7 +108,7 @@ class TestSmbFsMounter : public SmbFsMounter {
[mount_error, mount_path](
const std::string& source_path,
ash::disks::DiskMountManager::MountPathCallback callback) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(
std::move(callback), mount_error,
@ -134,7 +134,7 @@ class SmbFsMounterTest : public testing::Test {
const std::string& mount_path,
ash::MountError mount_error,
ash::disks::DiskMountManager::MountPathCallback callback) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), mount_error,
MakeMountPointInfo(source_path, mount_path)));
}
@ -562,7 +562,7 @@ class SmbFsMounterE2eTest : public testing::Test {
const std::string& source_path,
const std::string& mount_path,
ash::disks::DiskMountManager::MountPathCallback callback) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(std::move(callback), ash::MountError::kSuccess,
MakeMountPointInfo(source_path, mount_path)));
@ -681,7 +681,7 @@ TEST_F(SmbFsMounterE2eTest, MountSuccess) {
// providing a Mojo connection endpoint.
const std::string token =
source_path.substr(sizeof(kMountUrlPrefix) - 1);
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindLambdaForTesting([token, &channel]() {
mojo_bootstrap::PendingConnectionManager::Get().OpenIpcChannel(
token,

@ -8,6 +8,7 @@
#include <vector>
#include "base/bind.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/thread.h"
#include "chromeos/ash/services/assistant/audio_decoder/ipc_data_source.h"
#include "media/base/audio_bus.h"
@ -28,7 +29,7 @@ AssistantAudioDecoder::AssistantAudioDecoder(
mojo::PendingRemote<mojom::AssistantAudioDecoderClient> client,
mojo::PendingRemote<mojom::AssistantMediaDataSource> data_source)
: client_(std::move(client)),
task_runner_(base::SequencedTaskRunnerHandle::Get()),
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
data_source_(std::make_unique<IPCDataSource>(std::move(data_source))),
media_thread_(std::make_unique<base::Thread>("media_thread")),
weak_factory_(this) {

@ -9,7 +9,7 @@
#include "base/bind.h"
#include "base/ranges/algorithm.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "mojo/public/cpp/bindings/message.h"
namespace ash::assistant {
@ -17,7 +17,7 @@ namespace ash::assistant {
IPCDataSource::IPCDataSource(
mojo::PendingRemote<mojom::AssistantMediaDataSource> media_data_source)
: media_data_source_(std::move(media_data_source)),
utility_task_runner_(base::SequencedTaskRunnerHandle::Get()) {
utility_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
DETACH_FROM_THREAD(data_source_thread_checker_);
}

@ -9,6 +9,7 @@
#include "base/bind.h"
#include "base/memory/scoped_refptr.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/services/assistant/media_host.h"
#include "chromeos/ash/services/assistant/public/cpp/assistant_browser_delegate.h"
#include "chromeos/ash/services/libassistant/public/mojom/media_controller.mojom.h"
@ -36,7 +37,8 @@ const char kAudioFocusSourceName[] = "assistant";
} // namespace
AssistantMediaSession::AssistantMediaSession(MediaHost* host)
: host_(host), main_task_runner_(base::SequencedTaskRunnerHandle::Get()) {}
: host_(host),
main_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {}
AssistantMediaSession::~AssistantMediaSession() {
AbandonAudioFocusIfNeeded();

@ -20,6 +20,7 @@
#include "base/logging.h"
#include "base/metrics/histogram_functions.h"
#include "base/rand_util.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/single_thread_task_runner.h"
#include "base/time/time.h"
#include "base/timer/timer.h"
@ -193,7 +194,7 @@ Service::Service(std::unique_ptr<network::PendingSharedURLLoaderFactory>
: context_(std::make_unique<Context>(this)),
identity_manager_(identity_manager),
token_refresh_timer_(std::make_unique<base::OneShotTimer>()),
main_task_runner_(base::SequencedTaskRunnerHandle::Get()),
main_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
pending_url_loader_factory_(std::move(pending_url_loader_factory)) {
DCHECK(identity_manager_);
chromeos::PowerManagerClient* power_manager_client =

@ -4,6 +4,7 @@
#include "chromeos/ash/services/assistant/test_support/fake_service_controller.h"
#include "base/task/sequenced_task_runner.h"
#include "testing/gtest/include/gtest/gtest.h"
namespace ash::assistant {
@ -75,7 +76,7 @@ std::string FakeServiceController::gaia_id() {
void FakeServiceController::Initialize(
libassistant::mojom::BootupConfigPtr config,
mojo::PendingRemote<network::mojom::URLLoaderFactory> url_loader_factory) {
mojom_task_runner_ = base::SequencedTaskRunnerHandle::Get();
mojom_task_runner_ = base::SequencedTaskRunner::GetCurrentDefault();
libassistant_config_ = std::move(config);
authentication_tokens_ =

@ -11,7 +11,7 @@
#include "base/no_destructor.h"
#include "base/notreached.h"
#include "base/posix/eintr_wrapper.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/components/mojo_service_manager/connection.h"
#include "content/public/browser/browser_task_traits.h"
#include "content/public/browser/browser_thread.h"
@ -148,7 +148,7 @@ void DataCollector::GetTouchscreenDevices(
GetTouchscreenDevicesCallback callback) {
content::GetUIThreadTaskRunner({})->PostTask(
FROM_HERE, base::BindOnce(&GetTouchscreenDevicesOnUIThread,
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
std::move(callback)));
}

@ -55,7 +55,7 @@ ImeService::ImeService(
ImeDecoder* ime_decoder,
std::unique_ptr<FieldTrialParamsRetriever> field_trial_params_retriever)
: receiver_(this, std::move(receiver)),
main_task_runner_(base::SequencedTaskRunnerHandle::Get()),
main_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
ime_decoder_(ime_decoder),
field_trial_params_retriever_(std::move(field_trial_params_retriever)) {}

@ -14,6 +14,7 @@
#include "base/memory/weak_ptr.h"
#include "base/metrics/histogram_functions.h"
#include "base/strings/string_util.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "base/timer/timer.h"
#include "chromeos/ash/services/assistant/public/cpp/assistant_browser_delegate.h"
@ -273,7 +274,7 @@ void AudioInputImpl::HotwordStateManager::RecreateAudioInputStream() {
}
AudioInputImpl::AudioInputImpl(const absl::optional<std::string>& device_id)
: task_runner_(base::SequencedTaskRunnerHandle::Get()),
: task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
preferred_device_id_(device_id),
weak_factory_(this) {
DETACH_FROM_SEQUENCE(observer_sequence_checker_);
@ -281,7 +282,7 @@ AudioInputImpl::AudioInputImpl(const absl::optional<std::string>& device_id)
audio_capturer_ = std::make_unique<AudioCapturer>(
base::BindRepeating(&AudioInputImpl::OnCaptureDataArrived,
weak_factory_.GetWeakPtr()),
/*callback_task_runner=*/base::SequencedTaskRunnerHandle::Get());
/*callback_task_runner=*/base::SequencedTaskRunner::GetCurrentDefault());
RecreateStateManager();
if (assistant::features::IsStereoAudioInputEnabled())

@ -9,6 +9,7 @@
#include "base/bind.h"
#include "base/callback_helpers.h"
#include "base/sequence_checker.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
namespace ash::libassistant {
@ -24,7 +25,7 @@ constexpr uint32_t kMaxBytesToDecode = 512;
AudioMediaDataSource::AudioMediaDataSource(
mojo::PendingReceiver<AssistantMediaDataSource> receiver)
: receiver_(this, std::move(receiver)),
task_runner_(base::SequencedTaskRunnerHandle::Get()),
task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
weak_factory_(this) {}
AudioMediaDataSource::~AudioMediaDataSource() {

@ -11,6 +11,7 @@
#include "base/bind.h"
#include "base/memory/weak_ptr.h"
#include "base/sequence_checker.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/services/assistant/public/mojom/assistant_audio_decoder.mojom.h"
#include "chromeos/ash/services/libassistant/audio/audio_stream_handler.h"
#include "chromeos/ash/services/libassistant/public/mojom/platform_delegate.mojom.h"
@ -207,7 +208,7 @@ class AudioDecoderFactoryManagerImpl
AudioOutputProviderImpl::AudioOutputProviderImpl(const std::string& device_id)
: loop_back_input_(media::AudioDeviceDescription::kLoopbackInputDeviceId),
volume_control_impl_(),
main_task_runner_(base::SequencedTaskRunnerHandle::Get()),
main_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
device_id_(device_id),
start_audio_decoder_on_demand_(
features::IsStartAssistantAudioDecoderOnDemandEnabled()) {}

@ -5,6 +5,7 @@
#include "chromeos/ash/services/libassistant/audio/audio_stream_handler.h"
#include "base/bind.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/services/libassistant/audio/audio_media_data_source.h"
#include "mojo/public/cpp/bindings/pending_receiver.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
@ -12,7 +13,7 @@
namespace ash::libassistant {
AudioStreamHandler::AudioStreamHandler()
: main_task_runner_(base::SequencedTaskRunnerHandle::Get()),
: main_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
weak_factory_(this) {}
AudioStreamHandler::~AudioStreamHandler() {

@ -7,6 +7,7 @@
#include <utility>
#include "ash/public/mojom/assistant_volume_control.mojom.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/services/libassistant/public/mojom/platform_delegate.mojom.h"
#include "mojo/public/cpp/bindings/pending_remote.h"
#include "mojo/public/cpp/bindings/receiver.h"
@ -38,7 +39,7 @@ struct TypeConverter<AudioOutputStreamType,
namespace ash::libassistant {
VolumeControlImpl::VolumeControlImpl()
: main_task_runner_(base::SequencedTaskRunnerHandle::Get()),
: main_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
weak_factory_(this) {}
void VolumeControlImpl::Initialize(

@ -10,7 +10,7 @@
#include "base/bind.h"
#include "base/memory/scoped_refptr.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
namespace ash::libassistant {
@ -94,7 +94,7 @@ base::OnceCallback<void(Args...)> BindToCurrentSequence(
base::BindOnce(std::move(callback), std::forward<Args>(args)...));
}
},
std::move(callback), base::SequencedTaskRunnerHandle::Get());
std::move(callback), base::SequencedTaskRunner::GetCurrentDefault());
}
// Binds a method call to the current sequence, meaning we ensure |callback|
@ -116,7 +116,7 @@ base::RepeatingCallback<void(Args...)> BindToCurrentSequenceRepeating(
base::BindRepeating(callback, std::forward<Args>(args)...));
}
},
callback, base::SequencedTaskRunnerHandle::Get());
callback, base::SequencedTaskRunner::GetCurrentDefault());
}
// Binds a method call to the current sequence.

@ -8,8 +8,8 @@
#include "base/sequence_checker.h"
#include "base/strings/string_number_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "base/thread_annotations.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "chromeos/ash/services/assistant/public/cpp/features.h"
#include "chromeos/ash/services/libassistant/grpc/assistant_client.h"
#include "chromeos/ash/services/libassistant/public/mojom/conversation_controller.mojom.h"
@ -204,7 +204,7 @@ ConversationController::ConversationController()
std::make_unique<chromeos::assistant::action::CrosActionModule>(
assistant::features::IsAppSupportEnabled(),
assistant::features::IsWaitSchedulingEnabled())),
mojom_task_runner_(base::SequencedTaskRunnerHandle::Get()) {
mojom_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
action_module_->AddObserver(this);
}

@ -4,6 +4,7 @@
#include "chromeos/ash/services/libassistant/conversation_state_listener_impl.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/services/assistant/public/cpp/assistant_enums.h"
#include "chromeos/ash/services/libassistant/audio_input_controller.h"
#include "chromeos/ash/services/libassistant/grpc/assistant_client.h"
@ -34,7 +35,7 @@ ConversationStateListenerImpl::ConversationStateListenerImpl(
: speech_recognition_observers_(*speech_recognition_observers),
conversation_observers_(*conversation_observers),
audio_input_controller_(audio_input_controller),
mojom_task_runner_(base::SequencedTaskRunnerHandle::Get()) {
mojom_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {
DCHECK(speech_recognition_observers);
DCHECK(conversation_observers);
DCHECK(audio_input_controller);

@ -10,6 +10,7 @@
#include "base/containers/contains.h"
#include "base/logging.h"
#include "base/memory/weak_ptr.h"
#include "base/task/sequenced_task_runner.h"
#include "chromeos/ash/services/libassistant/grpc/assistant_client.h"
#include "chromeos/ash/services/libassistant/public/mojom/device_settings_delegate.mojom.h"
#include "chromeos/ash/services/libassistant/util.h"
@ -270,7 +271,7 @@ class BrightnessSetting : public Setting {
} // namespace
DeviceSettingsController::DeviceSettingsController()
: mojom_task_runner_(base::SequencedTaskRunnerHandle::Get()) {}
: mojom_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()) {}
DeviceSettingsController::~DeviceSettingsController() = default;
void DeviceSettingsController::Bind(

Some files were not shown because too many files have changed in this diff Show More