// Copyright 2021 The Chromium Authors
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "ash/components/arc/memory/arc_memory_bridge.h"
#include <optional>
#include "ash/components/arc/mojom/memory.mojom-shared.h"
#include "ash/components/arc/session/arc_bridge_service.h"
#include "ash/components/arc/session/arc_service_manager.h"
#include "ash/components/arc/test/connection_holder_util.h"
#include "ash/components/arc/test/fake_memory_instance.h"
#include "base/memory/raw_ptr.h"
#include "base/test/bind.h"
#include "components/user_prefs/test/test_browser_context_with_prefs.h"
#include "content/public/test/browser_task_environment.h"
#include "testing/gtest/include/gtest/gtest.h"
namespace arc {
namespace {
class ArcMemoryBridgeTest : public testing::Test {
protected:
ArcMemoryBridgeTest() = default;
ArcMemoryBridgeTest(const ArcMemoryBridgeTest&) = delete;
ArcMemoryBridgeTest& operator=(const ArcMemoryBridgeTest&) = delete;
~ArcMemoryBridgeTest() override = default;
void SetUp() override {
bridge_ = ArcMemoryBridge::GetForBrowserContextForTesting(&context_);
// This results in ArcMemoryBridge::OnInstanceReady being called.
ArcServiceManager::Get()->arc_bridge_service()->memory()->SetInstance(
&memory_instance_);
WaitForInstanceReady(
ArcServiceManager::Get()->arc_bridge_service()->memory());
}
ArcMemoryBridge* bridge() { return bridge_; }
FakeMemoryInstance* memory_instance() { return &memory_instance_; }
private:
content::BrowserTaskEnvironment task_environment_;
ArcServiceManager arc_service_manager_;
FakeMemoryInstance memory_instance_;
user_prefs::TestBrowserContextWithPrefs context_;
raw_ptr<ArcMemoryBridge> bridge_ = nullptr;
};
TEST_F(ArcMemoryBridgeTest, ConstructDestruct) {
EXPECT_NE(nullptr, bridge());
}
// Tests that DropCaches runs the callback passed.
TEST_F(ArcMemoryBridgeTest, DropCaches) {
std::optional<bool> opt_result;
bridge()->DropCaches(base::BindLambdaForTesting(
[&opt_result](bool result) { opt_result = result; }));
ASSERT_TRUE(opt_result);
EXPECT_TRUE(*opt_result);
}
// Tests that DropCaches runs the callback with a proper result.
TEST_F(ArcMemoryBridgeTest, DropCaches_Fail) {
// Inject failure.
memory_instance()->set_drop_caches_result(false);
std::optional<bool> opt_result;
bridge()->DropCaches(base::BindLambdaForTesting(
[&opt_result](bool result) { opt_result = result; }));
ASSERT_TRUE(opt_result);
EXPECT_FALSE(*opt_result);
}
// Tests that DropCaches runs the callback with a proper result.
TEST_F(ArcMemoryBridgeTest, DropCaches_NoInstance) {
// Inject failure.
ArcServiceManager::Get()->arc_bridge_service()->memory()->CloseInstance(
memory_instance());
std::optional<bool> opt_result;
bridge()->DropCaches(base::BindLambdaForTesting(
[&opt_result](bool result) { opt_result = result; }));
ASSERT_TRUE(opt_result);
EXPECT_FALSE(*opt_result);
}
// Tests that Reclaim runs the callback with memory reclaimed from all
// processes successfully.
TEST_F(ArcMemoryBridgeTest, Reclaim_All_Success) {
memory_instance()->set_reclaim_all_result(100, 0);
std::optional<uint32_t> reclaimed_result;
std::optional<uint32_t> unreclaimed_result;
bridge()->Reclaim(
mojom::ReclaimRequest::New(mojom::ReclaimType::ALL),
base::BindLambdaForTesting([&](mojom::ReclaimResultPtr result) {
reclaimed_result = result->reclaimed;
unreclaimed_result = result->unreclaimed;
}));
ASSERT_TRUE(reclaimed_result);
EXPECT_EQ(*reclaimed_result, 100u);
ASSERT_TRUE(unreclaimed_result);
EXPECT_EQ(*unreclaimed_result, 0u);
}
// Tests that Reclaim runs the callback with memory reclaimed from some
// processes successfully.
TEST_F(ArcMemoryBridgeTest, Reclaim_Partial_Success) {
memory_instance()->set_reclaim_all_result(50, 50);
std::optional<uint32_t> reclaimed_result;
std::optional<uint32_t> unreclaimed_result;
bridge()->Reclaim(
mojom::ReclaimRequest::New(mojom::ReclaimType::ALL),
base::BindLambdaForTesting([&](mojom::ReclaimResultPtr result) {
reclaimed_result = result->reclaimed;
unreclaimed_result = result->unreclaimed;
}));
ASSERT_TRUE(reclaimed_result);
EXPECT_EQ(*reclaimed_result, 50u);
ASSERT_TRUE(unreclaimed_result);
EXPECT_EQ(*unreclaimed_result, 50u);
}
// Tests that Reclaim runs the callback with memory reclaimed from some
// processes successfully when anon pages are requested.
TEST_F(ArcMemoryBridgeTest, Reclaim_Anon_Partial_Success) {
memory_instance()->set_reclaim_anon_result(10, 10);
std::optional<uint32_t> reclaimed_result;
std::optional<uint32_t> unreclaimed_result;
bridge()->Reclaim(
mojom::ReclaimRequest::New(mojom::ReclaimType::ANON),
base::BindLambdaForTesting([&](mojom::ReclaimResultPtr result) {
reclaimed_result = result->reclaimed;
unreclaimed_result = result->unreclaimed;
}));
ASSERT_TRUE(reclaimed_result);
EXPECT_EQ(*reclaimed_result, 10u);
ASSERT_TRUE(unreclaimed_result);
EXPECT_EQ(*unreclaimed_result, 10u);
}
// Tests that Reclaim runs the callback with the instance not available.
TEST_F(ArcMemoryBridgeTest, Reclaim_NoInstance) {
// Inject failure.
ArcServiceManager::Get()->arc_bridge_service()->memory()->CloseInstance(
memory_instance());
std::optional<uint32_t> reclaimed_result;
std::optional<uint32_t> unreclaimed_result;
bridge()->Reclaim(
mojom::ReclaimRequest::New(mojom::ReclaimType::ALL),
base::BindLambdaForTesting([&](mojom::ReclaimResultPtr result) {
reclaimed_result = result->reclaimed;
unreclaimed_result = result->unreclaimed;
}));
ASSERT_TRUE(reclaimed_result);
EXPECT_EQ(*reclaimed_result, 0u);
ASSERT_TRUE(unreclaimed_result);
EXPECT_EQ(*unreclaimed_result, 0u);
}
} // namespace
} // namespace arc