GCC Code Coverage Report

Directory: ./
File: include/shared_memory/array_serializable.hxx
Date: 2022-06-30 06:29:57
Exec Total Coverage
Lines: 38 41 92.7%
Branches: 19 42 45.2%
Line Branch Exec Source
1 // Copyright (c) 2019 Max Planck Gesellschaft
2 // Author : Vincent Berenz
3
4 template <typename T, int SIZE>
5 3 void array<T, SIZE>::init(SERIALIZABLE)
6 {
7 3 this->item_size_ = Serializer<T>::serializable_size();
8 3 this->total_size_ = this->item_size_ * this->size_;
9 3 uint segment_size = get_segment_size(this->total_size_, sizeof(char));
10
2/4
✓ Branch 3 taken 3 times.
✗ Branch 4 not taken.
✓ Branch 6 taken 3 times.
✗ Branch 7 not taken.
 3 segment_manager_ = boost::interprocess::managed_shared_memory(
11 boost::interprocess::open_or_create, segment_id_.c_str(), segment_size);
12
1/2
✓ Branch 3 taken 3 times.
✗ Branch 4 not taken.
 6 this->shared_ = segment_manager_.find_or_construct<char>(
13
1/2
✓ Branch 2 taken 3 times.
✗ Branch 3 not taken.
 3 segment_id_.c_str())[this->total_size_]();
14 3 }
15
16 template <typename T, int SIZE>
17 200 void array<T, SIZE>::set(uint index, const T& t, SERIALIZABLE)
18 {
19 200 uint abs_index = index * this->item_size_;
20
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 200 times.
 200 if (index >= this->total_size_)
21 {
22 ✗ throw std::runtime_error("invalid index");
23 }
24
1/2
✓ Branch 0 taken 200 times.
✗ Branch 1 not taken.
 200 if (multiprocess_safe_)
25 {
26 200 mutex_.lock();
27 }
28 200 const std::string& serialized = this->serializer_.serialize(t);
29
2/2
✓ Branch 0 taken 8800 times.
✓ Branch 1 taken 200 times.
 9000 for (uint index = 0; index < this->item_size_; index++)
30 {
31 8800 this->shared_[abs_index + index] = serialized[index];
32 }
33
1/2
✓ Branch 0 taken 200 times.
✗ Branch 1 not taken.
 200 if (multiprocess_safe_)
34 {
35 200 mutex_.unlock();
36 }
37 200 }
38
39 template <typename T, int SIZE>
40 300 void array<T, SIZE>::get(uint index, T& t, SERIALIZABLE)
41 {
42 300 uint abs_index = index * this->item_size_;
43
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 300 times.
 300 if (abs_index >= this->total_size_)
44 {
45 ✗ throw std::runtime_error("invalid index");
46 }
47
1/2
✓ Branch 0 taken 300 times.
✗ Branch 1 not taken.
 300 if (multiprocess_safe_)
48 {
49 300 mutex_.lock();
50 }
51
2/4
✓ Branch 2 taken 300 times.
✗ Branch 3 not taken.
✓ Branch 5 taken 300 times.
✗ Branch 6 not taken.
 900 this->serializer_.deserialize(
52 600 std::string(&this->shared_[abs_index], this->item_size_), t);
53
1/2
✓ Branch 0 taken 300 times.
✗ Branch 1 not taken.
 300 if (multiprocess_safe_)
54 {
55 300 mutex_.unlock();
56 }
57 300 }
58
59 template <typename T, int SIZE>
60 100 std::string array<T, SIZE>::get_serialized(uint index, SERIALIZABLE)
61 {
62 100 uint abs_index = index * this->item_size_;
63
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 100 times.
 100 if (abs_index >= this->total_size_)
64 {
65 ✗ throw std::runtime_error("invalid index");
66 }
67
1/2
✓ Branch 0 taken 100 times.
✗ Branch 1 not taken.
 100 if (multiprocess_safe_)
68 {
69 100 mutex_.lock();
70 }
71
1/2
✓ Branch 2 taken 100 times.
✗ Branch 3 not taken.
 100 std::string r(&this->shared_[abs_index], this->item_size_);
72
1/2
✓ Branch 0 taken 100 times.
✗ Branch 1 not taken.
 100 if (multiprocess_safe_)
73 {
74
1/2
✓ Branch 1 taken 100 times.
✗ Branch 2 not taken.
 100 mutex_.unlock();
75 }
76 100 return r;
77 }
78