GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/sqlitemem.cc
Date: 2026-11-01 02:41:19
Exec Total Coverage
Lines: 154 159 96.9%
Branches: 80 122 65.6%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "sqlitemem.h"
6
7 #include <cassert>
8 #include <cstddef>
9 #include <cstring>
10 #include <new>
11
12 #include "malloc_arena.h"
13 #include "util/concurrency.h"
14 #include "util/exception.h"
15 #include "util/smalloc.h"
16
17 using namespace std; // NOLINT
18
19
20 15760 void *SqliteMemoryManager::LookasideBufferArena::GetBuffer() {
21
2/2
✓ Branch 0 taken 37765 times.
✓ Branch 1 taken 135 times.
 37900 for (unsigned i = 0; i < kNoBitmaps; ++i) {
22 37765 const int bit_set = ffs(freemap_[i]);
23
2/2
✓ Branch 0 taken 15625 times.
✓ Branch 1 taken 22140 times.
 37765 if (bit_set != 0) {
24 15625 freemap_[i] &= ~(1 << (bit_set - 1)); // set bit to zero
25 15625 const int nbuffer = i * sizeof(int) * 8 + bit_set - 1;
26 15625 return reinterpret_cast<char *>(arena_) + nbuffer * kBufferSize;
27 }
28 }
29 135 return NULL;
30 }
31
32
33 5985 bool SqliteMemoryManager::LookasideBufferArena::IsEmpty() {
34
2/2
✓ Branch 0 taken 15165 times.
✓ Branch 1 taken 180 times.
 15345 for (unsigned i = 0; i < kNoBitmaps; ++i) {
35
2/2
✓ Branch 0 taken 5805 times.
✓ Branch 1 taken 9360 times.
 15165 if (~freemap_[i] != 0)
36 5805 return false;
37 }
38 180 return true;
39 }
40
41
42 15760 bool SqliteMemoryManager::LookasideBufferArena::Contains(void *buffer) {
43
3/4
✓ Branch 0 taken 15760 times.
✗ Branch 1 not taken.
✓ Branch 2 taken 45 times.
✓ Branch 3 taken 15715 times.
 15760 if ((buffer == NULL) || (buffer < arena_))
44 45 return false;
45 15715 return (static_cast<uint64_t>((reinterpret_cast<char *>(buffer)
46 15715 - reinterpret_cast<char *>(arena_)))
47 15715 < kArenaSize);
48 }
49
50
51 3195 SqliteMemoryManager::LookasideBufferArena::LookasideBufferArena()
52 3195 : arena_(sxmmap(kArenaSize)) {
53 // All buffers unused, i.e. all bits set
54 3195 memset(freemap_, 0xFF, kNoBitmaps * sizeof(int));
55 3195 }
56
57
58 3191 SqliteMemoryManager::LookasideBufferArena::~LookasideBufferArena() {
59 3191 sxunmap(arena_, kArenaSize);
60 3191 }
61
62
63 15625 void SqliteMemoryManager::LookasideBufferArena::PutBuffer(void *buffer) {
64
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15625 times.
 15625 assert(buffer >= arena_);
65 15625 const ptrdiff_t nbuffer = (reinterpret_cast<char *>(buffer)
66 15625 - reinterpret_cast<char *>(arena_))
67 / kBufferSize;
68
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 15625 times.
 15625 assert(static_cast<uint64_t>(nbuffer) < kBuffersPerArena);
69 15625 const int nfreemap = nbuffer / (sizeof(int) * 8);
70 15625 freemap_[nfreemap] |= 1 << (nbuffer % (sizeof(int) * 8));
71 15625 }
72
73
74 //------------------------------------------------------------------------------
75
76
77 SqliteMemoryManager *SqliteMemoryManager::instance_ = NULL;
78
79
80 /**
81 * Sqlite ensures that size > 0.
82 */
83 2091749 void *SqliteMemoryManager::xMalloc(int size) {
84 2091749 return instance_->GetMemory(size);
85 }
86
87
88 /**
89 * Sqlite ensures that ptr != NULL.
90 */
91 2091656 void SqliteMemoryManager::xFree(void *ptr) { instance_->PutMemory(ptr); }
92
93
94 /**
95 * Sqlite ensures that ptr != NULL and new_size > 0.
96 */
97 998807 void *SqliteMemoryManager::xRealloc(void *ptr, int new_size) {
98 998807 const int old_size = xSize(ptr);
99
2/2
✓ Branch 0 taken 24638 times.
✓ Branch 1 taken 974169 times.
 998807 if (old_size >= new_size)
100 24638 return ptr;
101
102 974169 void *new_ptr = xMalloc(new_size);
103 974169 memcpy(new_ptr, ptr, old_size);
104 974169 xFree(ptr);
105 974169 return new_ptr;
106 }
107
108
109 /**
110 * Sqlite ensures that ptr != NULL.
111 */
112 3493495 int SqliteMemoryManager::xSize(void *ptr) {
113 3493495 return instance_->GetMemorySize(ptr);
114 }
115
116
117 1216342 int SqliteMemoryManager::xRoundup(int size) { return RoundUp8(size); }
118
119
120 2880 int SqliteMemoryManager::xInit(void *app_data __attribute__((unused))) {
121 2880 return SQLITE_OK;
122 }
123
124
125 2876 void SqliteMemoryManager::xShutdown(void *app_data __attribute__((unused))) { }
126
127
128 2880 void SqliteMemoryManager::AssignGlobalArenas() {
129
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2880 times.
 2880 if (assigned_)
130 ✗ return;
131 int retval;
132
133 2880 retval = sqlite3_config(SQLITE_CONFIG_PAGECACHE, page_cache_memory_,
134 kPageCacheSlotSize, kPageCacheNoSlots);
135
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2880 times.
 2880 assert(retval == SQLITE_OK);
136
137 2880 retval = sqlite3_config(SQLITE_CONFIG_GETMALLOC, &sqlite3_mem_vanilla_);
138
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2880 times.
 2880 assert(retval == SQLITE_OK);
139 2880 retval = sqlite3_config(SQLITE_CONFIG_MALLOC, &mem_methods_);
140
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2880 times.
 2880 assert(retval == SQLITE_OK);
141
142 2880 assigned_ = true;
143 }
144
145
146 /**
147 * Needs to be the first operation on an opened sqlite database. Returns the
148 * location of the buffer.
149 */
150 1135 void *SqliteMemoryManager::AssignLookasideBuffer(sqlite3 *db) {
151 1135 const MutexLockGuard lock_guard(lock_);
152
153
1/2
✓ Branch 1 taken 1135 times.
✗ Branch 2 not taken.
 1135 void *buffer = GetLookasideBuffer();
154
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1135 times.
 1135 assert(buffer != NULL);
155
1/2
✓ Branch 1 taken 1135 times.
✗ Branch 2 not taken.
 1135 const int retval = sqlite3_db_config(db, SQLITE_DBCONFIG_LOOKASIDE, buffer,
156 kLookasideSlotSize,
157 kLookasideSlotsPerDb);
158
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 1135 times.
 1135 assert(retval == SQLITE_OK);
159 1135 return buffer;
160 1135 }
161
162
163 3101 void SqliteMemoryManager::CleanupInstance() {
164
1/2
✓ Branch 0 taken 3101 times.
✗ Branch 1 not taken.
 3101 delete instance_;
165 3101 instance_ = NULL;
166 3101 }
167
168
169 /**
170 * Opens a new arena if necessary.
171 */
172 6940 void *SqliteMemoryManager::GetLookasideBuffer() {
173 void *result;
174 vector<LookasideBufferArena *>::reverse_iterator
175 6940 reverse_iter = lookaside_buffer_arenas_.rbegin();
176 const vector<LookasideBufferArena *>::reverse_iterator
177 6940 i_rend = lookaside_buffer_arenas_.rend();
178
3/4
✓ Branch 2 taken 6985 times.
✗ Branch 3 not taken.
✓ Branch 4 taken 6940 times.
✓ Branch 5 taken 45 times.
 6985 for (; reverse_iter != i_rend; ++reverse_iter) {
179 6940 result = (*reverse_iter)->GetBuffer();
180
2/2
✓ Branch 0 taken 6895 times.
✓ Branch 1 taken 45 times.
 6940 if (result != NULL)
181 6895 return result;
182 }
183
184
1/2
✓ Branch 1 taken 45 times.
✗ Branch 2 not taken.
 45 LookasideBufferArena *new_arena = new LookasideBufferArena();
185
1/2
✓ Branch 1 taken 45 times.
✗ Branch 2 not taken.
 45 lookaside_buffer_arenas_.push_back(new_arena);
186 45 return new_arena->GetBuffer();
187 }
188
189
190 3493675 int SqliteMemoryManager::GetMemorySize(void *ptr) {
191 3493675 return MallocArena::GetMallocArena(ptr, kArenaSize)->GetSize(ptr);
192 }
193
194
195 /**
196 * Opens new arenas as necessary.
197 */
198 2992019 void *SqliteMemoryManager::GetMemory(int size) {
199
1/2
✓ Branch 2 taken 2992019 times.
✗ Branch 3 not taken.
 2992019 void *p = malloc_arenas_[idx_last_arena_]->Malloc(size);
200
2/2
✓ Branch 0 taken 2991974 times.
✓ Branch 1 taken 45 times.
 2992019 if (p != NULL)
201 2991974 return p;
202 45 const unsigned N = malloc_arenas_.size();
203
2/2
✓ Branch 0 taken 45 times.
✓ Branch 1 taken 45 times.
 90 for (unsigned i = 0; i < N; ++i) {
204
1/2
✓ Branch 2 taken 45 times.
✗ Branch 3 not taken.
 45 p = malloc_arenas_[i]->Malloc(size);
205
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 45 times.
 45 if (p != NULL) {
206 ✗ idx_last_arena_ = i;
207 ✗ return p;
208 }
209 }
210 45 idx_last_arena_ = N;
211
2/4
✓ Branch 1 taken 45 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 45 times.
✗ Branch 5 not taken.
 45 MallocArena *M = new MallocArena(kArenaSize);
212
1/2
✓ Branch 1 taken 45 times.
✗ Branch 2 not taken.
 45 malloc_arenas_.push_back(M);
213
1/2
✓ Branch 1 taken 45 times.
✗ Branch 2 not taken.
 45 p = M->Malloc(size);
214
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 45 times.
 45 assert(p != NULL);
215 45 return p;
216 }
217
218
219 3105 SqliteMemoryManager::SqliteMemoryManager()
220 3105 : assigned_(false)
221 3105 , page_cache_memory_(sxmmap(kPageCacheSize))
222 3105 , idx_last_arena_(0) {
223 3105 memset(&sqlite3_mem_vanilla_, 0, sizeof(sqlite3_mem_vanilla_));
224 3105 const int retval = pthread_mutex_init(&lock_, NULL);
225
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 3105 times.
 3105 assert(retval == 0);
226
227
2/4
✓ Branch 1 taken 3105 times.
✗ Branch 2 not taken.
✓ Branch 5 taken 3105 times.
✗ Branch 6 not taken.
 3105 lookaside_buffer_arenas_.push_back(new LookasideBufferArena());
228
3/6
✓ Branch 1 taken 3105 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 3105 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 3105 times.
✗ Branch 8 not taken.
 3105 malloc_arenas_.push_back(new MallocArena(kArenaSize));
229
230 3105 memset(&mem_methods_, 0, sizeof(mem_methods_));
231 3105 mem_methods_.xMalloc = xMalloc;
232 3105 mem_methods_.xFree = xFree;
233 3105 mem_methods_.xRealloc = xRealloc;
234 3105 mem_methods_.xSize = xSize;
235 3105 mem_methods_.xRoundup = xRoundup;
236 3105 mem_methods_.xInit = xInit;
237 3105 mem_methods_.xShutdown = xShutdown;
238 3105 mem_methods_.pAppData = NULL;
239 3105 }
240
241
242 /**
243 * Must be executed only after sqlite3_shutdown.
244 */
245 3101 SqliteMemoryManager::~SqliteMemoryManager() {
246
2/2
✓ Branch 0 taken 2876 times.
✓ Branch 1 taken 225 times.
 3101 if (assigned_) {
247 // Reset sqlite to default values
248 int retval;
249 2876 retval = sqlite3_config(SQLITE_CONFIG_PAGECACHE, NULL, 0, 0);
250
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2876 times.
 2876 assert(retval == SQLITE_OK);
251 2876 retval = sqlite3_config(SQLITE_CONFIG_MALLOC, &sqlite3_mem_vanilla_);
252
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2876 times.
 2876 assert(retval == SQLITE_OK);
253 }
254
255 3101 sxunmap(page_cache_memory_, kPageCacheSize);
256
2/2
✓ Branch 1 taken 3101 times.
✓ Branch 2 taken 3101 times.
 6202 for (unsigned i = 0; i < lookaside_buffer_arenas_.size(); ++i)
257
1/2
✓ Branch 1 taken 3101 times.
✗ Branch 2 not taken.
 3101 delete lookaside_buffer_arenas_[i];
258
2/2
✓ Branch 1 taken 3101 times.
✓ Branch 2 taken 3101 times.
 6202 for (unsigned i = 0; i < malloc_arenas_.size(); ++i)
259
1/2
✓ Branch 1 taken 3101 times.
✗ Branch 2 not taken.
 3101 delete malloc_arenas_[i];
260 3101 pthread_mutex_destroy(&lock_);
261 3101 }
262
263
264 /**
265 * Only entirely empty arenas are freed to the system. In cvmfs, catalogs
266 * are gradually opened and sometimes close altogether when a new root catalog
267 * arrives. Hence there is no fragmentation.
268 */
269 6940 void SqliteMemoryManager::PutLookasideBuffer(void *buffer) {
270 6940 const unsigned N = lookaside_buffer_arenas_.size();
271
1/2
✓ Branch 0 taken 6940 times.
✗ Branch 1 not taken.
 6940 for (unsigned i = 0; i < N; ++i) {
272
1/2
✓ Branch 2 taken 6940 times.
✗ Branch 3 not taken.
 6940 if (lookaside_buffer_arenas_[i]->Contains(buffer)) {
273 6940 lookaside_buffer_arenas_[i]->PutBuffer(buffer);
274
6/6
✓ Branch 0 taken 5760 times.
✓ Branch 1 taken 1180 times.
✓ Branch 4 taken 45 times.
✓ Branch 5 taken 5715 times.
✓ Branch 6 taken 45 times.
✓ Branch 7 taken 6895 times.
 6940 if ((N > 1) && lookaside_buffer_arenas_[i]->IsEmpty()) {
275
1/2
✓ Branch 1 taken 45 times.
✗ Branch 2 not taken.
 45 delete lookaside_buffer_arenas_[i];
276
1/2
✓ Branch 4 taken 45 times.
✗ Branch 5 not taken.
 45 lookaside_buffer_arenas_.erase(lookaside_buffer_arenas_.begin() + i);
277 }
278 6940 return;
279 }
280 }
281 ✗ PANIC(NULL);
282 }
283
284
285 /**
286 * Closes empty areas.
287 */
288 2091836 void SqliteMemoryManager::PutMemory(void *ptr) {
289 2091836 MallocArena *M = MallocArena::GetMallocArena(ptr, kArenaSize);
290 2091836 M->Free(ptr);
291 2091836 const unsigned N = malloc_arenas_.size();
292
5/6
✓ Branch 0 taken 45 times.
✓ Branch 1 taken 2091791 times.
✓ Branch 3 taken 45 times.
✗ Branch 4 not taken.
✓ Branch 5 taken 45 times.
✓ Branch 6 taken 2091791 times.
 2091836 if ((N > 1) && M->IsEmpty()) {
293
1/2
✓ Branch 0 taken 90 times.
✗ Branch 1 not taken.
 90 for (unsigned i = 0; i < N; ++i) {
294
2/2
✓ Branch 1 taken 45 times.
✓ Branch 2 taken 45 times.
 90 if (malloc_arenas_[i] == M) {
295
1/2
✓ Branch 1 taken 45 times.
✗ Branch 2 not taken.
 45 delete malloc_arenas_[i];
296
1/2
✓ Branch 4 taken 45 times.
✗ Branch 5 not taken.
 45 malloc_arenas_.erase(malloc_arenas_.begin() + i);
297 45 idx_last_arena_ = 0;
298 45 return;
299 }
300 }
301 ✗ PANIC(NULL);
302 }
303 }
304
305
306 /**
307 * To be used after an sqlite database has been closed.
308 */
309 1135 void SqliteMemoryManager::ReleaseLookasideBuffer(void *buffer) {
310 1135 const MutexLockGuard lock_guard(lock_);
311
1/2
✓ Branch 1 taken 1135 times.
✗ Branch 2 not taken.
 1135 PutLookasideBuffer(buffer);
312 1135 }
313