GCC Code Coverage Report


Directory: cvmfs/
File: cvmfs/backoff.cc
Date: 2025-07-21 10:50:29
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 5000689 void BackoffThrottle::Init(const unsigned init_delay_ms,
19 const unsigned max_delay_ms,
20 const unsigned reset_after_ms) {
21 5000689 init_delay_ms_ = init_delay_ms;
22 5000689 max_delay_ms_ = max_delay_ms;
23 5000689 reset_after_ms_ = reset_after_ms;
24 5000689 prng_.InitLocaltime();
25
26 5001829 lock_ = reinterpret_cast<pthread_mutex_t *>(smalloc(sizeof(pthread_mutex_t)));
27 5001169 const int retval = pthread_mutex_init(lock_, NULL);
28
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 5001569 times.
5001569 assert(retval == 0);
29
30 5001569 Reset();
31 5001989 }
32
33
34 4993363 BackoffThrottle::~BackoffThrottle() {
35 4993363 pthread_mutex_destroy(lock_);
36 4993483 free(lock_);
37 4993483 }
38
39
40 5002289 void BackoffThrottle::Reset() {
41 5002289 pthread_mutex_lock(lock_);
42 5003629 delay_range_ = 0;
43 5003629 last_throttle_ = 0;
44 5003629 pthread_mutex_unlock(lock_);
45 5002809 }
46
47
48 226 void BackoffThrottle::Throttle() {
49 226 const time_t now = time(NULL);
50
51 226 pthread_mutex_lock(lock_);
52
2/2
✓ Branch 0 taken 70 times.
✓ Branch 1 taken 156 times.
226 if (unsigned(now - last_throttle_) < reset_after_ms_ / 1000) {
53
1/2
✓ Branch 0 taken 70 times.
✗ Branch 1 not taken.
70 if (delay_range_ < max_delay_ms_) {
54
1/2
✓ Branch 0 taken 70 times.
✗ Branch 1 not taken.
70 if (delay_range_ == 0)
55 70 delay_range_ = init_delay_ms_;
56 else
57 delay_range_ *= 2;
58 }
59 70 unsigned delay = prng_.Next(delay_range_) + 1;
60
1/2
✗ Branch 0 not taken.
✓ Branch 1 taken 70 times.
70 if (delay > max_delay_ms_)
61 delay = max_delay_ms_;
62
63 70 pthread_mutex_unlock(lock_);
64 70 LogCvmfs(kLogCvmfs, kLogDebug, "backoff throttle %d ms", delay);
65 70 SafeSleepMs(delay);
66 70 pthread_mutex_lock(lock_);
67 }
68 226 last_throttle_ = now;
69 226 pthread_mutex_unlock(lock_);
70 226 }
71