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
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
52
53
54
55
56
57
58
59
60
61
62
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "checksumaggregators.h"
#include <xxhash.h>
namespace proton::bucketdb {
using BucketChecksum = ChecksumAggregator::BucketChecksum;
using Timestamp = ChecksumAggregator::Timestamp;
using GlobalId = ChecksumAggregator::GlobalId;
namespace {
uint32_t
gidChecksum(const GlobalId &gid)
{
uint32_t i[3];
memcpy(i, gid.get(), GlobalId::LENGTH);
return i[0] + i[1] + i[2];
}
uint32_t
timestampChecksum(const Timestamp ×tamp)
{
return (timestamp >> 32) + timestamp;
}
uint32_t
calcChecksum(const GlobalId &gid, const Timestamp ×tamp)
{
return gidChecksum(gid) + timestampChecksum(timestamp);
}
uint64_t
compute(const GlobalId &gid, const Timestamp ×tamp) {
char buffer[20];
memcpy(&buffer[0], gid.get(), GlobalId::LENGTH);
uint64_t tmp = timestamp.getValue();
memcpy(&buffer[GlobalId::LENGTH], &tmp, sizeof(tmp));
return XXH64(buffer, sizeof(buffer), 0);
}
}
uint32_t
LegacyChecksumAggregator::addDoc(const GlobalId &gid, const Timestamp ×tamp, uint32_t checkSum) {
return add(calcChecksum(gid, timestamp), checkSum);
}
uint32_t
LegacyChecksumAggregator::removeDoc(const GlobalId &gid, const Timestamp ×tamp, uint32_t checkSum) {
return remove(calcChecksum(gid, timestamp), checkSum);
}
uint64_t
XXH64ChecksumAggregator::update(const GlobalId &gid, const Timestamp ×tamp, uint64_t checkSum) {
return update(compute(gid, timestamp), checkSum);
}
}
|
