GCC Code Coverage Report


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