GCC Code Coverage Report


Directory: cvmfs/
File: cvmfs/backoff.cc
Date: 2025-06-29 02:35:41
Exec Total Coverage
Lines: 36 38 94.7%
Branches: 6 10 60.0%

Line Branch Exec Source
1 /**
2 * This file is part of the CernVM File System.
3 *
4 * Exponential backoff (sleep) with cutoff.
5 */
6
7
8 #include "backoff.h"
9
10 #include <ctime>
11
12 #include "util/logging.h"
13 #include "util/posix.h"
14 #include "util/smalloc.h"
15
16 using namespace std; // NOLINT
17
18 9751116 void BackoffThrottle::Init(const unsigned init_delay_ms,
19 const unsigned max_delay_ms,
20 const unsigned reset_after_ms) {
21 9751116 init_delay_ms_ = init_delay_ms;
22 9751116 max_delay_ms_ = max_delay_ms;
23 9751116 reset_after_ms_ = reset_after_ms;
24 9751116 prng_.InitLocaltime();
25
26 9752637 lock_ = reinterpret_cast<pthread_mutex_t *>(smalloc(sizeof(pthread_mutex_t)));
27 9751623 const int retval = pthread_mutex_init(lock_, NULL);
28
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 9751935 times.
9751935 assert(retval == 0);
29
30 9751935 Reset();
31 9752715 }
32
33
34 9741823 BackoffThrottle::~BackoffThrottle() {
35 9741823 pthread_mutex_destroy(lock_);
36 9741784 free(lock_);
37 9741784 }
38
39
40 9752350 void BackoffThrottle::Reset() {
41 9752350 pthread_mutex_lock(lock_);
42 9754924 delay_range_ = 0;
43 9754924 last_throttle_ = 0;
44 9754924 pthread_mutex_unlock(lock_);
45 9753598 }
46
47
48 175 void BackoffThrottle::Throttle() {
49 175 const time_t now = time(NULL);
50
51 175 pthread_mutex_lock(lock_);
52
2/2
✓ Branch 0 taken 86 times.
✓ Branch 1 taken 89 times.
175 if (unsigned(now - last_throttle_) < reset_after_ms_ / 1000) {
53
1/2
✓ Branch 0 taken 86 times.
✗ Branch 1 not taken.
86 if (delay_range_ < max_delay_ms_) {
54
1/2
✓ Branch 0 taken 86 times.
✗ Branch 1 not taken.
86 if (delay_range_ == 0)
55 86 delay_range_ = init_delay_ms_;
56 else
57 delay_range_ *= 2;
58 }
59 86 unsigned delay = prng_.Next(delay_range_) + 1;
60
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 86 times.
86 if (delay > max_delay_ms_)
61 delay = max_delay_ms_;
62
63 86 pthread_mutex_unlock(lock_);
64 86 LogCvmfs(kLogCvmfs, kLogDebug, "backoff throttle %d ms", delay);
65 86 SafeSleepMs(delay);
66 86 pthread_mutex_lock(lock_);
67 }
68 175 last_throttle_ = now;
69 175 pthread_mutex_unlock(lock_);
70 175 }
71