mirror of
https://github.com/XRPLF/rippled.git
synced 2025-11-20 02:55:50 +00:00
Move varint out of NuDB
varint is no longer used by NuDB. It is now only used by codec.h in nodestore and so has been moved there.
This commit is contained in:
committed by
Nik Bougalis
parent
fd061bba8a
commit
8a6c7f9208
154
src/ripple/nodestore/impl/varint.h
Normal file
154
src/ripple/nodestore/impl/varint.h
Normal file
@@ -0,0 +1,154 @@
|
||||
//------------------------------------------------------------------------------
|
||||
/*
|
||||
This file is part of Beast: https://github.com/vinniefalco/Beast
|
||||
Copyright 2014, Vinnie Falco <vinnie.falco@gmail.com>
|
||||
|
||||
Permission to use, copy, modify, and/or distribute this software for any
|
||||
purpose with or without fee is hereby granted, provided that the above
|
||||
copyright notice and this permission notice appear in all copies.
|
||||
|
||||
THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
|
||||
WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
|
||||
MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
|
||||
ANY SPECIAL , DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
|
||||
WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
|
||||
ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
|
||||
OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
|
||||
*/
|
||||
//==============================================================================
|
||||
|
||||
#ifndef BEAST_NUDB_VARINT_H_INCLUDED
|
||||
#define BEAST_NUDB_VARINT_H_INCLUDED
|
||||
|
||||
#include <ripple/beast/nudb/detail/stream.h>
|
||||
#include <cstdint>
|
||||
#include <type_traits>
|
||||
|
||||
namespace ripple {
|
||||
namespace NodeStore {
|
||||
namespace detail {
|
||||
|
||||
// This is a variant of the base128 varint format from
|
||||
// google protocol buffers:
|
||||
// https://developers.google.com/protocol-buffers/docs/encoding#varints
|
||||
|
||||
// field tag
|
||||
struct varint;
|
||||
|
||||
// Metafuncton to return largest
|
||||
// possible size of T represented as varint.
|
||||
// T must be unsigned
|
||||
template <class T,
|
||||
bool = std::is_unsigned<T>::value>
|
||||
struct varint_traits;
|
||||
|
||||
template <class T>
|
||||
struct varint_traits<T, true>
|
||||
{
|
||||
static std::size_t constexpr max =
|
||||
(8 * sizeof(T) + 6) / 7;
|
||||
};
|
||||
|
||||
// Returns: Number of bytes consumed or 0 on error,
|
||||
// if the buffer was too small or t overflowed.
|
||||
//
|
||||
template <class = void>
|
||||
std::size_t
|
||||
read_varint (void const* buf,
|
||||
std::size_t buflen, std::size_t& t)
|
||||
{
|
||||
t = 0;
|
||||
std::uint8_t const* p =
|
||||
reinterpret_cast<
|
||||
std::uint8_t const*>(buf);
|
||||
std::size_t n = 0;
|
||||
while (p[n] & 0x80)
|
||||
if (++n >= buflen)
|
||||
return 0;
|
||||
if (++n > buflen)
|
||||
return 0;
|
||||
// Special case for 0
|
||||
if (n == 1 && *p == 0)
|
||||
{
|
||||
t = 0;
|
||||
return 1;
|
||||
}
|
||||
auto const used = n;
|
||||
while (n--)
|
||||
{
|
||||
auto const d = p[n];
|
||||
auto const t0 = t;
|
||||
t *= 127;
|
||||
t += d & 0x7f;
|
||||
if (t <= t0)
|
||||
return 0; // overflow
|
||||
}
|
||||
return used;
|
||||
}
|
||||
|
||||
template <class T,
|
||||
std::enable_if_t<std::is_unsigned<
|
||||
T>::value>* = nullptr>
|
||||
std::size_t
|
||||
size_varint (T v)
|
||||
{
|
||||
std::size_t n = 0;
|
||||
do
|
||||
{
|
||||
v /= 127;
|
||||
++n;
|
||||
}
|
||||
while (v != 0);
|
||||
return n;
|
||||
}
|
||||
|
||||
template <class = void>
|
||||
std::size_t
|
||||
write_varint (void* p0, std::size_t v)
|
||||
{
|
||||
std::uint8_t* p = reinterpret_cast<
|
||||
std::uint8_t*>(p0);
|
||||
do
|
||||
{
|
||||
std::uint8_t d =
|
||||
v % 127;
|
||||
v /= 127;
|
||||
if (v != 0)
|
||||
d |= 0x80;
|
||||
*p++ = d;
|
||||
}
|
||||
while (v != 0);
|
||||
return p - reinterpret_cast<
|
||||
std::uint8_t*>(p0);
|
||||
}
|
||||
|
||||
// input stream
|
||||
|
||||
template <class T, std::enable_if_t<
|
||||
std::is_same<T, varint>::value>* = nullptr>
|
||||
void
|
||||
read (beast::nudb::detail::istream& is, std::size_t& u)
|
||||
{
|
||||
auto p0 = is(1);
|
||||
auto p1 = p0;
|
||||
while (*p1++ & 0x80)
|
||||
is(1);
|
||||
read_varint(p0, p1 - p0, u);
|
||||
}
|
||||
|
||||
// output stream
|
||||
|
||||
template <class T, std::enable_if_t<
|
||||
std::is_same<T, varint>::value>* = nullptr>
|
||||
void
|
||||
write (beast::nudb::detail::ostream& os, std::size_t t)
|
||||
{
|
||||
write_varint(os.data(
|
||||
size_varint(t)), t);
|
||||
}
|
||||
|
||||
} // detail
|
||||
} // NodeStore
|
||||
} // ripple
|
||||
|
||||
#endif
|
||||
Reference in New Issue
Block a user