Bitcoin Core  0.20.99
P2P Digital Currency
checkqueue.cpp
Go to the documentation of this file.
1 // Copyright (c) 2015-2020 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 <bench/bench.h>
6 #include <checkqueue.h>
7 #include <key.h>
8 #include <prevector.h>
9 #include <pubkey.h>
10 #include <random.h>
11 #include <util/system.h>
12 
13 #include <boost/thread/thread.hpp>
14 
15 #include <vector>
16 
17 
18 static const int MIN_CORES = 2;
19 static const size_t BATCHES = 101;
20 static const size_t BATCH_SIZE = 30;
21 static const int PREVECTOR_SIZE = 28;
22 static const unsigned int QUEUE_BATCH_SIZE = 128;
23 
24 // This Benchmark tests the CheckQueue with a slightly realistic workload,
25 // where checks all contain a prevector that is indirect 50% of the time
26 // and there is a little bit of work done between calls to Add.
28 {
29  const ECCVerifyHandle verify_handle;
30  ECC_Start();
31 
32  struct PrevectorJob {
34  PrevectorJob(){
35  }
36  explicit PrevectorJob(FastRandomContext& insecure_rand){
37  p.resize(insecure_rand.randrange(PREVECTOR_SIZE*2));
38  }
39  bool operator()()
40  {
41  return true;
42  }
43  void swap(PrevectorJob& x){p.swap(x.p);};
44  };
46  boost::thread_group tg;
47  for (auto x = 0; x < std::max(MIN_CORES, GetNumCores()); ++x) {
48  tg.create_thread([&]{queue.Thread();});
49  }
50  while (state.KeepRunning()) {
51  // Make insecure_rand here so that each iteration is identical.
52  FastRandomContext insecure_rand(true);
53  CCheckQueueControl<PrevectorJob> control(&queue);
54  std::vector<std::vector<PrevectorJob>> vBatches(BATCHES);
55  for (auto& vChecks : vBatches) {
56  vChecks.reserve(BATCH_SIZE);
57  for (size_t x = 0; x < BATCH_SIZE; ++x)
58  vChecks.emplace_back(insecure_rand);
59  control.Add(vChecks);
60  }
61  // control waits for completion by RAII, but
62  // it is done explicitly here for clarity
63  control.Wait();
64  }
65  tg.interrupt_all();
66  tg.join_all();
67  ECC_Stop();
68 }
static const int MIN_CORES
Definition: checkqueue.cpp:18
static const int PREVECTOR_SIZE
Definition: checkqueue.cpp:21
void ECC_Start()
Initialize the elliptic curve support.
Definition: key.cpp:348
void resize(size_type new_size)
Definition: prevector.h:316
void Add(std::vector< T > &vChecks)
Definition: checkqueue.h:197
int GetNumCores()
Return the number of cores available on the current system.
Definition: system.cpp:1131
static const size_t BATCHES
Definition: checkqueue.cpp:19
bool KeepRunning()
Definition: bench.h:69
static void CCheckQueueSpeedPrevectorJob(benchmark::State &state)
Definition: checkqueue.cpp:27
RAII-style controller object for a CCheckQueue that guarantees the passed queue is finished before co...
Definition: checkqueue.h:17
static const unsigned int QUEUE_BATCH_SIZE
Definition: checkqueue.cpp:22
Users of this module must hold an ECCVerifyHandle.
Definition: pubkey.h:237
void swap(prevector< N, T, Size, Diff > &other)
Definition: prevector.h:461
void ECC_Stop()
Deinitialize the elliptic curve support.
Definition: key.cpp:365
Fast randomness source.
Definition: random.h:119
Queue for verifications that have to be performed.
Definition: checkqueue.h:30
BENCHMARK(CCheckQueueSpeedPrevectorJob, 1400)
Implements a drop-in replacement for std::vector<T> which stores up to N elements directly (without h...
Definition: prevector.h:37
static const size_t BATCH_SIZE
Definition: checkqueue.cpp:20
uint64_t randrange(uint64_t range) noexcept
Generate a random integer in the range [0..range).
Definition: random.h:190