23561935370

Committed 25 Mar 2026 08:15PM UTC coverage: 51.009% (+0.8%) from 50.205%

Build # 23561935370

Build Type

Pull #57

github

Committed by

web-flow

Commit Message

Merge f8aaf6b1d into f837e5ce7

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

Coverage Stats

22032 of 55983 branches covered (39.35%)

Branch coverage included in aggregate %.

1642 of 1888 new or added lines in 26 files covered. (86.97%)

6 existing lines in 3 files now uncovered.

19366 of 25175 relevant lines covered (76.93%)

439564.25 hits per line

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

0.0

/src/dftracer/utils/server/cursor.cpp

#include <dftracer/utils/server/cursor.h>

#include <array>
#include <cstring>

namespace dftracer::utils::server {

namespace {

// Minimal base64 encode/decode for cursor serialization.
static constexpr char kBase64Chars[] =
    "ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";

std::string base64_encode(const void* data, std::size_t len) {
    auto* bytes = static_cast<const unsigned char*>(data);
    std::string out;
    out.reserve(4 * ((len + 2) / 3));
    for (std::size_t i = 0; i < len; i += 3) {
        unsigned val = static_cast<unsigned>(bytes[i]) << 16;
        if (i + 1 < len) val |= static_cast<unsigned>(bytes[i + 1]) << 8;
        if (i + 2 < len) val |= static_cast<unsigned>(bytes[i + 2]);
        out.push_back(kBase64Chars[(val >> 18) & 0x3F]);
        out.push_back(kBase64Chars[(val >> 12) & 0x3F]);
        out.push_back((i + 1 < len) ? kBase64Chars[(val >> 6) & 0x3F] : '=');
        out.push_back((i + 2 < len) ? kBase64Chars[val & 0x3F] : '=');
    }
    return out;
}

std::optional<std::string> base64_decode(std::string_view sv) {
    static constexpr unsigned char DEC_TABLE[256] = {
        // clang-format off
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,62,64,64,64,63,
        52,53,54,55,56,57,58,59,60,61,64,64,64,64,64,64,
        64, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9,10,11,12,13,14,
        15,16,17,18,19,20,21,22,23,24,25,64,64,64,64,64,
        64,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,
        41,42,43,44,45,46,47,48,49,50,51,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
        // clang-format on
    };

    if (sv.size() % 4 != 0) return std::nullopt;
    std::string out;
    out.reserve(sv.size() / 4 * 3);
    for (std::size_t i = 0; i < sv.size(); i += 4) {
        auto a = DEC_TABLE[static_cast<unsigned char>(sv[i])];
        auto b = DEC_TABLE[static_cast<unsigned char>(sv[i + 1])];
        auto c = DEC_TABLE[static_cast<unsigned char>(sv[i + 2])];
        auto d = DEC_TABLE[static_cast<unsigned char>(sv[i + 3])];
        if (a == 64 || b == 64) return std::nullopt;
        unsigned val = (a << 18) | (b << 12);
        out.push_back(static_cast<char>(val >> 16));
        if (c != 64) {
            val |= (c << 6);
            out.push_back(static_cast<char>((val >> 8) & 0xFF));
        }
        if (d != 64) {
            val |= d;
            out.push_back(static_cast<char>(val & 0xFF));
        }
    }
    return out;
}

}  // namespace

// Wire format: 8 bytes file_index + 4 bytes chunk_index + 4 bytes line_offset
// (all little-endian), base64-encoded.
static constexpr std::size_t CURSOR_BYTES = 16;

std::string QueryCursor::encode() const {
    unsigned char raw[CURSOR_BYTES];
    std::memcpy(raw, &file_index, 8);
    std::memcpy(raw + 8, &chunk_index, 4);
    std::memcpy(raw + 12, &line_offset, 4);
    return base64_encode(raw, CURSOR_BYTES);
}

std::optional<QueryCursor> QueryCursor::decode(std::string_view cursor) {
    auto raw = base64_decode(cursor);
    if (!raw || raw->size() != CURSOR_BYTES) return std::nullopt;
    QueryCursor c;
    std::memcpy(&c.file_index, raw->data(), 8);
    std::memcpy(&c.chunk_index, raw->data() + 8, 4);
    std::memcpy(&c.line_offset, raw->data() + 12, 4);
    return c;
}

}  // namespace dftracer::utils::server

1	#include <dftracer/utils/server/cursor.h>
2
3	#include <array>
4	#include <cstring>
5
6	namespace dftracer::utils::server {
7
8	namespace {
9
10	// Minimal base64 encode/decode for cursor serialization.
11	static constexpr char kBase64Chars[] =
12	"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789+/";
13
14	std::string base64_encode(const void* data, std::size_t len) {	×
15	auto* bytes = static_cast<const unsigned char*>(data);	×
16	std::string out;	×
17	out.reserve(4 * ((len + 2) / 3));	×
18	for (std::size_t i = 0; i < len; i += 3) {	×
19	unsigned val = static_cast<unsigned>(bytes[i]) << 16;	×
20	if (i + 1 < len) val \|= static_cast<unsigned>(bytes[i + 1]) << 8;	×
21	if (i + 2 < len) val \|= static_cast<unsigned>(bytes[i + 2]);	×
22	out.push_back(kBase64Chars[(val >> 18) & 0x3F]);	×
23	out.push_back(kBase64Chars[(val >> 12) & 0x3F]);	×
24	out.push_back((i + 1 < len) ? kBase64Chars[(val >> 6) & 0x3F] : '=');	×
25	out.push_back((i + 2 < len) ? kBase64Chars[val & 0x3F] : '=');	×
26	}
27	return out;	×
28	}	×
29
30	std::optional<std::string> base64_decode(std::string_view sv) {	×
31	static constexpr unsigned char DEC_TABLE[256] = {
32	// clang-format off
33	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
34	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
35	64,64,64,64,64,64,64,64,64,64,64,62,64,64,64,63,
36	52,53,54,55,56,57,58,59,60,61,64,64,64,64,64,64,
37	64, 0, 1, 2, 3, 4, 5, 6, 7, 8, 9,10,11,12,13,14,
38	15,16,17,18,19,20,21,22,23,24,25,64,64,64,64,64,
39	64,26,27,28,29,30,31,32,33,34,35,36,37,38,39,40,
40	41,42,43,44,45,46,47,48,49,50,51,64,64,64,64,64,
41	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
42	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
43	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
44	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
45	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
46	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
47	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
48	64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,64,
49	// clang-format on
50	};
51
52	if (sv.size() % 4 != 0) return std::nullopt;	×
53	std::string out;	×
54	out.reserve(sv.size() / 4 * 3);	×
55	for (std::size_t i = 0; i < sv.size(); i += 4) {	×
NEW 56	auto a = DEC_TABLE[static_cast<unsigned char>(sv[i])];	×
NEW 57	auto b = DEC_TABLE[static_cast<unsigned char>(sv[i + 1])];	×
NEW 58	auto c = DEC_TABLE[static_cast<unsigned char>(sv[i + 2])];	×
NEW 59	auto d = DEC_TABLE[static_cast<unsigned char>(sv[i + 3])];	×
60	if (a == 64 \|\| b == 64) return std::nullopt;	×
61	unsigned val = (a << 18) \| (b << 12);	×
62	out.push_back(static_cast<char>(val >> 16));	×
63	if (c != 64) {	×
64	val \|= (c << 6);	×
65	out.push_back(static_cast<char>((val >> 8) & 0xFF));	×
66	}
67	if (d != 64) {	×
68	val \|= d;	×
69	out.push_back(static_cast<char>(val & 0xFF));	×
70	}
71	}
72	return out;	×
73	}	×
74
75	} // namespace
76
77	// Wire format: 8 bytes file_index + 4 bytes chunk_index + 4 bytes line_offset
78	// (all little-endian), base64-encoded.
79	static constexpr std::size_t CURSOR_BYTES = 16;
80
81	std::string QueryCursor::encode() const {	×
82	unsigned char raw[CURSOR_BYTES];
83	std::memcpy(raw, &file_index, 8);	×
84	std::memcpy(raw + 8, &chunk_index, 4);	×
85	std::memcpy(raw + 12, &line_offset, 4);	×
NEW 86	return base64_encode(raw, CURSOR_BYTES);	×
87	}
88
89	std::optional<QueryCursor> QueryCursor::decode(std::string_view cursor) {	×
90	auto raw = base64_decode(cursor);	×
NEW 91	if (!raw \|\| raw->size() != CURSOR_BYTES) return std::nullopt;	×
92	QueryCursor c;	×
93	std::memcpy(&c.file_index, raw->data(), 8);	×
94	std::memcpy(&c.chunk_index, raw->data() + 8, 4);	×
95	std::memcpy(&c.line_offset, raw->data() + 12, 4);	×
96	return c;	×
97	}	×
98
99	} // namespace dftracer::utils::server

llnl / dftracer-utils / 23561935370

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