f379578a3 Release 1.7.1 040947ba2 CMake: Add language C to project() c60e87879 Update include catch.hpp to 2.13.8 6599d4828 Update change log ebd2e4f40 Allow setting C++ version to compile with in CMake config bbb2a95d0 Github actions: Only install x64 version of vcpkgs in windows build 546edf929 Avoid narrowing conversion by being explicit 91adaecd6 Fix various issues reported by clang-tidy and disable some checks 68f30a1f7 Add Github actions CI build for Linux/macOS/Windows c13886b78 Update some links bd429c52f Include tools subdirectory *after* testing is enabled 3133dc52f Use std::memcpy instead of just memcpy 7ee29422a Merge pull request #106 from daniel-j-h/fix-byteswap-ub aba0800aa CMake config: clang-tidy target needs writer_tests which need protobuf 74516e8df Modernize CMake config a little bit b4486ca7a Disable some clang-tidy warnings 19f4b75f6 Fix appveyor build 58b1a19a4 Modernize Doxygen config file 046c07d0e Update included catch2 framework to current version v2.13.7 49acea746 fix some doxygen warnings by removing obsolete config entries 0c5426df3 fix cmake dep warning: 'Compatibility with CMake < 2.8.12 will be removed from a future version of CMake' dadf7bd51 Fixes float and double byteswap undefined behavior 85db94025 Merge pull request #105 from ffontaine/master d3a35791d Merge pull request #104 from joto/master 03daae49c CMakeLists.txt: respect BUILD_TESTING 67133e362 Add missing includes 9f85f3a5e Update README.md 010ffcf69 Release 1.7.0 6ad492994 Fixed docs adde4dedf Travis: Add non-Intel architectures 37c3d0e1d Add typedefs and functions to make buffer adaptor work as container 83563acdb Remove delegating constructor because clang-tidy doesn't like it b4afc06db Use #include "" for library-internal includes d1929788e Add missing includes fae5247f0 Update change log 2abb1b5cd Travis: Test with std::string_view, not std::experimental::string_view 697bd812d Use forwarding constructor in fixed_size_buffer_adaptor c8fd2e819 Move fixed_size_buffer_adaptor into buffer_fixed.hpp abb856ecc Remove semicolon where it doesn't belong 6243855bc Change the way the customization for special buffer classes work d6a8ed098 Remove useless post-increment 184046cb0 Remove need for push_back() on custom buffer types 0a974e067 Remove templated buffer adaptor wrappers ed6ba5097 Add buffer implementation based on std::vector<char> cec309c3c Use more descriptive names for buffer test types a7b99da6f Use TEMPLATE_TEST_CASE to test different buffer implementations a0abc493c Use explicit for constructor 72850abc9 Remove broken doxygen link 1e347c620 Add more convenient fixed_size_buffer_adaptor constructor fb575e0ea Make members private 50e953b71 Make older compilers happy c850ef150 Extend tests of static buffer use f6d8394c0 Rename fixed_size_buffer to fixed_size_buffer_adaptor 3b18162e3 Make the buffer backend used by the pbf writer configurable. 6fd19c58d "Modernize" travis config 981aba084 Use explicit cast to avoid undefined behaviour 550974d5d Travis: Do not test GCC 4.7 any more 866e024fc Revert "Workaround in catch code so it compiles with older compilers" 65dfad056 Disable a clang-tidy test triggered by Catch. 02bf73df5 Workaround in catch code so it compiles with older compilers f98792a15 Travis: Do not update homebrew for faster builds 2d87da7ec Switch tests to Catch2 5dc45ac3b Avoid signed/unsigned comparison 3a93f19ba Add missing includes b49c077ac Disable clang-tidy for files where we don't have a compile command 34396fc7d Travis: Fix gcc8 build c3060101c Handle clang-tidy warnings 64ef96ff0 Revert "Initialize test messages" a0828d538 Travis: Also build with GCC 8 171c5c446 Update travis xcode versions f5a223aa7 Use "auto*" instead of just "auto" for pointer types e4fa23616 Initialize test messages e3a59454a Simpler code and avoid shadowing of external function 830f049b4 Use STL algorithms insted of raw loops faa7e6e8a Disable config settings not used in newer Doxygen versions 3b2e11438 Remove unnecessary enum name 7487f8109 Release 1.6.8 6dcaf8fde Travis config: Use "official" way to pull homebrew package. c61eb29c3 Revert "Disable warnings from clang-tidy about a missing file." 28d05a0a8 Disable warnings from clang-tidy about a missing file. 329920a3c Pesky aliases of clang-tidy warnings strike again. 79fd87922 User plain assert() instead of our own so compare() can be noexcept. 473e6ec13 Update change log. 393e279b7 Make pbf_writer destructor noexcept. 48a38b3f2 Disable clang-tidy misc-non-private-member-variables-in-classes. e9c148c8a Use no-argument version of main(). 29ba04123 Disable clang tidy checks for C arrays. 2fcfb56e2 More places to use std::array instead of a C style array. 7321761a3 Disable a clang-tidy warning. 4d9d8fff4 Make data_view::compare() noexcept. 3325364cf User uppercase integer literal suffix. df0a23c5e Use std::array instead of C arrays in some places. 8247ed76b Make clang-tidy include order check happy. f1b504e16 Update travis config to user newer compilers and operating systems. ccf692d47 Disable some clang-tidy warnings. 095abd259 CMake config: Also look for newer clang-tidy versions. 2c1f6f9c8 Use uppercase integer literal suffixes. fadd024d4 Release 1.6.7 8c6acbff7 Fix signed-unsigned comparison. b36774ccb Release 1.6.6 5a92b744f Remove useless asserts, simplify condition. 06bafb56c Fix several possible UBs. b7b290b1a Release 1.6.5 51753d514 Merge pull request #95 from tomhughes/subscript b90faaf03 Avoid out of bounds array subscript 7d418492e Merge pull request #94 from nigels-com/proto2 015f9cc5e Specify proto2 syntax to appease protoc 23d48fd2a Use universal initialization syntax in constructors. 0f610fad5 Update travis config: Use xenial for most builds. d71da0b04 Update appveyor config: Simpler builds, current MSVC, 32bit build 3ef46ba78 Release 1.6.4 3a1ef0138 Tighten some tests. 18eebb8c3 Remove unused code from tests. 29ef3e4e7 More casts to remove undefined behaviour. 6108e6480 No more bitwise operations on signed integers in zigzag encoder/decoder. 6e0d34985 Remove bitwise operations on signed integers in varint decoder. 4af65f262 Update change log. 2f82182fe Add some tips to test/create_pbf_test_data.sh. c55f4ed55 Fix some doxygen warnings. afa362a03 Add static_asserts to check movability of some classes. efeb45e0c Disable readability-implicit-bool-conversion clang-tidy warning. 78febda5b Explicit conversion and tests for new pbf_reader::data() function. 0d5492c9c Revert "Explicit conversion and tests for new pbf_reader::data() function." 43cf8fa5a Fix travis config. bd2ae4682 Explicit conversion and tests for new pbf_reader::data() function. 28cd406bd Update travis with newer compiler versions. 0555e6a1f Add function to get the not yet read data from a pbf_reader. bf4284bee Disable docker builds on travis. They are being phased out by travis. 5ffe45b71 New add_packed_fixed template function. e54cd858d Add helper function that computes the length a varint would have. 72d7e143a More consistent implementation of operators. 3a41880c2 Do not download protobuf library, it isn't found by cmake anyway. 3c662ce3c Remove comment that doesn't apply (any more). 45da6dd4d Update zigzag tests. 4ad573dbf Extra cast so we do the xor with unsigned ints. 509aec5ab Update appveyor build to current Visual Studio compiler. 67b24e1a3 Remove unnecessary workaround in Appveyor config. c559af682 Remove xcode6.4 build soon to be removed from travis. 0662dcecc Release 1.6.3 da5bfc019 Move byteswap_inplace functions from detail into protozero namespace. a44efc34e Travis: Ignore install problems on OSX. 5775b2b23 Travis update to newer OSX image. 032aa037c Special case the distance between default initialized iterators. 0ca02161e Make dereferencing operator of fixed_iterator noexcept. a0095f603 Test code must call functions that it wants to test. 6791b0bc3 Add unit tests. 191eb4004 Add some paranoia asserts. 99ca512f5 Use TEST_CASEs instead of SECTIOs in some tests. 040e2bc14 Add some asserts and tests. git-subtree-dir: third_party/protozero git-subtree-split: f379578a3f7c8162aac0ac31c2696de09a5b5f93
978 lines
34 KiB
C++
978 lines
34 KiB
C++
#ifndef PROTOZERO_PBF_READER_HPP
|
|
#define PROTOZERO_PBF_READER_HPP
|
|
|
|
/*****************************************************************************
|
|
|
|
protozero - Minimalistic protocol buffer decoder and encoder in C++.
|
|
|
|
This file is from https://github.com/mapbox/protozero where you can find more
|
|
documentation.
|
|
|
|
*****************************************************************************/
|
|
|
|
/**
|
|
* @file pbf_reader.hpp
|
|
*
|
|
* @brief Contains the pbf_reader class.
|
|
*/
|
|
|
|
#include "config.hpp"
|
|
#include "data_view.hpp"
|
|
#include "exception.hpp"
|
|
#include "iterators.hpp"
|
|
#include "types.hpp"
|
|
#include "varint.hpp"
|
|
|
|
#if PROTOZERO_BYTE_ORDER != PROTOZERO_LITTLE_ENDIAN
|
|
# include <protozero/byteswap.hpp>
|
|
#endif
|
|
|
|
#include <cstddef>
|
|
#include <cstdint>
|
|
#include <cstring>
|
|
#include <string>
|
|
#include <utility>
|
|
|
|
namespace protozero {
|
|
|
|
/**
|
|
* This class represents a protobuf message. Either a top-level message or
|
|
* a nested sub-message. Top-level messages can be created from any buffer
|
|
* with a pointer and length:
|
|
*
|
|
* @code
|
|
* std::string buffer;
|
|
* // fill buffer...
|
|
* pbf_reader message{buffer.data(), buffer.size()};
|
|
* @endcode
|
|
*
|
|
* Sub-messages are created using get_message():
|
|
*
|
|
* @code
|
|
* pbf_reader message{...};
|
|
* message.next();
|
|
* pbf_reader submessage = message.get_message();
|
|
* @endcode
|
|
*
|
|
* All methods of the pbf_reader class except get_bytes() and get_string()
|
|
* provide the strong exception guarantee, ie they either succeed or do not
|
|
* change the pbf_reader object they are called on. Use the get_view() method
|
|
* instead of get_bytes() or get_string(), if you need this guarantee.
|
|
*/
|
|
class pbf_reader {
|
|
|
|
// A pointer to the next unread data.
|
|
const char* m_data = nullptr;
|
|
|
|
// A pointer to one past the end of data.
|
|
const char* m_end = nullptr;
|
|
|
|
// The wire type of the current field.
|
|
pbf_wire_type m_wire_type = pbf_wire_type::unknown;
|
|
|
|
// The tag of the current field.
|
|
pbf_tag_type m_tag = 0;
|
|
|
|
template <typename T>
|
|
T get_fixed() {
|
|
T result;
|
|
const char* data = m_data;
|
|
skip_bytes(sizeof(T));
|
|
std::memcpy(&result, data, sizeof(T));
|
|
#if PROTOZERO_BYTE_ORDER != PROTOZERO_LITTLE_ENDIAN
|
|
byteswap_inplace(&result);
|
|
#endif
|
|
return result;
|
|
}
|
|
|
|
template <typename T>
|
|
iterator_range<const_fixed_iterator<T>> packed_fixed() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
const auto len = get_len_and_skip();
|
|
if (len % sizeof(T) != 0) {
|
|
throw invalid_length_exception{};
|
|
}
|
|
return {const_fixed_iterator<T>(m_data - len),
|
|
const_fixed_iterator<T>(m_data)};
|
|
}
|
|
|
|
template <typename T>
|
|
T get_varint() {
|
|
const auto val = static_cast<T>(decode_varint(&m_data, m_end));
|
|
return val;
|
|
}
|
|
|
|
template <typename T>
|
|
T get_svarint() {
|
|
protozero_assert((has_wire_type(pbf_wire_type::varint) || has_wire_type(pbf_wire_type::length_delimited)) && "not a varint");
|
|
return static_cast<T>(decode_zigzag64(decode_varint(&m_data, m_end)));
|
|
}
|
|
|
|
pbf_length_type get_length() {
|
|
return get_varint<pbf_length_type>();
|
|
}
|
|
|
|
void skip_bytes(pbf_length_type len) {
|
|
if (m_end - m_data < static_cast<ptrdiff_t>(len)) {
|
|
throw end_of_buffer_exception{};
|
|
}
|
|
m_data += len;
|
|
|
|
#ifndef NDEBUG
|
|
// In debug builds reset the tag to zero so that we can detect (some)
|
|
// wrong code.
|
|
m_tag = 0;
|
|
#endif
|
|
}
|
|
|
|
pbf_length_type get_len_and_skip() {
|
|
const auto len = get_length();
|
|
skip_bytes(len);
|
|
return len;
|
|
}
|
|
|
|
template <typename T>
|
|
iterator_range<T> get_packed() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
const auto len = get_len_and_skip();
|
|
return {T{m_data - len, m_data},
|
|
T{m_data, m_data}};
|
|
}
|
|
|
|
public:
|
|
|
|
/**
|
|
* Construct a pbf_reader message from a data_view. The pointer from the
|
|
* data_view will be stored inside the pbf_reader object, no data is
|
|
* copied. So you must make sure the view stays valid as long as the
|
|
* pbf_reader object is used.
|
|
*
|
|
* The buffer must contain a complete protobuf message.
|
|
*
|
|
* @post There is no current field.
|
|
*/
|
|
explicit pbf_reader(const data_view& view) noexcept
|
|
: m_data{view.data()},
|
|
m_end{view.data() + view.size()} {
|
|
}
|
|
|
|
/**
|
|
* Construct a pbf_reader message from a data pointer and a length. The
|
|
* pointer will be stored inside the pbf_reader object, no data is copied.
|
|
* So you must make sure the buffer stays valid as long as the pbf_reader
|
|
* object is used.
|
|
*
|
|
* The buffer must contain a complete protobuf message.
|
|
*
|
|
* @post There is no current field.
|
|
*/
|
|
pbf_reader(const char* data, std::size_t size) noexcept
|
|
: m_data{data},
|
|
m_end{data + size} {
|
|
}
|
|
|
|
#ifndef PROTOZERO_STRICT_API
|
|
/**
|
|
* Construct a pbf_reader message from a data pointer and a length. The
|
|
* pointer will be stored inside the pbf_reader object, no data is copied.
|
|
* So you must make sure the buffer stays valid as long as the pbf_reader
|
|
* object is used.
|
|
*
|
|
* The buffer must contain a complete protobuf message.
|
|
*
|
|
* @post There is no current field.
|
|
* @deprecated Use one of the other constructors.
|
|
*/
|
|
explicit pbf_reader(const std::pair<const char*, std::size_t>& data) noexcept
|
|
: m_data{data.first},
|
|
m_end{data.first + data.second} {
|
|
}
|
|
#endif
|
|
|
|
/**
|
|
* Construct a pbf_reader message from a std::string. A pointer to the
|
|
* string internals will be stored inside the pbf_reader object, no data
|
|
* is copied. So you must make sure the string is unchanged as long as the
|
|
* pbf_reader object is used.
|
|
*
|
|
* The string must contain a complete protobuf message.
|
|
*
|
|
* @post There is no current field.
|
|
*/
|
|
explicit pbf_reader(const std::string& data) noexcept
|
|
: m_data{data.data()},
|
|
m_end{data.data() + data.size()} {
|
|
}
|
|
|
|
/**
|
|
* pbf_reader can be default constructed and behaves like it has an empty
|
|
* buffer.
|
|
*/
|
|
pbf_reader() noexcept = default;
|
|
|
|
/// pbf_reader messages can be copied trivially.
|
|
pbf_reader(const pbf_reader&) noexcept = default;
|
|
|
|
/// pbf_reader messages can be moved trivially.
|
|
pbf_reader(pbf_reader&&) noexcept = default;
|
|
|
|
/// pbf_reader messages can be copied trivially.
|
|
pbf_reader& operator=(const pbf_reader& other) noexcept = default;
|
|
|
|
/// pbf_reader messages can be moved trivially.
|
|
pbf_reader& operator=(pbf_reader&& other) noexcept = default;
|
|
|
|
~pbf_reader() = default;
|
|
|
|
/**
|
|
* Swap the contents of this object with the other.
|
|
*
|
|
* @param other Other object to swap data with.
|
|
*/
|
|
void swap(pbf_reader& other) noexcept {
|
|
using std::swap;
|
|
swap(m_data, other.m_data);
|
|
swap(m_end, other.m_end);
|
|
swap(m_wire_type, other.m_wire_type);
|
|
swap(m_tag, other.m_tag);
|
|
}
|
|
|
|
/**
|
|
* In a boolean context the pbf_reader class evaluates to `true` if there
|
|
* are still fields available and to `false` if the last field has been
|
|
* read.
|
|
*/
|
|
operator bool() const noexcept { // NOLINT(google-explicit-constructor, hicpp-explicit-conversions)
|
|
return m_data != m_end;
|
|
}
|
|
|
|
/**
|
|
* Get a view of the not yet read data.
|
|
*/
|
|
data_view data() const noexcept {
|
|
return {m_data, static_cast<std::size_t>(m_end - m_data)};
|
|
}
|
|
|
|
/**
|
|
* Return the length in bytes of the current message. If you have
|
|
* already called next() and/or any of the get_*() functions, this will
|
|
* return the remaining length.
|
|
*
|
|
* This can, for instance, be used to estimate the space needed for a
|
|
* buffer. Of course you have to know reasonably well what data to expect
|
|
* and how it is encoded for this number to have any meaning.
|
|
*/
|
|
std::size_t length() const noexcept {
|
|
return std::size_t(m_end - m_data);
|
|
}
|
|
|
|
/**
|
|
* Set next field in the message as the current field. This is usually
|
|
* called in a while loop:
|
|
*
|
|
* @code
|
|
* pbf_reader message(...);
|
|
* while (message.next()) {
|
|
* // handle field
|
|
* }
|
|
* @endcode
|
|
*
|
|
* @returns `true` if there is a next field, `false` if not.
|
|
* @pre There must be no current field.
|
|
* @post If it returns `true` there is a current field now.
|
|
*/
|
|
bool next() {
|
|
if (m_data == m_end) {
|
|
return false;
|
|
}
|
|
|
|
const auto value = get_varint<uint32_t>();
|
|
m_tag = pbf_tag_type(value >> 3U);
|
|
|
|
// tags 0 and 19000 to 19999 are not allowed as per
|
|
// https://developers.google.com/protocol-buffers/docs/proto#assigning-tags
|
|
if (m_tag == 0 || (m_tag >= 19000 && m_tag <= 19999)) {
|
|
throw invalid_tag_exception{};
|
|
}
|
|
|
|
m_wire_type = pbf_wire_type(value & 0x07U);
|
|
switch (m_wire_type) {
|
|
case pbf_wire_type::varint:
|
|
case pbf_wire_type::fixed64:
|
|
case pbf_wire_type::length_delimited:
|
|
case pbf_wire_type::fixed32:
|
|
break;
|
|
default:
|
|
throw unknown_pbf_wire_type_exception{};
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
* Set next field with given tag in the message as the current field.
|
|
* Fields with other tags are skipped. This is usually called in a while
|
|
* loop for repeated fields:
|
|
*
|
|
* @code
|
|
* pbf_reader message{...};
|
|
* while (message.next(17)) {
|
|
* // handle field
|
|
* }
|
|
* @endcode
|
|
*
|
|
* or you can call it just once to get the one field with this tag:
|
|
*
|
|
* @code
|
|
* pbf_reader message{...};
|
|
* if (message.next(17)) {
|
|
* // handle field
|
|
* }
|
|
* @endcode
|
|
*
|
|
* Note that this will not check the wire type. The two-argument version
|
|
* of this function will also check the wire type.
|
|
*
|
|
* @returns `true` if there is a next field with this tag.
|
|
* @pre There must be no current field.
|
|
* @post If it returns `true` there is a current field now with the given tag.
|
|
*/
|
|
bool next(pbf_tag_type next_tag) {
|
|
while (next()) {
|
|
if (m_tag == next_tag) {
|
|
return true;
|
|
}
|
|
skip();
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* Set next field with given tag and wire type in the message as the
|
|
* current field. Fields with other tags are skipped. This is usually
|
|
* called in a while loop for repeated fields:
|
|
*
|
|
* @code
|
|
* pbf_reader message{...};
|
|
* while (message.next(17, pbf_wire_type::varint)) {
|
|
* // handle field
|
|
* }
|
|
* @endcode
|
|
*
|
|
* or you can call it just once to get the one field with this tag:
|
|
*
|
|
* @code
|
|
* pbf_reader message{...};
|
|
* if (message.next(17, pbf_wire_type::varint)) {
|
|
* // handle field
|
|
* }
|
|
* @endcode
|
|
*
|
|
* Note that this will also check the wire type. The one-argument version
|
|
* of this function will not check the wire type.
|
|
*
|
|
* @returns `true` if there is a next field with this tag.
|
|
* @pre There must be no current field.
|
|
* @post If it returns `true` there is a current field now with the given tag.
|
|
*/
|
|
bool next(pbf_tag_type next_tag, pbf_wire_type type) {
|
|
while (next()) {
|
|
if (m_tag == next_tag && m_wire_type == type) {
|
|
return true;
|
|
}
|
|
skip();
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/**
|
|
* The tag of the current field. The tag is the field number from the
|
|
* description in the .proto file.
|
|
*
|
|
* Call next() before calling this function to set the current field.
|
|
*
|
|
* @returns tag of the current field.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
*/
|
|
pbf_tag_type tag() const noexcept {
|
|
return m_tag;
|
|
}
|
|
|
|
/**
|
|
* Get the wire type of the current field. The wire types are:
|
|
*
|
|
* * 0 - varint
|
|
* * 1 - 64 bit
|
|
* * 2 - length-delimited
|
|
* * 5 - 32 bit
|
|
*
|
|
* All other types are illegal.
|
|
*
|
|
* Call next() before calling this function to set the current field.
|
|
*
|
|
* @returns wire type of the current field.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
*/
|
|
pbf_wire_type wire_type() const noexcept {
|
|
return m_wire_type;
|
|
}
|
|
|
|
/**
|
|
* Get the tag and wire type of the current field in one integer suitable
|
|
* for comparison with a switch statement.
|
|
*
|
|
* Use it like this:
|
|
*
|
|
* @code
|
|
* pbf_reader message{...};
|
|
* while (message.next()) {
|
|
* switch (message.tag_and_type()) {
|
|
* case tag_and_type(17, pbf_wire_type::length_delimited):
|
|
* ....
|
|
* break;
|
|
* case tag_and_type(21, pbf_wire_type::varint):
|
|
* ....
|
|
* break;
|
|
* default:
|
|
* message.skip();
|
|
* }
|
|
* }
|
|
* @endcode
|
|
*/
|
|
uint32_t tag_and_type() const noexcept {
|
|
return protozero::tag_and_type(tag(), wire_type());
|
|
}
|
|
|
|
/**
|
|
* Check the wire type of the current field.
|
|
*
|
|
* @returns `true` if the current field has the given wire type.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
*/
|
|
bool has_wire_type(pbf_wire_type type) const noexcept {
|
|
return wire_type() == type;
|
|
}
|
|
|
|
/**
|
|
* Consume the current field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
void skip() {
|
|
protozero_assert(tag() != 0 && "call next() before calling skip()");
|
|
switch (wire_type()) {
|
|
case pbf_wire_type::varint:
|
|
skip_varint(&m_data, m_end);
|
|
break;
|
|
case pbf_wire_type::fixed64:
|
|
skip_bytes(8);
|
|
break;
|
|
case pbf_wire_type::length_delimited:
|
|
skip_bytes(get_length());
|
|
break;
|
|
case pbf_wire_type::fixed32:
|
|
skip_bytes(4);
|
|
break;
|
|
default:
|
|
break;
|
|
}
|
|
}
|
|
|
|
///@{
|
|
/**
|
|
* @name Scalar field accessor functions
|
|
*/
|
|
|
|
/**
|
|
* Consume and return value of current "bool" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "bool".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
bool get_bool() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
protozero_assert(has_wire_type(pbf_wire_type::varint) && "not a varint");
|
|
const bool result = m_data[0] != 0;
|
|
skip_varint(&m_data, m_end);
|
|
return result;
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "enum" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "enum".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
int32_t get_enum() {
|
|
protozero_assert(has_wire_type(pbf_wire_type::varint) && "not a varint");
|
|
return get_varint<int32_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "int32" varint field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "int32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
int32_t get_int32() {
|
|
protozero_assert(has_wire_type(pbf_wire_type::varint) && "not a varint");
|
|
return get_varint<int32_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "sint32" varint field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "sint32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
int32_t get_sint32() {
|
|
protozero_assert(has_wire_type(pbf_wire_type::varint) && "not a varint");
|
|
return get_svarint<int32_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "uint32" varint field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "uint32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
uint32_t get_uint32() {
|
|
protozero_assert(has_wire_type(pbf_wire_type::varint) && "not a varint");
|
|
return get_varint<uint32_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "int64" varint field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "int64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
int64_t get_int64() {
|
|
protozero_assert(has_wire_type(pbf_wire_type::varint) && "not a varint");
|
|
return get_varint<int64_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "sint64" varint field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "sint64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
int64_t get_sint64() {
|
|
protozero_assert(has_wire_type(pbf_wire_type::varint) && "not a varint");
|
|
return get_svarint<int64_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "uint64" varint field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "uint64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
uint64_t get_uint64() {
|
|
protozero_assert(has_wire_type(pbf_wire_type::varint) && "not a varint");
|
|
return get_varint<uint64_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "fixed32" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "fixed32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
uint32_t get_fixed32() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
protozero_assert(has_wire_type(pbf_wire_type::fixed32) && "not a 32-bit fixed");
|
|
return get_fixed<uint32_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "sfixed32" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "sfixed32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
int32_t get_sfixed32() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
protozero_assert(has_wire_type(pbf_wire_type::fixed32) && "not a 32-bit fixed");
|
|
return get_fixed<int32_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "fixed64" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "fixed64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
uint64_t get_fixed64() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
protozero_assert(has_wire_type(pbf_wire_type::fixed64) && "not a 64-bit fixed");
|
|
return get_fixed<uint64_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "sfixed64" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "sfixed64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
int64_t get_sfixed64() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
protozero_assert(has_wire_type(pbf_wire_type::fixed64) && "not a 64-bit fixed");
|
|
return get_fixed<int64_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "float" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "float".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
float get_float() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
protozero_assert(has_wire_type(pbf_wire_type::fixed32) && "not a 32-bit fixed");
|
|
return get_fixed<float>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "double" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "double".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
double get_double() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
protozero_assert(has_wire_type(pbf_wire_type::fixed64) && "not a 64-bit fixed");
|
|
return get_fixed<double>();
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "bytes", "string", or "message"
|
|
* field.
|
|
*
|
|
* @returns A data_view object.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "bytes", "string", or "message".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
data_view get_view() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
protozero_assert(has_wire_type(pbf_wire_type::length_delimited) && "not of type string, bytes or message");
|
|
const auto len = get_len_and_skip();
|
|
return {m_data - len, len};
|
|
}
|
|
|
|
#ifndef PROTOZERO_STRICT_API
|
|
/**
|
|
* Consume and return value of current "bytes" or "string" field.
|
|
*
|
|
* @returns A pair with a pointer to the data and the length of the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "bytes" or "string".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
std::pair<const char*, pbf_length_type> get_data() {
|
|
protozero_assert(tag() != 0 && "call next() before accessing field value");
|
|
protozero_assert(has_wire_type(pbf_wire_type::length_delimited) && "not of type string, bytes or message");
|
|
const auto len = get_len_and_skip();
|
|
return {m_data - len, len};
|
|
}
|
|
#endif
|
|
|
|
/**
|
|
* Consume and return value of current "bytes" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "bytes".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
std::string get_bytes() {
|
|
return std::string(get_view());
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "string" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "string".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
std::string get_string() {
|
|
return std::string(get_view());
|
|
}
|
|
|
|
/**
|
|
* Consume and return value of current "message" field.
|
|
*
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "message".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
pbf_reader get_message() {
|
|
return pbf_reader{get_view()};
|
|
}
|
|
|
|
///@}
|
|
|
|
/// Forward iterator for iterating over bool (int32 varint) values.
|
|
using const_bool_iterator = const_varint_iterator< int32_t>;
|
|
|
|
/// Forward iterator for iterating over enum (int32 varint) values.
|
|
using const_enum_iterator = const_varint_iterator< int32_t>;
|
|
|
|
/// Forward iterator for iterating over int32 (varint) values.
|
|
using const_int32_iterator = const_varint_iterator< int32_t>;
|
|
|
|
/// Forward iterator for iterating over sint32 (varint) values.
|
|
using const_sint32_iterator = const_svarint_iterator<int32_t>;
|
|
|
|
/// Forward iterator for iterating over uint32 (varint) values.
|
|
using const_uint32_iterator = const_varint_iterator<uint32_t>;
|
|
|
|
/// Forward iterator for iterating over int64 (varint) values.
|
|
using const_int64_iterator = const_varint_iterator< int64_t>;
|
|
|
|
/// Forward iterator for iterating over sint64 (varint) values.
|
|
using const_sint64_iterator = const_svarint_iterator<int64_t>;
|
|
|
|
/// Forward iterator for iterating over uint64 (varint) values.
|
|
using const_uint64_iterator = const_varint_iterator<uint64_t>;
|
|
|
|
/// Forward iterator for iterating over fixed32 values.
|
|
using const_fixed32_iterator = const_fixed_iterator<uint32_t>;
|
|
|
|
/// Forward iterator for iterating over sfixed32 values.
|
|
using const_sfixed32_iterator = const_fixed_iterator<int32_t>;
|
|
|
|
/// Forward iterator for iterating over fixed64 values.
|
|
using const_fixed64_iterator = const_fixed_iterator<uint64_t>;
|
|
|
|
/// Forward iterator for iterating over sfixed64 values.
|
|
using const_sfixed64_iterator = const_fixed_iterator<int64_t>;
|
|
|
|
/// Forward iterator for iterating over float values.
|
|
using const_float_iterator = const_fixed_iterator<float>;
|
|
|
|
/// Forward iterator for iterating over double values.
|
|
using const_double_iterator = const_fixed_iterator<double>;
|
|
|
|
///@{
|
|
/**
|
|
* @name Repeated packed field accessor functions
|
|
*/
|
|
|
|
/**
|
|
* Consume current "repeated packed bool" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed bool".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_bool_iterator> get_packed_bool() {
|
|
return get_packed<pbf_reader::const_bool_iterator>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed enum" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed enum".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_enum_iterator> get_packed_enum() {
|
|
return get_packed<pbf_reader::const_enum_iterator>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed int32" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed int32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_int32_iterator> get_packed_int32() {
|
|
return get_packed<pbf_reader::const_int32_iterator>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed sint32" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed sint32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_sint32_iterator> get_packed_sint32() {
|
|
return get_packed<pbf_reader::const_sint32_iterator>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed uint32" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed uint32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_uint32_iterator> get_packed_uint32() {
|
|
return get_packed<pbf_reader::const_uint32_iterator>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed int64" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed int64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_int64_iterator> get_packed_int64() {
|
|
return get_packed<pbf_reader::const_int64_iterator>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed sint64" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed sint64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_sint64_iterator> get_packed_sint64() {
|
|
return get_packed<pbf_reader::const_sint64_iterator>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed uint64" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed uint64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_uint64_iterator> get_packed_uint64() {
|
|
return get_packed<pbf_reader::const_uint64_iterator>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed fixed32" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed fixed32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_fixed32_iterator> get_packed_fixed32() {
|
|
return packed_fixed<uint32_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed sfixed32" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed sfixed32".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_sfixed32_iterator> get_packed_sfixed32() {
|
|
return packed_fixed<int32_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed fixed64" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed fixed64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_fixed64_iterator> get_packed_fixed64() {
|
|
return packed_fixed<uint64_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed sfixed64" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed sfixed64".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_sfixed64_iterator> get_packed_sfixed64() {
|
|
return packed_fixed<int64_t>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed float" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed float".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_float_iterator> get_packed_float() {
|
|
return packed_fixed<float>();
|
|
}
|
|
|
|
/**
|
|
* Consume current "repeated packed double" field.
|
|
*
|
|
* @returns a pair of iterators to the beginning and one past the end of
|
|
* the data.
|
|
* @pre There must be a current field (ie. next() must have returned `true`).
|
|
* @pre The current field must be of type "repeated packed double".
|
|
* @post The current field was consumed and there is no current field now.
|
|
*/
|
|
iterator_range<pbf_reader::const_double_iterator> get_packed_double() {
|
|
return packed_fixed<double>();
|
|
}
|
|
|
|
///@}
|
|
|
|
}; // class pbf_reader
|
|
|
|
/**
|
|
* Swap two pbf_reader objects.
|
|
*
|
|
* @param lhs First object.
|
|
* @param rhs Second object.
|
|
*/
|
|
inline void swap(pbf_reader& lhs, pbf_reader& rhs) noexcept {
|
|
lhs.swap(rhs);
|
|
}
|
|
|
|
} // end namespace protozero
|
|
|
|
#endif // PROTOZERO_PBF_READER_HPP
|