1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980 |
- // Copyright 2016 The Chromium Authors. All rights reserved.
- // Use of this source code is governed by a BSD-style license that can be
- // found in the LICENSE file.
- #include <memory>
- #include "base/run_loop.h"
- #include "base/task/thread_pool.h"
- #include "base/test/bind.h"
- #include "base/test/task_environment.h"
- #include "build/build_config.h"
- #include "chrome/updater/persisted_data.h"
- #include "chrome/updater/prefs.h"
- #include "chrome/updater/prefs_impl.h"
- #include "chrome/updater/registration_data.h"
- #include "chrome/updater/updater_scope.h"
- #include "components/prefs/testing_pref_service.h"
- #include "components/update_client/update_client.h"
- #include "testing/gtest/include/gtest/gtest.h"
- namespace updater {
- TEST(PrefsTest, PrefsCommitPendingWrites) {
- base::test::TaskEnvironment task_environment;
- auto pref = std::make_unique<TestingPrefServiceSimple>();
- update_client::RegisterPrefs(pref->registry());
- auto metadata = base::MakeRefCounted<PersistedData>(pref.get());
- // Writes something to prefs.
- metadata->SetBrandCode("someappid", "brand");
- EXPECT_STREQ(metadata->GetBrandCode("someappid").c_str(), "brand");
- // Tests writing to storage completes.
- PrefsCommitPendingWrites(pref.get());
- }
- TEST(PrefsTest, AcquireGlobalPrefsLock_LockThenTryLockInThreadFail) {
- base::test::TaskEnvironment task_environment;
- std::unique_ptr<ScopedPrefsLock> lock =
- AcquireGlobalPrefsLock(GetUpdaterScope(), base::Seconds(0));
- EXPECT_TRUE(lock);
- base::RunLoop run_loop;
- base::ThreadPool::PostTaskAndReplyWithResult(
- FROM_HERE, base::BindOnce([]() {
- std::unique_ptr<ScopedPrefsLock> lock =
- AcquireGlobalPrefsLock(GetUpdaterScope(), base::Seconds(0));
- return lock.get() != nullptr;
- }),
- base::OnceCallback<void(bool)>(
- base::BindLambdaForTesting([&run_loop](bool acquired_lock) {
- EXPECT_FALSE(acquired_lock);
- run_loop.Quit();
- })));
- run_loop.Run();
- }
- TEST(PrefsTest, AcquireGlobalPrefsLock_TryLockInThreadSuccess) {
- base::test::TaskEnvironment task_environment;
- base::RunLoop run_loop;
- base::ThreadPool::PostTaskAndReplyWithResult(
- FROM_HERE, base::BindOnce([]() {
- std::unique_ptr<ScopedPrefsLock> lock =
- AcquireGlobalPrefsLock(GetUpdaterScope(), base::Seconds(0));
- return lock.get() != nullptr;
- }),
- base::OnceCallback<void(bool)>(
- base::BindLambdaForTesting([&run_loop](bool acquired_lock) {
- EXPECT_TRUE(acquired_lock);
- run_loop.Quit();
- })));
- run_loop.Run();
- auto lock = AcquireGlobalPrefsLock(GetUpdaterScope(), base::Seconds(0));
- EXPECT_TRUE(lock);
- }
- } // namespace updater
|