23529483807

Committed 25 Mar 2026 07:17AM UTC coverage: 48.515% (-1.6%) from 50.098%

Build # 23529483807

Build Type

Pull #57

github

Committed by

web-flow

Commit Message

Merge 5b1e117ad into 38f9f3616

Pull Request Pull Request #57: feat(comparator): add pairwise traces comparator

Coverage Stats

18829 of 49412 branches covered (38.11%)

Branch coverage included in aggregate %.

1584 of 1933 new or added lines in 14 files covered. (81.95%)

3552 existing lines in 135 files now uncovered.

18474 of 27477 relevant lines covered (67.23%)

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

llnl / dftracer-utils / 23529483807

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