29787659139

Committed 20 Jul 2026 11:34PM UTC coverage: 51.578% (-1.1%) from 52.66%

Build # 29787659139

Build Type

Pull #99

github

Committed by

web-flow

Commit Message

Merge ee805adeb into 06bc84ec9

Pull Request Pull Request #99: Support CM time_metric (NS/MS/SEC/US) across reader and viz

Coverage Stats

34832 of 86278 branches covered (40.37%)

Branch coverage included in aggregate %.

1034 of 1319 new or added lines in 30 files covered. (78.39%)

5193 existing lines in 197 files now uncovered.

35349 of 49791 relevant lines covered (70.99%)

9765.54 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

69.7

/src/dftracer/utils/core/io/io_completion_thread.cpp

#include <dftracer/utils/core/io/io_completion_thread.h>

namespace dftracer::utils::io {

IoCompletionThread::~IoCompletionThread() {
    if (running_.load(std::memory_order_relaxed)) {
        stop();
    }
}

void IoCompletionThread::start(std::function<void()> poll_fn) {
    poll_fn_ = std::move(poll_fn);
    running_.store(true, std::memory_order_release);
    thread_ = std::thread([this] {
        while (running_.load(std::memory_order_acquire)) {
            poll_fn_();
        }
    });
}

void IoCompletionThread::signal_stop() {
    running_.store(false, std::memory_order_release);
}

void IoCompletionThread::join() {
    if (thread_.joinable()) {
        thread_.join();
    }
}

void IoCompletionThread::stop() {
    signal_stop();
    join();
}

}  // namespace dftracer::utils::io

1	#include <dftracer/utils/core/io/io_completion_thread.h>
2
3	namespace dftracer::utils::io {
4
5	IoCompletionThread::~IoCompletionThread() {	1,096✔
6	if (running_.load(std::memory_order_relaxed)) {	548!
7	stop();	×
UNCOV 8	}	×
9	}	1,096✔
10
11	void IoCompletionThread::start(std::function<void()> poll_fn) {	548✔
12	poll_fn_ = std::move(poll_fn);	548✔
13	running_.store(true, std::memory_order_release);	548✔
14	thread_ = std::thread([this] {	1,096✔
15	while (running_.load(std::memory_order_acquire)) {	1,096✔
16	poll_fn_();	548✔
17	}
18	});	548✔
19	}	548✔
20
21	void IoCompletionThread::signal_stop() {	548✔
22	running_.store(false, std::memory_order_release);	548✔
23	}	548✔
24
25	void IoCompletionThread::join() {	548✔
26	if (thread_.joinable()) {	548!
27	thread_.join();	548✔
28	}	548✔
29	}	548✔
30
31	void IoCompletionThread::stop() {	×
32	signal_stop();	×
33	join();	×
34	}	×
35
36	} // namespace dftracer::utils::io

llnl / dftracer-utils / 29787659139

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous