aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/lru.h
blob: d8a692c2eb127b94ee7f4ae5ff8a91f99610ff2c (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
// Least-recently-used cache implementation.
#ifndef FISH_LRU_H
#define FISH_LRU_H

#include <assert.h>
#include <wchar.h>
#include <list>
#include <map>
#include <set>

#include "common.h"

/// A predicate to compare dereferenced pointers.
struct dereference_less_t {
    template <typename ptr_t>
    bool operator()(ptr_t p1, ptr_t p2) const {
        return *p1 < *p2;
    }
};

class lru_node_t {
    template <class T>
    friend class lru_cache_t;

    /// Our linked list pointer.
    lru_node_t *prev, *next;

   public:
    /// The key used to look up in the cache.
    const wcstring key;

    /// Constructor.
    explicit lru_node_t(const wcstring &pkey) : prev(NULL), next(NULL), key(pkey) {}

    /// Virtual destructor that does nothing for classes that inherit lru_node_t.
    virtual ~lru_node_t() {}

    /// operator< for std::set
    bool operator<(const lru_node_t &other) const { return key < other.key; }
};

template <class node_type_t>
class lru_cache_t {
   private:
    /// Max node count. This may be (transiently) exceeded by add_node_without_eviction, which is
    /// used from background threads.
    const size_t max_node_count;

    /// Count of nodes.
    size_t node_count;

    /// The set of nodes.
    typedef std::set<lru_node_t *, dereference_less_t> node_set_t;
    node_set_t node_set;

    void promote_node(node_type_t *node) {
        // We should never promote the mouth.
        assert(node != &mouth);

        // First unhook us.
        node->prev->next = node->next;
        node->next->prev = node->prev;

        // Put us after the mouth.
        node->next = mouth.next;
        node->next->prev = node;
        node->prev = &mouth;
        mouth.next = node;
    }

    void evict_node(node_type_t *condemned_node) {
        // We should never evict the mouth.
        assert(condemned_node != NULL && condemned_node != &mouth);

        // Remove it from the linked list.
        condemned_node->prev->next = condemned_node->next;
        condemned_node->next->prev = condemned_node->prev;

        // Remove us from the set.
        node_set.erase(condemned_node);
        node_count--;

        // Tell ourselves.
        this->node_was_evicted(condemned_node);
    }

    void evict_last_node(void) { evict_node((node_type_t *)mouth.prev); }

    static lru_node_t *get_previous(lru_node_t *node) { return node->prev; }

   protected:
    /// Head of the linked list.
    lru_node_t mouth;

    /// Overridable callback for when a node is evicted.
    virtual void node_was_evicted(node_type_t *node) {}

   public:
    /// Constructor
    explicit lru_cache_t(size_t max_size = 1024)
        : max_node_count(max_size), node_count(0), mouth(wcstring()) {
        // Hook up the mouth to itself: a one node circularly linked list!
        mouth.prev = mouth.next = &mouth;
    }

    /// Note that we do not evict nodes in our destructor (even though they typically need to be
    /// deleted by their creator).
    virtual ~lru_cache_t() {}

    /// Returns the node for a given key, or NULL.
    node_type_t *get_node(const wcstring &key) {
        node_type_t *result = NULL;

        // Construct a fake node as our key.
        lru_node_t node_key(key);

        // Look for it in the set.
        node_set_t::iterator iter = node_set.find(&node_key);

        // If we found a node, promote and return it.
        if (iter != node_set.end()) {
            result = static_cast<node_type_t *>(*iter);
            promote_node(result);
        }
        return result;
    }

    /// Evicts the node for a given key, returning true if a node was evicted.
    bool evict_node(const wcstring &key) {
        // Construct a fake node as our key.
        lru_node_t node_key(key);

        // Look for it in the set.
        node_set_t::iterator iter = node_set.find(&node_key);
        if (iter == node_set.end()) return false;

        // Evict the given node.
        evict_node(static_cast<node_type_t *>(*iter));
        return true;
    }

    /// Adds a node under the given key. Returns true if the node was added, false if the node was
    /// not because a node with that key is already in the set.
    bool add_node(node_type_t *node) {
        // Add our node without eviction.
        if (!this->add_node_without_eviction(node)) return false;

        while (node_count > max_node_count) evict_last_node();  // evict
        return true;
    }

    /// Adds a node under the given key without triggering eviction. Returns true if the node was
    /// added, false if the node was not because a node with that key is already in the set.
    bool add_node_without_eviction(node_type_t *node) {
        assert(node != NULL && node != &mouth);

        // Try inserting; return false if it was already in the set.
        if (!node_set.insert(node).second) return false;

        // Add the node after the mouth.
        node->next = mouth.next;
        node->next->prev = node;
        node->prev = &mouth;
        mouth.next = node;

        // Update the count. This may push us over the maximum node count.
        node_count++;
        return true;
    }

    /// Counts nodes.
    size_t size(void) { return node_count; }

    /// Evicts all nodes.
    void evict_all_nodes(void) {
        while (node_count > 0) {
            evict_last_node();
        }
    }

    /// Iterator for walking nodes, from least recently used to most.
    class iterator {
        lru_node_t *node;

       public:
        explicit iterator(lru_node_t *val) : node(val) {}
        void operator++() { node = lru_cache_t::get_previous(node); }
        void operator++(int x) { node = lru_cache_t::get_previous(node); }
        bool operator==(const iterator &other) { return node == other.node; }
        bool operator!=(const iterator &other) { return !(*this == other); }
        node_type_t *operator*() { return static_cast<node_type_t *>(node); }
    };

    iterator begin() { return iterator(mouth.prev); }
    iterator end() { return iterator(&mouth); }
};

#endif