/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 |