GCC Code Coverage Report

Directory: cvmfs/
File: cvmfs/ring_buffer.cc
Date: 2026-06-28 02:36:10
Exec Total Coverage
Lines: 59 59 100.0%
Branches: 12 14 85.7%
Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 */
4
5 #include "ring_buffer.h"
6
7 #include <algorithm>
8 #include <cassert>
9 #include <cstdlib>
10 #include <cstring>
11
12 #include "util/smalloc.h"
13
14 const RingBuffer::ObjectHandle_t RingBuffer::kInvalidObjectHandle = size_t(-1);
15
16
17 192 RingBuffer::RingBuffer(size_t total_size)
18 192 : total_size_(total_size)
19 192 , free_space_(total_size)
20 192 , front_(0)
21 192 , back_(0)
22 192 , buffer_(reinterpret_cast<unsigned char *>(sxmmap(total_size_))) {
23
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 192 times.
 192 assert(total_size_ >= sizeof(size_t));
24 192 }
25
26
27 192 RingBuffer::~RingBuffer() { sxunmap(buffer_, total_size_); }
28
29
30 96288 void RingBuffer::Put(const void *data, size_t size) {
31 96288 const size_t size_head = std::min(size, total_size_ - front_);
32
2/2
✓ Branch 0 taken 96240 times.
✓ Branch 1 taken 48 times.
 96288 if (size_head > 0)
33 96240 memcpy(buffer_ + front_, data, size_head);
34
35
2/2
✓ Branch 0 taken 16272 times.
✓ Branch 1 taken 80016 times.
 96288 if (size_head < size) {
36 16272 const size_t size_tail = size - size_head;
37 16272 memcpy(buffer_, reinterpret_cast<const unsigned char *>(data) + size_head,
38 size_tail);
39 }
40
41 96288 front_ = (front_ + size) % total_size_;
42 96288 free_space_ -= size;
43 96288 }
44
45
46 4982208 void RingBuffer::Get(size_t from, size_t size, void *to) const {
47 4982208 const size_t size_head = std::min(size, total_size_ - from);
48
2/2
✓ Branch 0 taken 4749216 times.
✓ Branch 1 taken 232992 times.
 4982208 if (size_head > 0)
49 4749216 memcpy(to, buffer_ + from, size_head);
50
51
2/2
✓ Branch 0 taken 418512 times.
✓ Branch 1 taken 4563696 times.
 4982208 if (size_head < size) {
52 418512 const size_t size_tail = size - size_head;
53 418512 memcpy(reinterpret_cast<unsigned char *>(to) + size_head, buffer_,
54 size_tail);
55 }
56 4982208 }
57
58
59 95904 void RingBuffer::Shrink(size_t by) {
60 95904 back_ = (back_ + by) % total_size_;
61 95904 free_space_ += by;
62 95904 }
63
64
65 143856 size_t RingBuffer::GetObjectSize(ObjectHandle_t handle) const {
66 size_t size_tag;
67 143856 Get(handle, sizeof(size_tag), &size_tag);
68
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 143856 times.
 143856 assert(size_tag <= total_size_);
69 143856 return size_tag;
70 }
71
72
73 48192 RingBuffer::ObjectHandle_t RingBuffer::PushFront(const void *obj, size_t size) {
74 48192 size_t size_tag = size;
75 48192 size += sizeof(size_tag);
76
2/2
✓ Branch 0 taken 48 times.
✓ Branch 1 taken 48144 times.
 48192 if (size > free_space_) {
77 48 return kInvalidObjectHandle;
78 }
79
80 48144 const ObjectHandle_t result = front_;
81
82 48144 Put(&size_tag, sizeof(size_tag));
83 48144 Put(obj, size_tag);
84
85 48144 return result;
86 }
87
88
89 47952 RingBuffer::ObjectHandle_t RingBuffer::RemoveBack() {
90 47952 const ObjectHandle_t result = back_;
91
92 47952 const size_t size_tag = GetObjectSize(result);
93 47952 Shrink(sizeof(size_tag));
94 47952 Shrink(size_tag);
95
96 47952 return result;
97 }
98
99
100 47904 void RingBuffer::CopyObject(ObjectHandle_t handle, void *to) const {
101 47904 const size_t size_tag = GetObjectSize(handle);
102 47904 const ObjectHandle_t object = (handle + sizeof(size_tag)) % total_size_;
103 47904 Get(object, size_tag, to);
104 47904 }
105
106
107 4790448 void RingBuffer::CopySlice(ObjectHandle_t handle, size_t size, size_t offset,
108 void *to) const {
109 4790448 const ObjectHandle_t begin = (handle + sizeof(size_t) + offset) % total_size_;
110 4790448 Get(begin, size, to);
111 4790448 }
112