pytorch/test/cpp/lazy/test_cache.cpp
Alban Desmaison 0951cb513a Revert D34342689: Revert D34250357: Sync lazy_tensor_staging back to master
Test Plan: revert-hammer

Differential Revision:
D34342689

Original commit changeset: 43f6da6986f7

Original Phabricator Diff: D34250357 (69389fb542)

fbshipit-source-id: 8a3fb74877e719e9b9577b58027b4e7061a04ef0
(cherry picked from commit c749f08e7a)
2022-02-18 17:31:21 +00:00

64 lines
1.9 KiB
C++

#include <gtest/gtest.h>
#include <c10/util/Exception.h>
#include <torch/csrc/lazy/core/cache.h>
#include <torch/csrc/lazy/core/hash.h>
#include <torch/csrc/lazy/core/ir.h>
namespace torch {
namespace lazy {
class CacheNode : public Node {
public:
explicit CacheNode(const std::string& str)
: Node(OpKind(), /* num_outputs */ 1, /* hash_func */ [&](bool /*bakeInSizes*/) -> hash_t { return Hash(str); }),
str_(str) {}
~CacheNode() override = default;
const std::vector<Output>& operands() const override {
TORCH_INTERNAL_ASSERT(false, "Can't access operands of test node");
}
const Output& operand(size_t i) const override {
TORCH_INTERNAL_ASSERT(false, "Can't access operand[i] of test node");
}
private:
std::string str_;
};
TEST(CacheTest, BasicTest) {
std::shared_ptr<CacheNode> a = std::make_shared<CacheNode>("a");
std::shared_ptr<CacheNode> b = std::make_shared<CacheNode>("b");
std::shared_ptr<CacheNode> c = std::make_shared<CacheNode>("c");
Cache<hash_t, CacheNode, HashReducer> cache(2);
cache.Add(a->node_hash(), a);
EXPECT_EQ(cache.Get(a->node_hash()), a);
EXPECT_EQ(cache.Get(b->node_hash()), nullptr);
EXPECT_EQ(cache.Get(c->node_hash()), nullptr);
cache.Add(b->node_hash(), b);
EXPECT_EQ(cache.Get(a->node_hash()), a);
EXPECT_EQ(cache.Get(b->node_hash()), b);
EXPECT_EQ(cache.Get(c->node_hash()), nullptr);
cache.Add(c->node_hash(), c);
EXPECT_EQ(cache.Get(a->node_hash()), nullptr); // a has been evicted
EXPECT_EQ(cache.Get(b->node_hash()), b);
EXPECT_EQ(cache.Get(c->node_hash()), c);
cache.Erase(c->node_hash());
EXPECT_EQ(cache.Get(a->node_hash()), nullptr);
EXPECT_EQ(cache.Get(b->node_hash()), b);
EXPECT_EQ(cache.Get(c->node_hash()), nullptr); // c has been removed
cache.Clear();
EXPECT_EQ(cache.Get(a->node_hash()), nullptr);
EXPECT_EQ(cache.Get(b->node_hash()), nullptr);
EXPECT_EQ(cache.Get(c->node_hash()), nullptr);
}
} // namespace lazy
} // namespace torch