Discharge7443/brave-core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Task posting v3 handle refactor (#16794)

Browse Source
This commit is contained in:
cdesouza-chromium
2023-01-24 12:36:37 +00:00
committed by GitHub
parent a3deea0c38
commit 428e0b7f0d
36 changed files with 84 additions and 89 deletions
Download Patch File Download Diff File Expand all files Collapse all files
browser/brave_ads/background_helper/background_helper_android.cc
+1 -1
View File
@@ -6,7 +6,7 @@
#include "brave/browser/brave_ads/background_helper/background_helper_android.h"
#include "base/functional/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/functional/callback.h"
namespace brave_ads {
browser/brave_ads/background_helper/background_helper_linux.cc
+3 -3
View File
@@ -6,7 +6,7 @@
#include "brave/browser/brave_ads/background_helper/background_helper_linux.h"
#include "base/functional/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chrome/browser/ui/browser.h"
#include "chrome/browser/ui/browser_list.h"
#include "chrome/browser/ui/browser_window.h"
@@ -43,13 +43,13 @@ bool BackgroundHelperLinux::IsForeground() const {
}
void BackgroundHelperLinux::OnBrowserSetLastActive(Browser* browser) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&BackgroundHelperLinux::TriggerOnForeground, AsWeakPtr()));
}
void BackgroundHelperLinux::OnBrowserNoLongerActive(Browser* browser) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&BackgroundHelperLinux::TriggerOnBackground, AsWeakPtr()));
}
browser/brave_wallet/external_wallets_importer.cc
+2 -2
View File
@@ -13,8 +13,8 @@
#include "base/json/json_reader.h"
#include "base/strings/utf_string_conversion_utils.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/types/cxx23_to_underlying.h"
#include "brave/browser/ethereum_remote_client/buildflags/buildflags.h"
#include "brave/components/brave_wallet/browser/password_encryptor.h"
@@ -297,7 +297,7 @@ void ExternalWalletsImporter::GetLocalStorage(
base::BindOnce(
&OnRunWithStorage,
base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&ExternalWalletsImporter::OnGetLocalStorage,
weak_ptr_factory_.GetWeakPtr(),
std::move(callback)))));
browser/ephemeral_storage/ephemeral_storage_browsertest.cc
+3 -3
View File
@@ -11,8 +11,8 @@
#include "base/path_service.h"
#include "base/strings/strcat.h"
#include "base/strings/stringprintf.h"
#include "base/task/sequenced_task_runner.h"
#include "base/test/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "brave/browser/ephemeral_storage/ephemeral_storage_tab_helper.h"
#include "brave/components/brave_shields/browser/brave_shields_util.h"
@@ -173,7 +173,7 @@ void EphemeralStorageBrowserTest::SetUpHttpsServer() {
https_server_.RegisterDefaultHandler(
base::BindRepeating(&HandleFileRequestWithCustomHeaders,
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
http_request_monitor_.AsWeakPtr(), test_data_dirs));
https_server_.AddDefaultHandlers(GetChromeTestDataDir());
content::SetupCrossSiteRedirector(&https_server_);
@@ -284,7 +284,7 @@ content::EvalJsResult EphemeralStorageBrowserTest::GetCookiesInFrame(
void EphemeralStorageBrowserTest::WaitForCleanupAfterKeepAlive() {
base::RunLoop run_loop;
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE, run_loop.QuitClosure(), base::Seconds(kKeepAliveInterval));
run_loop.Run();
}
browser/ephemeral_storage/ephemeral_storage_tab_helper.cc
+2 -2
View File
@@ -12,7 +12,7 @@
#include "base/feature_list.h"
#include "base/hash/md5.h"
#include "base/ranges/ranges.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "chrome/browser/content_settings/cookie_settings_factory.h"
#include "chrome/browser/profiles/profile.h"
#include "components/content_settings/core/browser/cookie_settings.h"
@@ -139,7 +139,7 @@ void EphemeralStorageTabHelper::CreateEphemeralStorageAreasForDomainAndURL(
// keep the ephemeral storage alive for some time to handle redirects
// including meta refresh or other page driven "redirects" that end up back
// at the original origin
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(
&EphemeralStorageTabHelper::ClearEphemeralLifetimeKeepalive,
browser/new_tab/new_tab_shows_navigation_throttle.cc
+2 -2
View File
@@ -8,7 +8,7 @@
#include <string>
#include "base/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/browser/new_tab/new_tab_shows_options.h"
#include "brave/browser/profiles/profile_util.h"
#include "chrome/browser/profiles/profile.h"
@@ -45,7 +45,7 @@ NewTabShowsNavigationThrottle::WillStartRequest() {
}
new_tab_options_url_ = brave::GetNewTabPageURL(profile);
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&NewTabShowsNavigationThrottle::LoadNewTabOptionsURL,
weak_factory_.GetWeakPtr()));
browser/permissions/permission_lifetime_manager_browsertest.cc
+4 -4
View File
@@ -13,9 +13,9 @@
#include "base/metrics/field_trial.h"
#include "base/path_service.h"
#include "base/run_loop.h"
#include "base/task/sequenced_task_runner.h"
#include "base/test/scoped_mock_time_message_loop_task_runner.h"
#include "base/test/test_mock_time_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "brave/browser/ephemeral_storage/ephemeral_storage_tab_helper.h"
#include "brave/browser/permissions/mock_permission_lifetime_prompt_factory.h"
@@ -322,7 +322,7 @@ IN_PROC_BROWSER_TEST_F(PermissionLifetimeManagerWithOriginMonitorBrowserTest,
// Permission Should be reset after the timeout
base::RunLoop run_loop;
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE, run_loop.QuitClosure(), base::Seconds(kKeepAliveInterval));
run_loop.Run();
@@ -376,7 +376,7 @@ IN_PROC_BROWSER_TEST_F(PermissionLifetimeManagerWithOriginMonitorBrowserTest,
// Permission Should be reset after the timeout
base::RunLoop run_loop;
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE, run_loop.QuitClosure(), base::Seconds(kKeepAliveInterval));
run_loop.Run();
@@ -430,7 +430,7 @@ IN_PROC_BROWSER_TEST_F(PermissionLifetimeManagerWithOriginMonitorBrowserTest,
// Permission Should be reset after the timeout
base::RunLoop run_loop;
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE, run_loop.QuitClosure(), base::Seconds(kKeepAliveInterval));
run_loop.Run();
browser/tor/brave_tor_browsertest.cc
+2 -2
View File
@@ -12,9 +12,9 @@
#include "base/process/process.h"
#include "base/process/process_iterator.h"
#include "base/run_loop.h"
#include "base/task/single_thread_task_runner.h"
#include "base/test/bind.h"
#include "base/test/thread_test_helper.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "brave/browser/brave_browser_process.h"
#include "brave/browser/tor/tor_profile_manager.h"
@@ -97,7 +97,7 @@ bool CheckComponentExists(const std::string& component_id) {
void NonBlockingDelay(const base::TimeDelta& delay) {
base::RunLoop run_loop(base::RunLoop::Type::kNestableTasksAllowed);
base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
base::SingleThreadTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE, run_loop.QuitWhenIdleClosure(), delay);
run_loop.Run();
}
browser/ui/views/crash_report_permission_ask_dialog_view.cc
+2 -2
View File
@@ -8,7 +8,7 @@
#include <utility>
#include "base/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/app/vector_icons/vector_icons.h"
#include "brave/browser/ui/color/brave_color_id.h"
#include "brave/components/constants/pref_names.h"
@@ -246,6 +246,6 @@ void CrashReportPermissionAskDialogView::OnWindowClosing() {
// On macOS, this dialog is not destroyed properly when session crashed bubble
// is launched directly.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&ScheduleSessionCrashedBubble));
}
browser/ui/views/sidebar/sidebar_items_scroll_view.cc
-1
View File
@@ -8,7 +8,6 @@
#include <string>
#include "base/bind.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "brave/app/vector_icons/vector_icons.h"
#include "brave/browser/ui/brave_browser.h"
chromium_src/components/sync_device_info/device_info_sync_bridge.cc
+3 -3
View File
@@ -35,7 +35,7 @@
#undef BRAVE_MAKE_LOCAL_DEVICE_SPECIFICS
#include "base/containers/contains.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
namespace syncer {
@@ -84,7 +84,7 @@ void DeviceInfoSyncBridge::DeleteDeviceInfo(const std::string& client_id,
DeleteSpecifics(client_id, batch.get());
batch->GetMetadataChangeList()->ClearMetadata(client_id);
CommitAndNotify(std::move(batch), /*should_notify=*/true);
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&DeviceInfoSyncBridge::OnDeviceInfoDeleted,
weak_ptr_factory_.GetWeakPtr(), client_id, 1,
@@ -98,7 +98,7 @@ void DeviceInfoSyncBridge::OnDeviceInfoDeleted(const std::string& client_id,
// Make sure the deleted device info is sent
if (change_processor()->IsEntityUnsynced(client_id) &&
attempt < kFailedAttemtpsToAckDeviceDelete) {
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&DeviceInfoSyncBridge::OnDeviceInfoDeleted,
weak_ptr_factory_.GetWeakPtr(), client_id, attempt + 1,
chromium_src/components/translate/core/browser/translate_script.cc
+2 -2
View File
@@ -8,7 +8,7 @@
#include "base/callback.h"
#include "base/strings/strcat.h"
#include "base/strings/stringprintf.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/constants/brave_services_key.h"
#include "brave/components/translate/core/common/brave_translate_constants.h"
#include "brave/components/translate/core/common/brave_translate_features.h"
@@ -45,7 +45,7 @@ GURL ChromiumTranslateScript::AddHostLocaleToUrl(const GURL& url) {
void TranslateScript::Request(RequestCallback callback, bool is_incognito) {
if (!IsBraveTranslateGoAvailable()) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), false));
return;
}
components/brave_federated/data_store_service.cc
-1
View File
@@ -10,7 +10,6 @@
#include "base/check.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequence_bound.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "brave/components/brave_federated/data_stores/async_data_store.h"
#include "brave/components/brave_federated/notification_ad_task_constants.h"
components/brave_federated/data_stores/async_data_store.cc
-1
View File
@@ -9,7 +9,6 @@
#include "base/task/sequenced_task_runner.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
namespace brave_federated {
components/brave_rewards/browser/rewards_service_impl.cc
+3 -3
View File
@@ -32,9 +32,9 @@
#include "base/strings/stringprintf.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/single_thread_task_runner.h"
#include "base/task/task_runner_util.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/time/time.h"
#include "bat/ledger/global_constants.h"
#include "bat/ledger/public/ledger_database.h"
@@ -295,7 +295,7 @@ std::vector<std::string> GetISOCountries() {
template <typename Callback, typename... Args>
void DeferCallback(base::Location location, Callback callback, Args&&... args) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
location,
base::BindOnce(std::move(callback), std::forward<Args>(args)...));
}
@@ -379,7 +379,7 @@ RewardsServiceImpl::~RewardsServiceImpl() {
}
void RewardsServiceImpl::ConnectionClosed() {
base::ThreadTaskRunnerHandle::Get()->PostDelayedTask(
base::SingleThreadTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&RewardsServiceImpl::StartLedgerProcessIfNecessary,
AsWeakPtr()),
components/brave_shields/browser/ad_block_filters_provider_manager.cc
+2 -2
View File
@@ -12,7 +12,7 @@
#include "base/barrier_callback.h"
#include "base/location.h"
#include "base/logging.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
namespace brave_shields {
@@ -75,7 +75,7 @@ void AdBlockFiltersProviderManager::LoadDATBuffer(
weak_factory_.GetWeakPtr(), std::move(cb)));
for (auto* provider : filters_providers_) {
task_tracker_.PostTask(
base::SequencedTaskRunnerHandle::Get().get(), FROM_HERE,
base::SequencedTaskRunner::GetCurrentDefault().get(), FROM_HERE,
base::BindOnce(
&AdBlockFiltersProvider::LoadDAT, provider->AsWeakPtr(),
base::BindOnce(OnDATLoaded, std::move(collect_and_merge))));
components/brave_shields/browser/ad_block_subscription_download_client.cc
+2 -2
View File
@@ -14,7 +14,7 @@
#include "base/bind.h"
#include "base/metrics/histogram_macros_local.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/brave_shields/browser/ad_block_service.h"
#include "brave/components/brave_shields/browser/ad_block_subscription_download_manager.h"
#include "brave/components/brave_shields/browser/ad_block_subscription_service_manager.h"
@@ -114,7 +114,7 @@ bool AdBlockSubscriptionDownloadClient::CanServiceRemoveDownloadedFile(
void AdBlockSubscriptionDownloadClient::GetUploadData(
const std::string& guid,
download::GetUploadDataCallback callback) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(std::move(callback), nullptr));
}
components/brave_vpn/browser/connection/brave_vpn_os_connection_api_sim.cc
+9 -9
View File
@@ -10,7 +10,7 @@
#include "base/logging.h"
#include "base/notreached.h"
#include "base/rand_util.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/time/time.h"
#include "brave/components/brave_vpn/browser/connection/brave_vpn_os_connection_api.h"
@@ -25,7 +25,7 @@ BraveVPNOSConnectionAPISim::~BraveVPNOSConnectionAPISim() = default;
void BraveVPNOSConnectionAPISim::CreateVPNConnectionImpl(
const BraveVPNConnectionInfo& info) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&BraveVPNOSConnectionAPISim::OnCreated,
weak_factory_.GetWeakPtr(), info.connection_name(), true));
@@ -42,11 +42,11 @@ void BraveVPNOSConnectionAPISim::ConnectImpl(const std::string& name) {
const bool success = base::RandInt(0, 9) > 3;
// Simulate connection success
if (success) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&BraveVPNOSConnectionAPISim::OnIsConnecting,
weak_factory_.GetWeakPtr(), name));
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&BraveVPNOSConnectionAPISim::OnConnected,
weak_factory_.GetWeakPtr(), name, true),
@@ -55,10 +55,10 @@ void BraveVPNOSConnectionAPISim::ConnectImpl(const std::string& name) {
}
// Simulate connection failure
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&BraveVPNOSConnectionAPISim::OnIsConnecting,
weak_factory_.GetWeakPtr(), name));
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&BraveVPNOSConnectionAPISim::OnConnected,
weak_factory_.GetWeakPtr(), name, false),
@@ -68,11 +68,11 @@ void BraveVPNOSConnectionAPISim::ConnectImpl(const std::string& name) {
void BraveVPNOSConnectionAPISim::DisconnectImpl(const std::string& name) {
disconnect_requested_ = true;
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&BraveVPNOSConnectionAPISim::OnIsDisconnecting,
weak_factory_.GetWeakPtr(), name));
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&BraveVPNOSConnectionAPISim::OnDisconnected,
weak_factory_.GetWeakPtr(), name, true));
}
@@ -87,7 +87,7 @@ void BraveVPNOSConnectionAPISim::Connect() {
void BraveVPNOSConnectionAPISim::RemoveVPNConnectionImpl(
const std::string& name) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&BraveVPNOSConnectionAPISim::OnRemoved,
weak_factory_.GetWeakPtr(), name, true));
}
components/brave_wayback_machine/brave_wayback_machine_tab_helper.cc
+2 -2
View File
@@ -10,7 +10,7 @@
#include "base/bind.h"
#include "base/command_line.h"
#include "base/containers/flat_set.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/brave_wayback_machine/brave_wayback_machine_delegate.h"
#include "brave/components/brave_wayback_machine/brave_wayback_machine_utils.h"
#include "brave/components/brave_wayback_machine/pref_names.h"
@@ -58,7 +58,7 @@ void BraveWaybackMachineTabHelper::DidFinishNavigation(
return;
// Create infobar in the next loop for not blocking navigation.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&BraveWaybackMachineTabHelper::CreateInfoBar,
weak_factory_.GetWeakPtr()));
}
components/child_process_monitor/child_process_monitor.cc
+2 -2
View File
@@ -24,10 +24,10 @@
#include "base/logging.h"
#include "base/process/kill.h"
#include "base/task/bind_post_task.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/single_thread_task_runner.h"
#include "base/task/task_traits.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "build/build_config.h"
namespace brave {
@@ -196,7 +196,7 @@ void ChildProcessMonitor::Start(
FROM_HERE,
base::BindOnce(
&MonitorChild, child_process_.Handle(),
base::BindPostTask(base::SequencedTaskRunnerHandle::Get(),
base::BindPostTask(base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&ChildProcessMonitor::OnChildCrash,
weak_ptr_factory_.GetWeakPtr(),
std::move(callback)))));
components/child_process_monitor/child_process_monitor_unittest.cc
+2 -2
View File
@@ -13,12 +13,12 @@
#include "base/process/kill.h"
#include "base/run_loop.h"
#include "base/task/sequenced_task_runner.h"
#include "base/test/bind.h"
#include "base/test/multiprocess_test.h"
#include "base/test/task_environment.h"
#include "base/test/test_timeouts.h"
#include "base/threading/platform_thread.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "build/build_config.h"
#include "testing/gtest/include/gtest/gtest.h"
#include "testing/multiprocess_func_list.h"
@@ -38,7 +38,7 @@ void WaitForChildTermination(base::ProcessHandle handle) {
class ChildProcessMonitorTest : public base::MultiProcessTest {
protected:
void SetUp() override {
callback_runner_ = base::SequencedTaskRunnerHandle::Get();
callback_runner_ = base::SequencedTaskRunner::GetCurrentDefault();
}
base::test::TaskEnvironment task_environment_;
components/content_settings/core/browser/brave_content_settings_pref_provider.cc
+2 -2
View File
@@ -16,7 +16,7 @@
#include "base/ranges/algorithm.h"
#include "base/strings/string_number_conversions.h"
#include "base/task/bind_post_task.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/brave_shields/common/brave_shield_constants.h"
#include "brave/components/constants/pref_names.h"
#include "brave/components/content_settings/core/browser/brave_content_settings_utils.h"
@@ -187,7 +187,7 @@ void BravePrefProvider::MigrateShieldsSettings(bool incognito) {
pref_change_registrar_.Add(
info->website_settings_info()->pref_name(),
base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindRepeating(&BravePrefProvider::EnsureNoWildcardEntries,
weak_factory_.GetWeakPtr(), content_type)));
}
components/debounce/browser/debounce_navigation_throttle.cc
+2 -2
View File
@@ -13,7 +13,7 @@
#include "base/bind.h"
#include "base/containers/contains.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/debounce/browser/debounce_service.h"
#include "brave/components/debounce/common/pref_names.h"
#include "components/user_prefs/user_prefs.h"
@@ -152,7 +152,7 @@ DebounceNavigationThrottle::MaybeRedirect() {
// technically this is a new navigation
params.redirect_chain.clear();
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(
[](base::WeakPtr<content::WebContents> web_contents,
const content::OpenURLParams& params) {
components/decentralized_dns/content/decentralized_dns_navigation_throttle.cc
+3 -3
View File
@@ -9,7 +9,7 @@
#include "base/bind.h"
#include "base/features.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/brave_wallet/common/features.h"
#include "brave/components/decentralized_dns/content/decentralized_dns_interstitial_controller_client.h"
#include "brave/components/decentralized_dns/content/decentralized_dns_opt_in_page.h"
@@ -65,7 +65,7 @@ DecentralizedDnsNavigationThrottle::WillStartRequest() {
(base::FeatureList::IsEnabled(
brave_wallet::features::kBraveWalletSnsFeature) &&
IsSnsTLD(url.host_piece()) && IsSnsResolveMethodAsk(local_state_))) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&DecentralizedDnsNavigationThrottle::ShowInterstitial,
weak_ptr_factory_.GetWeakPtr()));
@@ -80,7 +80,7 @@ DecentralizedDnsNavigationThrottle::WillFailRequest() {
auto* handle = navigation_handle();
if (handle &&
handle->GetNetErrorCode() == net::ERR_ENS_OFFCHAIN_LOOKUP_NOT_SELECTED) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&DecentralizedDnsNavigationThrottle::
ShowEnsOffchainLookupInterstitial,
weak_ptr_factory_.GetWeakPtr()));
components/ephemeral_storage/ephemeral_storage_service.cc
+2 -2
View File
@@ -7,7 +7,7 @@
#include <utility>
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/ephemeral_storage/url_storage_checker.h"
#include "components/content_settings/core/browser/host_content_settings_map.h"
#include "content/public/browser/browser_context.h"
@@ -46,7 +46,7 @@ void EphemeralStorageService::CanEnable1PESForUrl(
auto site_instance = content::SiteInstance::CreateForURL(context_, url);
auto* storage_partition = context_->GetStoragePartition(site_instance.get());
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&UrlStorageChecker::StartCheck,
base::MakeRefCounted<UrlStorageChecker>(
components/greaselion/browser/greaselion_download_service.cc
+2 -2
View File
@@ -17,9 +17,9 @@
#include "base/logging.h"
#include "base/strings/stringprintf.h"
#include "base/strings/utf_string_conversions.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/task_runner_util.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/version.h"
#include "brave/components/brave_component_updater/browser/dat_file_util.h"
#include "brave/components/brave_component_updater/browser/local_data_files_service.h"
@@ -217,7 +217,7 @@ GreaselionDownloadService::GreaselionDownloadService(
main_sequence->PostTask(FROM_HERE,
base::BindOnce(callback, error));
},
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindRepeating(
&GreaselionDownloadService::OnDevModeLocalFileChanged,
weak_factory_.GetWeakPtr()));
components/permissions/permission_lifetime_manager.cc
+2 -2
View File
@@ -11,7 +11,7 @@
#include "base/auto_reset.h"
#include "base/containers/contains.h"
#include "base/logging.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/permissions/permission_lifetime_pref_names.h"
#include "components/content_settings/core/browser/content_settings_registry.h"
#include "components/content_settings/core/browser/content_settings_utils.h"
@@ -113,7 +113,7 @@ void PermissionLifetimeManager::PermissionDecided(
// There is no any active origin with this key, so reset the permission
// right away. PostTask is required because at this point the permission
// is not stored in HostContentSettingsMap yet.
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&PermissionLifetimeManager::ResetPermission,
weak_ptr_factory_.GetWeakPtr(), content_type,
components/playlist/browser/playlist_media_file_download_manager.cc
+3 -3
View File
@@ -9,7 +9,7 @@
#include "base/files/file_path.h"
#include "base/logging.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "base/values.h"
#include "brave/components/playlist/browser/playlist_constants.h"
@@ -121,7 +121,7 @@ void PlaylistMediaFileDownloadManager::OnMediaFileReady(
current_item_.reset();
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&PlaylistMediaFileDownloadManager::TryStartingDownloadTask,
weak_factory_.GetWeakPtr()));
@@ -135,7 +135,7 @@ void PlaylistMediaFileDownloadManager::OnMediaFileGenerationFailed(
CancelCurrentDownloadingPlaylistItem();
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(&PlaylistMediaFileDownloadManager::TryStartingDownloadTask,
weak_factory_.GetWeakPtr()));
components/skus/browser/skus_context_impl.cc
+2 -2
View File
@@ -9,7 +9,7 @@
#include <utility>
#include "base/logging.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/skus/browser/pref_names.h"
#include "brave/components/skus/browser/rs/cxx/src/lib.rs.h"
#include "brave/components/skus/browser/skus_url_loader_impl.h"
@@ -100,7 +100,7 @@ void shim_scheduleWakeup(
int buffer_ms = 10;
VLOG(1) << "shim_scheduleWakeup " << (delay_ms + buffer_ms) << " ("
<< delay_ms << "ms plus " << buffer_ms << "ms buffer)";
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&OnScheduleWakeup, std::move(done), std::move(ctx)),
base::Milliseconds(delay_ms + buffer_ms));
components/skus/browser/skus_service_impl.cc
-1
View File
@@ -9,7 +9,6 @@
#include <utility>
#include "base/json/json_reader.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "brave/components/skus/browser/pref_names.h"
#include "brave/components/skus/browser/rs/cxx/src/lib.rs.h"
#include "brave/components/skus/browser/skus_context_impl.h"
components/speedreader/speedreader_rewriter_service.cc
+2 -2
View File
@@ -18,9 +18,9 @@
#include "base/strings/string_util.h"
#include "base/strings/stringprintf.h"
#include "base/task/bind_post_task.h"
#include "base/task/sequenced_task_runner.h"
#include "base/task/task_runner_util.h"
#include "base/task/thread_pool.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "brave/components/speedreader/common/features.h"
#include "brave/components/speedreader/common/url_readable_hints.h"
#include "brave/components/speedreader/rust/ffi/speedreader.h"
@@ -121,7 +121,7 @@ SpeedreaderRewriterService::SpeedreaderRewriterService()
base::BindOnce(
&CreateAndStartFilePathWatcher, stylesheet_override_path_,
base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindRepeating(&SpeedreaderRewriterService::OnFileChanged,
weak_factory_.GetWeakPtr()))),
base::BindOnce(&SpeedreaderRewriterService::OnWatcherStarted,
components/tor/tor_control.cc
+1 -2
View File
@@ -17,7 +17,6 @@
#include "base/strings/string_util.h"
#include "base/strings/stringprintf.h"
#include "base/task/sequenced_task_runner.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "net/base/io_buffer.h"
#include "net/base/net_errors.h"
#include "net/socket/tcp_client_socket.h"
@@ -88,7 +87,7 @@ static std::string escapify(const char* buf, int len) {
TorControl::TorControl(base::WeakPtr<TorControl::Delegate> delegate,
scoped_refptr<base::SequencedTaskRunner> task_runner)
: running_(false),
owner_task_runner_(base::SequencedTaskRunnerHandle::Get()),
owner_task_runner_(base::SequencedTaskRunner::GetCurrentDefault()),
io_task_runner_(task_runner),
writing_(false),
reading_(false),
components/tor/tor_launcher_factory.cc
+8 -8
View File
@@ -11,7 +11,7 @@
#include "base/bind.h"
#include "base/callback_helpers.h"
#include "base/task/bind_post_task.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "brave/components/tor/tor_file_watcher.h"
#include "brave/components/tor/tor_launcher_observer.h"
#include "brave/components/tor/tor_utils.h"
@@ -219,7 +219,7 @@ void TorLauncherFactory::OnTorLaunched(bool result, int64_t pid) {
tor::TorFileWatcher* tor_file_watcher =
new tor::TorFileWatcher(config_.tor_watch_path);
tor_file_watcher->StartWatching(base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&TorLauncherFactory::OnTorControlPrerequisitesReady,
weak_ptr_factory_.GetWeakPtr(), pid)));
}
@@ -228,11 +228,11 @@ void TorLauncherFactory::OnTorControlReady() {
DCHECK_CALLED_ON_VALID_SEQUENCE(sequence_checker_);
VLOG(2) << "TOR CONTROL: Ready!";
control_->GetVersion(
base::BindPostTask(base::SequencedTaskRunnerHandle::Get(),
base::BindPostTask(base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&TorLauncherFactory::GotVersion,
weak_ptr_factory_.GetWeakPtr())));
control_->GetSOCKSListeners(
base::BindPostTask(base::SequencedTaskRunnerHandle::Get(),
base::BindPostTask(base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&TorLauncherFactory::GotSOCKSListeners,
weak_ptr_factory_.GetWeakPtr())));
// A Circuit might have been established when Tor control is ready, in that
@@ -240,7 +240,7 @@ void TorLauncherFactory::OnTorControlReady() {
// directly as fail safe, otherwise Tor window might stuck in disconnected
// state while Tor circuit is ready.
control_->GetCircuitEstablished(base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&TorLauncherFactory::GotCircuitEstablished,
weak_ptr_factory_.GetWeakPtr())));
control_->Subscribe(tor::TorControlEvent::NETWORK_LIVENESS,
@@ -311,7 +311,7 @@ void TorLauncherFactory::OnTorControlClosed(bool was_running) {
tor::TorFileWatcher* tor_file_watcher =
new tor::TorFileWatcher(config_.tor_watch_path);
tor_file_watcher->StartWatching(base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&TorLauncherFactory::OnTorControlPrerequisitesReady,
weak_ptr_factory_.GetWeakPtr(), tor_pid_)));
}
@@ -333,7 +333,7 @@ void TorLauncherFactory::OnTorControlPrerequisitesReady(
tor::TorFileWatcher* tor_file_watcher =
new tor::TorFileWatcher(config_.tor_watch_path);
tor_file_watcher->StartWatching(base::BindPostTask(
base::SequencedTaskRunnerHandle::Get(),
base::SequencedTaskRunner::GetCurrentDefault(),
base::BindOnce(&TorLauncherFactory::OnTorControlPrerequisitesReady,
weak_ptr_factory_.GetWeakPtr(), pid)));
}
@@ -351,7 +351,7 @@ void TorLauncherFactory::DelayedRelaunchTor() {
is_connected_ = false;
KillTorProcess();
// Post delayed relaunch for control to stop
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&TorLauncherFactory::RelaunchTor,
weak_ptr_factory_.GetWeakPtr()),
components/tor/tor_tab_helper.cc
+2 -2
View File
@@ -5,7 +5,7 @@
#include "brave/components/tor/tor_tab_helper.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "content/public/browser/navigation_handle.h"
namespace tor {
@@ -31,7 +31,7 @@ void TorTabHelper::DidFinishNavigation(
// new connection or some fatal errors within tor process
if (navigation_handle->GetNetErrorCode() != net::ERR_PROXY_CONNECTION_FAILED)
return;
base::SequencedTaskRunnerHandle::Get()->PostDelayedTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostDelayedTask(
FROM_HERE,
base::BindOnce(&TorTabHelper::ReloadTab, AsWeakPtr(),
navigation_handle->GetWebContents()),
vendor/bat-native-ledger/src/bat/ledger/internal/core/test_ledger_client.cc
Vendored
+3 -3
View File
@@ -17,7 +17,7 @@
#include "base/strings/escape.h"
#include "base/strings/string_number_conversions.h"
#include "base/strings/string_util.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "net/http/http_status_code.h"
namespace ledger {
@@ -111,7 +111,7 @@ std::string TestLedgerClient::URIEncode(const std::string& value) {
void TestLedgerClient::LoadURL(mojom::UrlRequestPtr request,
client::LoadURLCallback callback) {
DCHECK(request);
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&TestLedgerClient::LoadURLAfterDelay,
weak_factory_.GetWeakPtr(), std::move(request),
std::move(callback)));
@@ -291,7 +291,7 @@ void TestLedgerClient::ReconcileStampReset() {}
void TestLedgerClient::RunDBTransaction(
mojom::DBTransactionPtr transaction,
client::RunDBTransactionCallback callback) {
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE, base::BindOnce(&TestLedgerClient::RunDBTransactionAfterDelay,
weak_factory_.GetWeakPtr(),
std::move(transaction), std::move(callback)));
vendor/bat-native-ledger/src/bat/ledger/internal/endpoints/request_for.h
Vendored
+2 -2
View File
@@ -10,7 +10,7 @@
#include <utility>
#include "base/callback.h"
#include "base/threading/sequenced_task_runner_handle.h"
#include "base/task/sequenced_task_runner.h"
#include "bat/ledger/internal/endpoints/request_builder.h"
#include "bat/ledger/internal/ledger_impl.h"
#include "bat/ledger/internal/logging/logging.h"
@@ -52,7 +52,7 @@ class RequestFor {
"Please make sure the error type of your endpoint has the "
"kFailedToCreateRequest enumerator!");
base::SequencedTaskRunnerHandle::Get()->PostTask(
base::SequencedTaskRunner::GetCurrentDefault()->PostTask(
FROM_HERE,
base::BindOnce(
std::move(callback),