aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/on_disk
diff options
context:
space:
mode:
authorqwerty <qwerty@yandex-team.ru>2022-02-10 16:49:24 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:24 +0300
commit34e37ee57f5837a8da2fdfaccaac9bbe6c7f02ba (patch)
treec9e2dc7251a6743c4352ec4a4c717b18a1bd4da7 /library/cpp/on_disk
parent19bd45eb7775ffded0c62ab05d10b7326198aaa6 (diff)
downloadydb-34e37ee57f5837a8da2fdfaccaac9bbe6c7f02ba.tar.gz
Restoring authorship annotation for <qwerty@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/on_disk')
-rw-r--r--library/cpp/on_disk/chunks/chunked_helpers.h30
-rw-r--r--library/cpp/on_disk/chunks/writer.h2
2 files changed, 16 insertions, 16 deletions
diff --git a/library/cpp/on_disk/chunks/chunked_helpers.h b/library/cpp/on_disk/chunks/chunked_helpers.h
index 5fa96afdca..96fb795035 100644
--- a/library/cpp/on_disk/chunks/chunked_helpers.h
+++ b/library/cpp/on_disk/chunks/chunked_helpers.h
@@ -164,7 +164,7 @@ protected:
TPackedPair() {
Init(TKey(), TValue());
}
-
+
typename TTypeTraits<TKey>::TFuncParam First() const {
return Key;
}
@@ -187,7 +187,7 @@ protected:
protected:
static const ui16 VERSION_ID = 2;
-
+
#pragma pack(push, 8)
struct TInterval {
static const ui32 INVALID = (ui32)-1;
@@ -218,12 +218,12 @@ protected:
};
#pragma pack(pop)
static_assert(8 == sizeof(TInterval), "expect 8 == sizeof(TInterval)");
-
+
template <typename TKey>
static ui32 KeyHash(typename TTypeTraits<TKey>::TFuncParam key, ui16 bits) {
Y_ASSERT(bits < 32);
const ui32 res = ui32(key) & ((ui32(1) << bits) - 1);
-
+
Y_ASSERT(res < (ui32(1) << bits));
return res;
}
@@ -255,11 +255,11 @@ public:
void Save(IOutputStream& out) const {
Y_ASSERT(Data.size() < Max<ui32>());
-
+
WriteBin<ui16>(&out, VERSION_ID);
static const ui32 PAIR_SIZE = sizeof(TKeyValuePair);
WriteBin<ui32>(&out, PAIR_SIZE);
-
+
ui16 bits;
if (!Data.empty()) {
bits = (ui16)(log((float)Data.size()) / log(2.f));
@@ -270,12 +270,12 @@ public:
}
WriteBin<ui16>(&out, bits);
WriteBin<ui32>(&out, (ui32)Data.size());
-
+
const ui32 nBuckets = ui32(1) << bits;
TData2 data2(nBuckets);
for (size_t i = 0; i < Data.size(); ++i)
data2[KeyHash<TKey>(TKeyValuePair::GetFirst(&Data[i]), bits)].push_back(Data[i]);
-
+
typedef TVector<TInterval> TIntervals;
TIntervals intervals(nBuckets);
ui32 offset = 0;
@@ -302,21 +302,21 @@ template <typename TKey, typename TValue>
class TPlainHash : TPlainHashCommon {
private:
typedef TPackedPair<TKey, TValue> TKeyValuePair;
-
+
const char* P;
-
+
ui16 GetBits() const {
return ReadUnaligned<ui16>(P + 6);
}
-
+
ui32 GetSize() const {
return ReadUnaligned<ui32>(P + 8);
}
-
+
const TInterval* GetIntervals() const {
return (const TInterval*)(P + 12);
}
-
+
const TKeyValuePair* GetData() const {
return (const TKeyValuePair*)(GetIntervals() + (1ULL << GetBits()));
}
@@ -342,7 +342,7 @@ public:
TPlainHash(const char* p) {
Init(p);
}
-
+
TPlainHash(const TBlob& blob) {
Init(blob.Begin());
}
@@ -377,7 +377,7 @@ public:
TConstIterator End() const {
return GetData() + GetSize();
}
-
+
const char* ByteEnd() const {
return (const char*)(GetData() + GetSize());
}
diff --git a/library/cpp/on_disk/chunks/writer.h b/library/cpp/on_disk/chunks/writer.h
index ab14522bdd..00f0529fed 100644
--- a/library/cpp/on_disk/chunks/writer.h
+++ b/library/cpp/on_disk/chunks/writer.h
@@ -21,7 +21,7 @@ public:
}
void WriteFooter();
-
+
size_t GetCurrentBlockOffset() const;
size_t GetBlockCount() const;