Directory: | cvmfs/ |
---|---|
File: | cvmfs/ingestion/item_mem.cc |
Date: | 2025-10-12 02:35:38 |
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 | 16091575 | void ItemAllocator::Free(void *ptr) { | |
17 | 16091575 | const MutexLockGuard guard(lock_); | |
18 | |||
19 | 16149978 | MallocArena *M = MallocArena::GetMallocArena(ptr, kArenaSize); | |
20 |
1/2✓ Branch 1 taken 16149978 times.
✗ Branch 2 not taken.
|
16149978 | M->Free(ptr); |
21 | 16149978 | const unsigned N = malloc_arenas_.size(); | |
22 |
6/6✓ Branch 0 taken 2548641 times.
✓ Branch 1 taken 13601337 times.
✓ Branch 3 taken 71 times.
✓ Branch 4 taken 2548570 times.
✓ Branch 5 taken 71 times.
✓ Branch 6 taken 16149907 times.
|
16149978 | if ((N > 1) && M->IsEmpty()) { |
23 |
1/2✓ Branch 0 taken 113 times.
✗ Branch 1 not taken.
|
113 | for (unsigned i = 0; i < N; ++i) { |
24 |
2/2✓ Branch 1 taken 71 times.
✓ Branch 2 taken 42 times.
|
113 | if (malloc_arenas_[i] == M) { |
25 |
1/2✓ Branch 1 taken 71 times.
✗ Branch 2 not taken.
|
71 | delete malloc_arenas_[i]; |
26 | 71 | atomic_xadd64(&total_allocated_, -static_cast<int>(kArenaSize)); | |
27 |
1/2✓ Branch 4 taken 71 times.
✗ Branch 5 not taken.
|
71 | malloc_arenas_.erase(malloc_arenas_.begin() + i); |
28 | 71 | idx_last_arena_ = 0; | |
29 | 71 | return; | |
30 | } | ||
31 | } | ||
32 | ✗ | PANIC(NULL); | |
33 | } | ||
34 |
2/2✓ Branch 1 taken 16134705 times.
✓ Branch 2 taken 1116 times.
|
16149978 | } |
35 | |||
36 | |||
37 | 1547 | ItemAllocator::ItemAllocator() : idx_last_arena_(0) { | |
38 | 1547 | const int retval = pthread_mutex_init(&lock_, NULL); | |
39 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 1547 times.
|
1547 | assert(retval == 0); |
40 | |||
41 |
3/6✓ Branch 1 taken 1547 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 1547 times.
✗ Branch 5 not taken.
✓ Branch 7 taken 1547 times.
✗ Branch 8 not taken.
|
1547 | malloc_arenas_.push_back(new MallocArena(kArenaSize)); |
42 | 1547 | atomic_xadd64(&total_allocated_, kArenaSize); | |
43 | 1547 | } | |
44 | |||
45 | |||
46 | 1546 | ItemAllocator::~ItemAllocator() { | |
47 |
2/2✓ Branch 1 taken 1546 times.
✓ Branch 2 taken 1546 times.
|
3092 | for (unsigned i = 0; i < malloc_arenas_.size(); ++i) { |
48 | 1546 | atomic_xadd64(&total_allocated_, -static_cast<int>(kArenaSize)); | |
49 |
1/2✓ Branch 1 taken 1546 times.
✗ Branch 2 not taken.
|
1546 | delete malloc_arenas_[i]; |
50 | } | ||
51 | 1546 | pthread_mutex_destroy(&lock_); | |
52 | 1546 | } | |
53 | |||
54 | |||
55 | 16064354 | void *ItemAllocator::Malloc(unsigned size) { | |
56 | 16064354 | const MutexLockGuard guard(lock_); | |
57 | |||
58 |
1/2✓ Branch 2 taken 16149978 times.
✗ Branch 3 not taken.
|
16149978 | void *p = malloc_arenas_[idx_last_arena_]->Malloc(size); |
59 |
2/2✓ Branch 0 taken 16149886 times.
✓ Branch 1 taken 92 times.
|
16149978 | if (p != NULL) |
60 | 16149886 | return p; | |
61 | 92 | const unsigned N = malloc_arenas_.size(); | |
62 |
2/2✓ Branch 0 taken 113 times.
✓ Branch 1 taken 71 times.
|
184 | for (unsigned i = 0; i < N; ++i) { |
63 |
1/2✓ Branch 2 taken 113 times.
✗ Branch 3 not taken.
|
113 | p = malloc_arenas_[i]->Malloc(size); |
64 |
2/2✓ Branch 0 taken 21 times.
✓ Branch 1 taken 92 times.
|
113 | if (p != NULL) { |
65 | 21 | idx_last_arena_ = i; | |
66 | 21 | return p; | |
67 | } | ||
68 | } | ||
69 | 71 | idx_last_arena_ = N; | |
70 |
2/4✓ Branch 1 taken 71 times.
✗ Branch 2 not taken.
✓ Branch 4 taken 71 times.
✗ Branch 5 not taken.
|
71 | MallocArena *M = new MallocArena(kArenaSize); |
71 | 71 | atomic_xadd64(&total_allocated_, kArenaSize); | |
72 |
1/2✓ Branch 1 taken 71 times.
✗ Branch 2 not taken.
|
71 | malloc_arenas_.push_back(M); |
73 |
1/2✓ Branch 1 taken 71 times.
✗ Branch 2 not taken.
|
71 | p = M->Malloc(size); |
74 |
1/2✗ Branch 0 not taken.
✓ Branch 1 taken 71 times.
|
71 | assert(p != NULL); |
75 | 71 | return p; | |
76 | 16149978 | } | |
77 |