Logo ROOT  
Reference Guide
RConcurrentHashColl.cxx
Go to the documentation of this file.
3#include <ROOT/TSeq.hxx>
4#include <ROOT/RSha256.hxx>
5
6#include <memory>
7#include <set>
8
9namespace ROOT {
10namespace Internal {
11
12
13std::ostream &operator<<(std::ostream &os, const RConcurrentHashColl::HashValue &h)
14{
15 auto digest = h.Get();
16 os << digest[0] << "-" << digest[1] << "-" << digest[2] << "-" << digest[3];
17 return os;
18}
19
21{
22 // The cast here is because in the TBuffer ecosystem, the type used is char*
23 Sha256(reinterpret_cast<const unsigned char *>(data), len, fDigest);
24}
25
26struct RHashSet {
27 std::set<ROOT::Internal::RConcurrentHashColl::HashValue> fSet;
28};
29
31 : fHashSet(std::make_unique<RHashSet>()), fRWLock(std::make_unique<ROOT::TRWSpinLock>()){};
32
34
35/// Return true if the hash is already in already there
36bool RConcurrentHashColl::Find(const HashValue &hash) const
37{
39 return (fHashSet->fSet.end() != fHashSet->fSet.find(hash));
40}
41
42/// If the buffer is there, return false. Otherwise, insert the hash and return true
44{
45 return HashValue(buffer, len);
46}
47
48/// If the buffer is there, return false. Otherwise, insert the hash and return true
49bool RConcurrentHashColl::Insert(char *buffer, int len) const
50{
51 HashValue hash(buffer, len);
52
53 {
55 if (fHashSet->fSet.end() != fHashSet->fSet.find(hash))
56 return false;
57 }
58 {
60 fHashSet->fSet.insert(hash);
61 return true;
62 }
63}
64
65/// If the buffer is there, return false. Otherwise, insert the hash and return true
67{
69 auto ret = fHashSet->fSet.insert(hash);
70 return ret.second;
71}
72
73} // End NS Internal
74} // End NS ROOT
#define h(i)
Definition: RSha256.hxx:106
bool Insert(char *buf, int len) const
If the hash is there, return false. Otherwise, insert the hash and return true;.
std::unique_ptr< RHashSet > fHashSet
static HashValue Hash(char *buf, int len)
Return the hash object corresponding to the buffer.
std::unique_ptr< ROOT::TRWSpinLock > fRWLock
bool Find(const HashValue &hash) const
Return true if the hash is already in already there.
std::ostream & operator<<(std::ostream &os, const RConcurrentHashColl::HashValue &h)
void Sha256(const unsigned char *data, int len, ULong64_t *fDigest)
Definition: RSha256.hxx:267
tbb::task_arena is an alias of tbb::interface7::task_arena, which doesn't allow to forward declare tb...
Definition: RNumpyDS.hxx:30
std::set< ROOT::Internal::RConcurrentHashColl::HashValue > fSet