GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/ingestion/item_mem.cc
Date: 2025-11-30 02:35:17
Exec Total Coverage
Lines: 45 46 97.8%
Branches: 34 50 68.0%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "item_mem.h"
6
7 #include <cassert>
8 #include <cstdlib>
9
10 #include "util/concurrency.h"
11 #include "util/exception.h"
12
13 atomic_int64 ItemAllocator::total_allocated_ = 0;
14
15
16 36866876 void ItemAllocator::Free(void *ptr) {
17 36866876 const MutexLockGuard guard(lock_);
18
19 36960394 MallocArena *M = MallocArena::GetMallocArena(ptr, kArenaSize);
20
1/2
✓ Branch 1 taken 36960394 times.
✗ Branch 2 not taken.
 36960394 M->Free(ptr);
21 36960394 const unsigned N = malloc_arenas_.size();
22
6/6
✓ Branch 0 taken 5913392 times.
✓ Branch 1 taken 31047002 times.
✓ Branch 3 taken 184 times.
✓ Branch 4 taken 5913208 times.
✓ Branch 5 taken 184 times.
✓ Branch 6 taken 36960210 times.
 36960394 if ((N > 1) && M->IsEmpty()) {
23
1/2
✓ Branch 0 taken 276 times.
✗ Branch 1 not taken.
 276 for (unsigned i = 0; i < N; ++i) {
24
2/2
✓ Branch 1 taken 184 times.
✓ Branch 2 taken 92 times.
 276 if (malloc_arenas_[i] == M) {
25
1/2
✓ Branch 1 taken 184 times.
✗ Branch 2 not taken.
 184 delete malloc_arenas_[i];
26 184 atomic_xadd64(&total_allocated_, -static_cast<int>(kArenaSize));
27
1/2
✓ Branch 4 taken 184 times.
✗ Branch 5 not taken.
 184 malloc_arenas_.erase(malloc_arenas_.begin() + i);
28 184 idx_last_arena_ = 0;
29 184 return;
30 }
31 }
32 ✗ PANIC(NULL);
33 }
34
2/2
✓ Branch 1 taken 36934910 times.
✓ Branch 2 taken 1564 times.
 36960394 }
35
36
37 2122 ItemAllocator::ItemAllocator() : idx_last_arena_(0) {
38 2122 const int retval = pthread_mutex_init(&lock_, NULL);
39
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 2122 times.
 2122 assert(retval == 0);
40
41
3/6
✓ Branch 1 taken 2122 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 2122 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 2122 times.
✗ Branch 8 not taken.
 2122 malloc_arenas_.push_back(new MallocArena(kArenaSize));
42 2122 atomic_xadd64(&total_allocated_, kArenaSize);
43 2122 }
44
45
46 2121 ItemAllocator::~ItemAllocator() {
47
2/2
✓ Branch 1 taken 2121 times.
✓ Branch 2 taken 2121 times.
 4242 for (unsigned i = 0; i < malloc_arenas_.size(); ++i) {
48 2121 atomic_xadd64(&total_allocated_, -static_cast<int>(kArenaSize));
49
1/2
✓ Branch 1 taken 2121 times.
✗ Branch 2 not taken.
 2121 delete malloc_arenas_[i];
50 }
51 2121 pthread_mutex_destroy(&lock_);
52 2121 }
53
54
55 36825522 void *ItemAllocator::Malloc(unsigned size) {
56 36825522 const MutexLockGuard guard(lock_);
57
58
1/2
✓ Branch 2 taken 36960394 times.
✗ Branch 3 not taken.
 36960394 void *p = malloc_arenas_[idx_last_arena_]->Malloc(size);
59
2/2
✓ Branch 0 taken 36960164 times.
✓ Branch 1 taken 230 times.
 36960394 if (p != NULL)
60 36960164 return p;
61 230 const unsigned N = malloc_arenas_.size();
62
2/2
✓ Branch 0 taken 276 times.
✓ Branch 1 taken 184 times.
 460 for (unsigned i = 0; i < N; ++i) {
63
1/2
✓ Branch 2 taken 276 times.
✗ Branch 3 not taken.
 276 p = malloc_arenas_[i]->Malloc(size);
64
2/2
✓ Branch 0 taken 46 times.
✓ Branch 1 taken 230 times.
 276 if (p != NULL) {
65 46 idx_last_arena_ = i;
66 46 return p;
67 }
68 }
69 184 idx_last_arena_ = N;
70
2/4
✓ Branch 1 taken 184 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 184 times.
✗ Branch 5 not taken.
 184 MallocArena *M = new MallocArena(kArenaSize);
71 184 atomic_xadd64(&total_allocated_, kArenaSize);
72
1/2
✓ Branch 1 taken 184 times.
✗ Branch 2 not taken.
 184 malloc_arenas_.push_back(M);
73
1/2
✓ Branch 1 taken 184 times.
✗ Branch 2 not taken.
 184 p = M->Malloc(size);
74
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 184 times.
 184 assert(p != NULL);
75 184 return p;
76 36960394 }
77