lbug 0.18.0

An in-process property graph database management system built for query speed and scalability
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

#pragma once

#include <algorithm>
#include <array>
#include <cstdint>

#include "common/cast.h"

namespace lbug {
namespace common {

class Reader {
public:
    virtual void read(uint8_t* data, uint64_t size) = 0;
    virtual ~Reader() = default;

    virtual bool finished() = 0;
    virtual uint64_t getReadOffset() const { return 0; }
    virtual void skip(uint64_t size) {
        std::array<uint8_t, 4096> buffer{};
        while (size > 0) {
            const auto numBytesToRead = std::min<uint64_t>(size, buffer.size());
            read(buffer.data(), numBytesToRead);
            size -= numBytesToRead;
        }
    }
    virtual void onObjectBegin() {};
    virtual void onObjectEnd() {};

    template<typename TARGET>
    TARGET* cast() {
        return common::dynamic_cast_checked<TARGET*>(this);
    }
};

} // namespace common
} // namespace lbug