Coverage Report

Created: 2026-04-29 19:21

next uncovered line (L), next uncovered region (R), next uncovered branch (B)
/tmp/bitcoin/src/node/minisketchwrapper.cpp
Line
Count
Source
1
// Copyright (c) 2021-present The Bitcoin Core developers
2
// Distributed under the MIT software license, see the accompanying
3
// file COPYING or http://www.opensource.org/licenses/mit-license.php.
4
5
#include <node/minisketchwrapper.h>
6
7
#include <logging.h>
8
#include <util/time.h>
9
10
#include <minisketch.h>
11
12
#include <algorithm>
13
#include <cstddef>
14
#include <cstdint>
15
#include <optional>
16
#include <utility>
17
#include <vector>
18
19
namespace node {
20
namespace {
21
22
static constexpr uint32_t BITS = 32;
23
24
uint32_t FindBestImplementation()
25
1
{
26
1
    std::optional<std::pair<SteadyClock::duration, uint32_t>> best;
27
28
1
    uint32_t max_impl = Minisketch::MaxImplementation();
29
2
    for (uint32_t impl = 0; impl <= max_impl; ++impl) {
30
1
        std::vector<SteadyClock::duration> benches;
31
1
        uint64_t offset = 0;
32
        /* Run a little benchmark with capacity 32, adding 184 entries, and decoding 11 of them once. */
33
12
        for (int b = 0; b < 11; ++b) {
34
11
            if (!Minisketch::ImplementationSupported(BITS, impl)) break;
35
11
            Minisketch sketch(BITS, impl, 32);
36
11
            auto start = SteadyClock::now();
37
1.11k
            for (uint64_t e = 0; e < 100; ++e) {
38
1.10k
                sketch.Add(e*1337 + b*13337 + offset);
39
1.10k
            }
40
935
            for (uint64_t e = 0; e < 84; ++e) {
41
924
                sketch.Add(e*1337 + b*13337 + offset);
42
924
            }
43
11
            offset += (*sketch.Decode(32))[0];
44
11
            auto stop = SteadyClock::now();
45
11
            benches.push_back(stop - start);
46
11
        }
47
        /* Remember which implementation has the best median benchmark time. */
48
1
        if (!benches.empty()) {
49
1
            std::sort(benches.begin(), benches.end());
50
1
            if (!best || best->first > benches[5]) {
51
1
                best = std::make_pair(benches[5], impl);
52
1
            }
53
1
        }
54
1
    }
55
1
    assert(best.has_value());
56
1
    LogInfo("Using Minisketch implementation number %i", best->second);
57
1
    return best->second;
58
1
}
59
60
uint32_t Minisketch32Implementation()
61
400
{
62
    // Fast compute-once idiom.
63
400
    static uint32_t best = FindBestImplementation();
64
400
    return best;
65
400
}
66
67
} // namespace
68
69
70
Minisketch MakeMinisketch32(size_t capacity)
71
400
{
72
400
    return Minisketch(BITS, Minisketch32Implementation(), capacity);
73
400
}
74
75
Minisketch MakeMinisketch32FP(size_t max_elements, uint32_t fpbits)
76
0
{
77
0
    return Minisketch::CreateFP(BITS, Minisketch32Implementation(), max_elements, fpbits);
78
0
}
79
} // namespace node