-
Notifications
You must be signed in to change notification settings - Fork 1.6k
/
Copy pathfixed_cache.h
93 lines (74 loc) · 2.05 KB
/
fixed_cache.h
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
// Copyright (c) 2017, the Dart project authors. Please see the AUTHORS file
// for details. All rights reserved. Use of this source code is governed by a
// BSD-style license that can be found in the LICENSE file.
#ifndef RUNTIME_VM_FIXED_CACHE_H_
#define RUNTIME_VM_FIXED_CACHE_H_
#include <stddef.h>
#include <stdint.h>
#include "vm/lockers.h"
namespace dart {
// A simple sorted fixed size Key-Value storage.
//
// Assumes both Key and Value are default-constructible objects.
//
// Keys must be comparable with operator<.
//
// Duplicates are not allowed - check with Lookup before insertion.
//
template <class K, class V, intptr_t kCapacity>
class FixedCache {
public:
struct Entry {
K key;
V value;
};
FixedCache() : length_(0) {}
~FixedCache() { Clear(); }
V* Lookup(K key) {
MutexLocker ml(&mutex_);
intptr_t i = LowerBound(key);
if (i != length_ && pairs_[i].key == key) return &pairs_[i].value;
return nullptr;
}
void Insert(K key, V value) {
MutexLocker ml(&mutex_);
intptr_t i = LowerBound(key);
if (length_ == kCapacity) {
length_ = kCapacity - 1;
if (i == kCapacity) i = kCapacity - 1;
}
for (intptr_t j = length_ - 1; j >= i; j--) {
pairs_[j + 1] = pairs_[j];
}
length_ += 1;
pairs_[i].key = key;
pairs_[i].value = value;
}
void Clear() {
MutexLocker ml(&mutex_);
length_ = 0;
}
private:
intptr_t LowerBound(K key) {
intptr_t low = 0, high = length_;
while (low != high) {
intptr_t mid = low + (high - low) / 2;
if (key < pairs_[mid].key) {
high = mid;
} else if (key > pairs_[mid].key) {
low = mid + 1;
} else {
low = high = mid;
}
}
return low;
}
// We protect any operation on the [FixedCache] because multiple isolates from
// the same [IsolateGroup] can access this cache concurrently (as can the GC
// when it clears it).
Mutex mutex_;
Entry pairs_[kCapacity]; // Sorted array of pairs.
intptr_t length_;
};
} // namespace dart
#endif // RUNTIME_VM_FIXED_CACHE_H_