The SWC-DB Serializations C++ namespace 'SWC::Serialization'. More...
Functions | |
SWC_CAN_INLINE uint8_t | encoded_length (const Comm::EndPoint &endpoint) noexcept |
void | encode (uint8_t **bufp, const Comm::EndPoint &endpoint) |
Comm::EndPoint | decode (const uint8_t **bufp, size_t *remainp) |
uint32_t SWC_PURE_FUNC | encoded_length (const Comm::EndPoints &endpoints) noexcept |
void | encode (uint8_t **bufp, const Comm::EndPoints &endpoints) |
void | decode (const uint8_t **bufp, size_t *remainp, Comm::EndPoints &endpoints) |
SWC_CAN_INLINE Comm::EndPoints | decode_endpoints (const uint8_t **bufp, size_t *remainp) |
SWC_CAN_INLINE void | memcopy (void *dest, const uint8_t **bufp, size_t len) noexcept |
SWC_CAN_INLINE void | memcopy (uint8_t **bufp, const void *src, size_t len) noexcept |
constexpr SWC_CAN_INLINE void | decode_needed_one (size_t *remainp) |
constexpr SWC_CAN_INLINE void | decode_needed (size_t *remainp, size_t len) |
constexpr SWC_CAN_INLINE void | encode_i8 (uint8_t **bufp, uint8_t val) noexcept |
constexpr SWC_CAN_INLINE uint8_t | decode_i8 (const uint8_t **bufp, size_t *remainp) |
constexpr SWC_CAN_INLINE uint8_t | decode_byte (const uint8_t **bufp, size_t *remainp) |
constexpr SWC_CAN_INLINE void | encode_bool (uint8_t **bufp, bool bval) noexcept |
constexpr SWC_CAN_INLINE bool | decode_bool (const uint8_t **bufp, size_t *remainp) |
SWC_CAN_INLINE void | encode_i16 (uint8_t **bufp, uint16_t val) noexcept |
SWC_CAN_INLINE uint16_t | decode_i16 (const uint8_t **bufp, size_t *remainp) |
SWC_CAN_INLINE void | encode_i24 (uint8_t **bufp, uint24_t val) noexcept |
SWC_CAN_INLINE uint24_t | decode_i24 (const uint8_t **bufp, size_t *remainp) |
SWC_CAN_INLINE void | encode_i32 (uint8_t **bufp, uint32_t val) noexcept |
SWC_CAN_INLINE uint32_t | decode_i32 (const uint8_t **bufp, size_t *remainp) |
SWC_CAN_INLINE void | encode_i64 (uint8_t **bufp, uint64_t val) noexcept |
SWC_CAN_INLINE uint64_t | decode_i64 (const uint8_t **bufp, size_t *remainp) |
constexpr SWC_CAN_INLINE uint8_t | encoded_length_vi24 (uint24_t val) noexcept |
constexpr SWC_CAN_INLINE void | encode_vi24 (uint8_t **bufp, uint24_t val) |
constexpr SWC_CAN_INLINE uint24_t | decode_vi24 (const uint8_t **bufp, size_t *remainp) |
constexpr SWC_CAN_INLINE uint24_t | decode_vi24 (const uint8_t **bufp) |
constexpr SWC_CAN_INLINE uint8_t | encoded_length_vi32 (uint32_t val) noexcept |
constexpr SWC_CAN_INLINE void | encode_vi32 (uint8_t **bufp, uint32_t val) |
constexpr SWC_CAN_INLINE uint32_t | decode_vi32 (const uint8_t **bufp, size_t *remainp) |
constexpr SWC_CAN_INLINE uint32_t | decode_vi32 (const uint8_t **bufp) |
constexpr SWC_CAN_INLINE uint8_t | encoded_length_vi64 (uint64_t val) noexcept |
constexpr SWC_CAN_INLINE void | encode_vi64 (uint8_t **bufp, uint64_t val) |
constexpr SWC_CAN_INLINE uint64_t | decode_vi64 (const uint8_t **bufp, size_t *remainp) |
constexpr SWC_CAN_INLINE uint64_t | decode_vi64 (const uint8_t **bufp) |
template<uint8_t BITS, uint8_t SZ, typename T > | |
SWC_CAN_INLINE void | encode_fixed_vi (uint8_t **bufp, T val) noexcept |
template<uint8_t BITS, uint8_t SZ, typename T > | |
SWC_CAN_INLINE T | decode_fixed_vi (const uint8_t **bufp) noexcept |
constexpr SWC_CAN_INLINE uint8_t | encoded_length_fixed_vi24 (uint24_t val) noexcept |
SWC_CAN_INLINE void | encode_fixed_vi24 (uint8_t **bufp, uint24_t val) noexcept |
SWC_CAN_INLINE uint24_t | decode_fixed_vi24 (const uint8_t **bufp, size_t *remainp) |
SWC_CAN_INLINE uint24_t | decode_fixed_vi24 (const uint8_t **bufp) |
constexpr SWC_CAN_INLINE uint8_t | encoded_length_fixed_vi32 (uint32_t val) noexcept |
SWC_CAN_INLINE void | encode_fixed_vi32 (uint8_t **bufp, uint32_t val) noexcept |
SWC_CAN_INLINE uint32_t | decode_fixed_vi32 (const uint8_t **bufp, size_t *remainp) |
SWC_CAN_INLINE uint32_t | decode_fixed_vi32 (const uint8_t **bufp) |
constexpr SWC_CAN_INLINE uint8_t | encoded_length_fixed_vi64 (uint64_t val) noexcept |
SWC_CAN_INLINE void | encode_fixed_vi64 (uint8_t **bufp, uint64_t val) noexcept |
SWC_CAN_INLINE uint64_t | decode_fixed_vi64 (const uint8_t **bufp, size_t *remainp) |
SWC_CAN_INLINE uint64_t | decode_fixed_vi64 (const uint8_t **bufp) |
constexpr SWC_CAN_INLINE uint8_t | encoded_length_double () noexcept |
SWC_CAN_INLINE void | encode_double (uint8_t **bufp, long double val) noexcept |
SWC_CAN_INLINE long double | decode_double (const uint8_t **bufp, size_t *remainp) |
constexpr SWC_CAN_INLINE size_t | encoded_length_bytes (size_t len) noexcept |
SWC_CAN_INLINE void | encode_bytes (uint8_t **bufp, const void *data, size_t len) |
constexpr SWC_CAN_INLINE const uint8_t * | decode_bytes (const uint8_t **bufp, size_t *remainp, size_t *lenp) |
SWC_CAN_INLINE std::string | decode_bytes_string (const uint8_t **bufp, size_t *remainp) |
SWC_CAN_INLINE void | encode_bytes_fixed (uint8_t **bufp, const void *data, uint32_t len) noexcept |
constexpr SWC_CAN_INLINE const uint8_t * | decode_bytes_fixed (const uint8_t **bufp, size_t *remainp, uint32_t len) |
Variables | |
constexpr const uint64_t | MAX_V1B = 0x7f |
constexpr const uint64_t | MAX_V2B = 0x3fff |
constexpr const uint64_t | MAX_V3B = 0x1fffff |
constexpr const uint64_t | MAX_V4B = 0x0fffffff |
constexpr const uint64_t | MAX_V5B = 0x07ffffffff |
constexpr const uint64_t | MAX_V6B = 0x03ffffffffff |
constexpr const uint64_t | MAX_V7B = 0x01ffffffffffff |
constexpr const uint64_t | MAX_V8B = 0x00ffffffffffffff |
constexpr const uint64_t | MAX_V9B = 0x7fffffffffffffff |
constexpr const uint8_t | MAX_LEN_VINT24 = 4 |
constexpr const uint8_t | MAX_LEN_VINT32 = 5 |
constexpr const uint8_t | MAX_LEN_VINT64 = 10 |
The SWC-DB Serializations C++ namespace 'SWC::Serialization'.
Comm::EndPoint SWC::Serialization::decode | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 35 of file Resolver.cc.
References decode_bool(), decode_bytes_fixed(), and decode_i16().
Referenced by SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::decode(), decode(), SWC::DB::RgrData::decode(), decode_endpoints(), SWC::Comm::Protocol::Mngr::Params::MngrActiveRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RgrMngId::internal_decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::internal_decode(), and SWC::Comm::Protocol::Mngr::Params::MngrState::internal_decode().
void SWC::Serialization::decode | ( | const uint8_t ** | bufp, |
size_t * | remainp, | ||
Comm::EndPoints & | endpoints | ||
) |
Definition at line 67 of file Resolver.cc.
References SWC::Core::Vector< T, SizeT, GROW_SZ >::clear(), decode(), decode_vi32(), SWC::Core::Vector< T, SizeT, GROW_SZ >::emplace_back(), SWC::Core::Vector< T, SizeT, GROW_SZ >::reserve(), and SWC::Core::Vector< T, SizeT, GROW_SZ >::shrink_to_fit().
|
constexpr |
Definition at line 107 of file Serialization.h.
References decode_i8().
Referenced by SWC::FS::Dirent::decode(), decode(), SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RgrGetReq::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeLoaded::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectRsp::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::ExistsRsp::internal_decode(), and SWC::Comm::Protocol::Mngr::Params::RgrUpdate::internal_decode().
|
constexpr |
Definition at line 97 of file Serialization.h.
References decode_i8().
|
constexpr |
Definition at line 548 of file Serialization.h.
References decode_needed(), and decode_vi64().
Referenced by SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::convert_less_to(), SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::convert_to(), decode_bytes_string(), SWC::DB::Cell::Serial::Value::Field_BYTES::Field_BYTES(), SWC::DB::Specs::Serial::Value::Field_BYTES::Field_BYTES(), SWC::DB::Specs::Serial::Value::Field_LIST_BYTES::Field_LIST_BYTES(), SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::Field_LIST_BYTES(), SWC::DB::Specs::Serial::Value::Field_LIST_INT64::Field_LIST_INT64(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::Field_LIST_INT64(), SWC::DB::Specs::IntervalUpdate::IntervalUpdate(), SWC::DB::Specs::Serial::Value::Field_LIST_BYTES::is_matching(), and SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::print().
|
constexpr |
Definition at line 574 of file Serialization.h.
References decode_needed().
Referenced by decode().
SWC_CAN_INLINE std::string SWC::Serialization::decode_bytes_string | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 558 of file Serialization.h.
References decode_bytes().
Referenced by SWC::FS::Dirent::decode(), SWC::Comm::Protocol::Mngr::Params::ColumnGetReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnListReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::CreateReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::ExistsReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::LengthReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::MkdirsReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::OpenReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::ReadAllReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::ReaddirReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::RemoveReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::RenameReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::RmdirReq::internal_decode(), and SWC::Comm::Protocol::FsBroker::Params::WriteReq::internal_decode().
SWC_CAN_INLINE long double SWC::Serialization::decode_double | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 527 of file Serialization.h.
References decode_needed(), encoded_length_double(), and memcopy().
SWC_CAN_INLINE Comm::EndPoints SWC::Serialization::decode_endpoints | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 81 of file Resolver.h.
References decode().
|
noexcept |
Definition at line 336 of file Serialization.h.
SWC_CAN_INLINE uint24_t SWC::Serialization::decode_fixed_vi24 | ( | const uint8_t ** | bufp | ) |
Definition at line 383 of file Serialization.h.
References decode_fixed_vi24().
SWC_CAN_INLINE uint24_t SWC::Serialization::decode_fixed_vi24 | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 367 of file Serialization.h.
References decode_i8(), and decode_needed().
Referenced by decode_fixed_vi24().
SWC_CAN_INLINE uint32_t SWC::Serialization::decode_fixed_vi32 | ( | const uint8_t ** | bufp | ) |
Definition at line 434 of file Serialization.h.
References decode_fixed_vi32().
SWC_CAN_INLINE uint32_t SWC::Serialization::decode_fixed_vi32 | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 416 of file Serialization.h.
References decode_i8(), and decode_needed().
Referenced by decode_fixed_vi32().
SWC_CAN_INLINE uint64_t SWC::Serialization::decode_fixed_vi64 | ( | const uint8_t ** | bufp | ) |
Definition at line 509 of file Serialization.h.
References decode_fixed_vi64().
SWC_CAN_INLINE uint64_t SWC::Serialization::decode_fixed_vi64 | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 483 of file Serialization.h.
References decode_i8(), and decode_needed().
Referenced by decode_fixed_vi64().
SWC_CAN_INLINE uint16_t SWC::Serialization::decode_i16 | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 117 of file Serialization.h.
References decode_needed(), and memcopy().
Referenced by SWC::Comm::Header::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::decode(), and decode().
SWC_CAN_INLINE uint24_t SWC::Serialization::decode_i24 | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 130 of file Serialization.h.
References decode_needed(), and memcopy().
SWC_CAN_INLINE uint32_t SWC::Serialization::decode_i32 | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 143 of file Serialization.h.
References decode_needed(), and memcopy().
Referenced by SWC::Comm::Header::decode(), SWC::Comm::BufferInfo::decode(), SWC::Ranger::CellStore::Block::Header::decode(), SWC::Comm::Protocol::Mngr::Req::ClusterStatus::handle(), SWC::Comm::Protocol::Mngr::Req::ColumnStatus::handle(), SWC::Comm::Protocol::Mngr::Req::RangersStatus::handle(), SWC::Comm::Protocol::Mngr::Req::ManagersStatus::handle(), SWC::Comm::Protocol::Rgr::Req::ReportRes::handle(), SWC::Comm::Protocol::Rgr::Req::ReportCids::handle(), SWC::Comm::Protocol::Rgr::Req::ReportColumnRids::handle(), SWC::Comm::Protocol::Rgr::Req::ReportColumnsRanges::handle(), SWC::Comm::Protocol::Mngr::Params::MngrState::internal_decode(), SWC::Ranger::RangeData::load(), SWC::Common::Files::Schema::load(), SWC::Ranger::CellStore::Read::load_blocks_index(), SWC::Ranger::CellStore::Block::Read::load_header(), SWC::Ranger::CommitLog::Fragment::load_header(), SWC::Ranger::CellStore::Read::load_trailer(), SWC::Common::Files::RgrData::read(), SWC::Comm::Event::response_code(), and SWC::Manager::Schemas::store_load().
SWC_CAN_INLINE uint64_t SWC::Serialization::decode_i64 | ( | const uint8_t ** | bufp, |
size_t * | remainp | ||
) |
Definition at line 156 of file Serialization.h.
References decode_needed(), and memcopy().
Referenced by SWC::DB::Cells::Cell::Cell(), SWC::DB::Specs::Timestamp::decode(), SWC::Comm::Protocol::Mngr::Params::MngrState::internal_decode(), SWC::Ranger::CellStore::Read::load_trailer(), SWC::DB::Cells::Cell::read(), SWC::Manager::Schemas::store_load(), and SWC::DB::Specs::Timestamp::Timestamp().
|
constexpr |
Definition at line 91 of file Serialization.h.
References decode_needed_one().
Referenced by SWC::DB::Cells::Cell::Cell(), SWC::Comm::Header::decode(), SWC::Comm::BufferInfo::decode(), SWC::DB::Specs::Flags::decode(), SWC::DB::Specs::Fraction::decode(), SWC::DB::Specs::Timestamp::decode(), SWC::DB::SchemaPrimitives::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::RangeStatus::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::Column::decode(), SWC::Ranger::CellStore::Block::Header::decode(), SWC::DB::Specs::Interval::decode(), SWC::DB::Specs::Value::decode(), SWC::DB::Cell::Serial::Value::FieldUpdate::decode(), SWC::DB::Cell::Serial::Value::FieldUpdate_MATH::decode(), SWC::DB::Cell::Serial::Value::FieldUpdate_LIST::decode(), decode_bool(), decode_byte(), decode_fixed_vi24(), decode_fixed_vi32(), decode_fixed_vi64(), SWC::Ranger::CellStore::Block::Header::decode_idx(), SWC::Comm::Header::decode_prefix(), SWC::DB::Specs::Serial::Value::Field_LIST_BYTES::Field_LIST_BYTES(), SWC::DB::Specs::Serial::Value::Field_LIST_INT64::Field_LIST_INT64(), SWC::DB::Cells::Cell::get_value(), SWC::Comm::Protocol::Mngr::Params::ColumnGetReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnGetRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnListReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnMng::internal_decode(), SWC::Comm::Protocol::Mngr::Params::MngrActiveReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RgrMngId::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeLocateReq::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeUnload::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeUnloadRsp::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::AppendReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::CreateReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::WriteReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnUpdate::internal_decode(), SWC::Ranger::RangeData::load(), SWC::Common::Files::Schema::load(), SWC::Ranger::CellStore::Read::load_blocks_index(), SWC::Ranger::CommitLog::Fragment::load_header(), SWC::Ranger::CellStore::Read::load_trailer(), SWC::Comm::Protocol::Mngr::Handler::Report::operator()(), SWC::Comm::Protocol::Rgr::Handler::Report::operator()(), SWC::DB::Cells::Cell::read(), SWC::DB::Cell::Serial::Value::read_type(), and SWC::Manager::Schemas::store_load().
|
constexpr |
Definition at line 76 of file Serialization.h.
References SWC::Error::SERIALIZATION_INPUT_OVERRUN, SWC_FMT_LU, and SWC_THROWF.
Referenced by decode_bytes(), decode_bytes_fixed(), decode_double(), decode_fixed_vi24(), decode_fixed_vi32(), decode_fixed_vi64(), decode_i16(), decode_i24(), decode_i32(), and decode_i64().
|
constexpr |
Definition at line 68 of file Serialization.h.
References SWC::Error::SERIALIZATION_INPUT_OVERRUN, and SWC_THROW.
Referenced by decode_i8().
|
constexpr |
Definition at line 227 of file Serialization.h.
References decode_vi24().
|
constexpr |
Definition at line 217 of file Serialization.h.
References SWC_DECODE_VI_1, and SWC_THROW_OVERRUN.
Referenced by SWC::DB::KeySeq::align(), SWC::DB::KeySeq::compare(), SWC::DB::KeySeq::compare_opt(), SWC::DB::Cell::Key::convert_to(), SWC::DB::Cell::Key::copy(), SWC::DB::Cell::Serial::Value::Field::decode(), SWC::DB::Cell::Key::decode(), SWC::DB::Cell::Serial::Value::FieldUpdate_LIST::decode(), SWC::DB::Cell::Serial::Value::FieldUpdate_LIST_ITEMS< UpdateField_T, ValueT >::decode(), decode_vi24(), SWC::DB::Cell::Key::display(), SWC::DB::Cell::Key::equal(), SWC::DB::Cell::Serial::Value::FieldUpdate_LIST_ITEMS< UpdateField_T, ValueT >::FieldUpdate_LIST_ITEMS(), SWC::DB::Cell::Key::get(), SWC::DB::Cell::Key::insert(), SWC::DB::Specs::Key::is_matching(), SWC::DB::Cell::Key::Key(), SWC::DB::Cell::Serial::Value::read_field_id(), and SWC::DB::Cell::Key::remove().
|
constexpr |
Definition at line 266 of file Serialization.h.
References decode_vi32().
|
constexpr |
Definition at line 254 of file Serialization.h.
References SWC_DECODE_VI_1, and SWC_THROW_OVERRUN.
Referenced by SWC::DB::Cells::Cell::Cell(), SWC::Comm::BufferInfo::decode(), SWC::Comm::Serializable::decode(), SWC::DB::Cell::KeyVec::decode(), SWC::DB::Specs::Column::decode(), SWC::DB::Specs::Flags::decode(), SWC::DB::Specs::Fraction::decode(), SWC::DB::Specs::Key::decode(), SWC::DB::Specs::Scan::decode(), SWC::DB::SchemaPrimitives::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::decode(), SWC::DB::Specs::Value::decode(), decode(), SWC::Ranger::CellStore::Readers::decode(), SWC::Ranger::CellStore::Block::Header::decode_idx(), decode_vi32(), SWC::DB::Cell::Serial::Value::FieldUpdate_Ext< UpdateField_T >::ext_decode(), SWC::DB::Cells::Cell::get_value(), SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::internal_decode(), SWC::Comm::Protocol::Bkr::Params::CellsUpdateRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnCompactRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnListReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RangeCreateRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RangeRemoveRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RangeUnloadedRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::ColumnCompactRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeLocateRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeUnloadRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspRes::internal_decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::AppendReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::AppendRsp::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::CloseReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::CreateReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::FlushReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::OpenReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::OpenRsp::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::PreadReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::ReadReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::SeekReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::SyncReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::WriteReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnUpdate::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RgrUpdate::internal_decode(), SWC::Ranger::CellStore::Read::load_blocks_index(), SWC::DB::Cells::Cell::read(), SWC::DB::Specs::Key::set(), and SWC::DB::Cells::TSV::FileWriter::write().
|
constexpr |
Definition at line 319 of file Serialization.h.
References decode_vi64().
|
constexpr |
Definition at line 302 of file Serialization.h.
References SWC_DECODE_VI_1, and SWC_THROW_OVERRUN.
Referenced by SWC::Ranger::Range::check_meta(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::convert_less_to(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::convert_to(), SWC::DB::Specs::Column::decode(), SWC::DB::Specs::Flags::decode(), SWC::DB::Specs::KeyIntervals::decode(), SWC::DB::SchemaPrimitives::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::RangeStatus::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::Range::decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::Column::decode(), SWC::FS::Dirent::decode(), SWC::DB::Specs::Interval::decode(), SWC::DB::Specs::Values::decode(), SWC::DB::RgrData::decode(), decode_bytes(), SWC::Ranger::CellStore::Block::Header::decode_idx(), decode_vi64(), SWC::DB::Cells::Cell::display(), SWC::DB::Specs::Serial::Value::Field_LIST_INT64::Field_LIST_INT64(), SWC::DB::Cells::Cell::get_counter(), SWC::Manager::ColumnHealthCheck::ColumnMerger::RangesMerger::handle(), SWC::Comm::Protocol::Bkr::Params::CellsSelectReq::internal_decode(), SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::internal_decode(), SWC::Comm::Protocol::Bkr::Params::CellsUpdateReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnCompactReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnGetReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnGetRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnListRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::MngrActiveReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RangeCreateReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RangeCreateRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RangeRemoveReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RangeUnloadedReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::Report::ReqColumnStatus::internal_decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::internal_decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::internal_decode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RgrGetReq::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::RgrMngId::internal_decode(), SWC::Comm::Protocol::Rgr::Params::ColumnCompactReq::internal_decode(), SWC::Comm::Protocol::Rgr::Params::ColumnDelete::internal_decode(), SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadReq::internal_decode(), SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedReq::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeLoad::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeLoaded::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeLocateReq::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeLocateRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectReq::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectRsp::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateReq::internal_decode(), SWC::Comm::Protocol::Rgr::Params::RangeUnload::internal_decode(), SWC::Comm::Protocol::Rgr::Params::Report::ReqColumn::internal_decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspRes::internal_decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspCids::internal_decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnRids::internal_decode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::AppendRsp::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::LengthRsp::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::PreadReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::ReadRsp::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::ReaddirRsp::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::SeekReq::internal_decode(), SWC::Comm::Protocol::FsBroker::Params::SeekRsp::internal_decode(), SWC::Comm::Protocol::Mngr::Params::ColumnUpdate::internal_decode(), SWC::DB::Specs::Serial::Value::Field_LIST_INT64::is_matching(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::print(), SWC::Manager::ColumnHealthCheck::ColumnMerger::run(), SWC::Ranger::Callback::RangeLocateScan::selector(), and SWC::Ranger::Callback::RangeLocateScanCommit::selector().
void SWC::Serialization::encode | ( | uint8_t ** | bufp, |
const Comm::EndPoint & | endpoint | ||
) |
Definition at line 22 of file Resolver.cc.
References encode_bool(), encode_bytes_fixed(), and encode_i16().
Referenced by SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::encode(), SWC::Manager::MngrStatus::encode(), SWC::Manager::Ranger::encode(), SWC::DB::RgrData::encode(), encode(), SWC::Comm::Protocol::Mngr::Params::MngrActiveRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RgrMngId::internal_encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::internal_encode(), and SWC::Comm::Protocol::Mngr::Params::MngrState::internal_encode().
void SWC::Serialization::encode | ( | uint8_t ** | bufp, |
const Comm::EndPoints & | endpoints | ||
) |
Definition at line 61 of file Resolver.cc.
References encode(), encode_vi32(), and SWC::Core::Vector< T, SizeT, GROW_SZ >::size().
|
constexprnoexcept |
Definition at line 102 of file Serialization.h.
References encode_i8().
Referenced by SWC::FS::Dirent::encode(), encode(), SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RgrGetReq::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeLoaded::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectRsp::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::ExistsRsp::internal_encode(), and SWC::Comm::Protocol::Mngr::Params::RgrUpdate::internal_encode().
SWC_CAN_INLINE void SWC::Serialization::encode_bytes | ( | uint8_t ** | bufp, |
const void * | data, | ||
size_t | len | ||
) |
Definition at line 542 of file Serialization.h.
References data, encode_vi64(), and memcopy().
Referenced by SWC::Comm::Buffers::create_error_message(), SWC::DB::Specs::IntervalUpdate::encode(), SWC::DB::Schema::encode(), SWC::FS::Dirent::encode(), SWC::DB::Cell::Serial::Value::Field_BYTES::encode(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::encode(), SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::encode(), SWC::DB::Specs::Serial::Value::Field_BYTES::encode(), SWC::DB::Specs::Serial::Value::Field_LIST_INT64::encode(), SWC::DB::Specs::Serial::Value::Field_LIST_BYTES::encode(), SWC::Comm::Protocol::Mngr::Params::ColumnGetReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnListReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::CreateReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::ExistsReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::LengthReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::MkdirsReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::OpenReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::ReadAllReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::ReaddirReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::RemoveReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::RenameReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::RmdirReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::WriteReq::internal_encode(), SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::set_from(), and SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::write().
|
noexcept |
Definition at line 568 of file Serialization.h.
References data, and memcopy().
Referenced by encode().
|
noexcept |
Definition at line 522 of file Serialization.h.
References encoded_length_double(), and memcopy().
Referenced by SWC::DB::Cell::Serial::Value::Field_DOUBLE::encode(), and SWC::DB::Specs::Serial::Value::Field_DOUBLE::encode().
|
noexcept |
Definition at line 327 of file Serialization.h.
|
noexcept |
Definition at line 356 of file Serialization.h.
References encode_i8().
|
noexcept |
Definition at line 403 of file Serialization.h.
References encode_i8().
|
noexcept |
Definition at line 462 of file Serialization.h.
References encode_i8().
|
noexcept |
Definition at line 112 of file Serialization.h.
References memcopy().
Referenced by SWC::Comm::Header::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::encode(), SWC::Manager::Ranger::encode(), and encode().
|
noexcept |
Definition at line 125 of file Serialization.h.
References memcopy().
|
noexcept |
Definition at line 138 of file Serialization.h.
References memcopy().
Referenced by SWC::Comm::Buffers::append_i32(), SWC::Core::checksum_i32(), SWC::Comm::Buffers::create_error_message(), SWC::Ranger::CellStore::Block::Header::encode(), SWC::Comm::Header::encode(), SWC::Manager::MngrStatus::encode(), SWC::Comm::Protocol::Mngr::Params::MngrState::internal_encode(), SWC::Common::Files::RgrData::set_rgr(), SWC::Manager::Schemas::store_make_block(), SWC::Ranger::RangeData::write(), SWC::Ranger::CommitLog::Fragment::write(), SWC::Common::Files::Schema::write(), SWC::Ranger::CellStore::Write::write_blocks_index(), and SWC::Ranger::CellStore::Write::write_trailer().
|
noexcept |
Definition at line 151 of file Serialization.h.
References memcopy().
Referenced by SWC::DB::Specs::Timestamp::encode(), SWC::Comm::Protocol::Mngr::Params::MngrState::internal_encode(), SWC::Manager::Schemas::store_make_block(), SWC::DB::Cells::Cell::write(), and SWC::Ranger::CellStore::Write::write_trailer().
|
constexprnoexcept |
Definition at line 85 of file Serialization.h.
Referenced by SWC::Comm::Buffers::append_i8(), SWC::Ranger::CellStore::Block::Header::encode(), SWC::Comm::Header::encode(), SWC::DB::Cell::Serial::Value::FieldUpdate::encode(), SWC::DB::Specs::Flags::encode(), SWC::DB::Specs::Interval::encode(), SWC::DB::Specs::IntervalUpdate::encode(), SWC::DB::Specs::Fraction::encode(), SWC::DB::Specs::Timestamp::encode(), SWC::DB::Specs::UpdateOP::encode(), SWC::DB::Specs::Value::encode(), SWC::DB::SchemaPrimitives::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::RangeStatus::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::Column::encode(), SWC::Manager::MngrStatus::encode(), SWC::Manager::Ranger::encode(), SWC::DB::Cell::Serial::Value::FieldUpdate_MATH::encode(), SWC::DB::Cell::Serial::Value::FieldUpdate_LIST::encode(), SWC::DB::Specs::Serial::Value::Field_INT64::encode(), SWC::DB::Specs::Serial::Value::Field_DOUBLE::encode(), SWC::DB::Specs::Serial::Value::Field_BYTES::encode(), SWC::DB::Specs::Serial::Value::Field_KEY::encode(), SWC::DB::Specs::Serial::Value::Field_LIST_INT64::encode(), SWC::DB::Specs::Serial::Value::Field_LIST_BYTES::encode(), SWC::DB::Cell::Serial::Value::Field::encode(), SWC::DB::Specs::Serial::Value::Field::encode(), encode_bool(), encode_fixed_vi24(), encode_fixed_vi32(), encode_fixed_vi64(), SWC::Ranger::CellStore::Block::Header::encode_idx(), SWC::Comm::Protocol::Mngr::Params::ColumnGetReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnGetRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnListReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnMng::internal_encode(), SWC::Comm::Protocol::Mngr::Params::MngrActiveReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RgrMngId::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeLocateReq::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeUnload::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeUnloadRsp::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::AppendReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::CreateReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::WriteReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnUpdate::internal_encode(), SWC::DB::Cells::Cell::set_value(), SWC::Manager::Schemas::store_make_block(), SWC::DB::Cells::Cell::write(), SWC::Ranger::RangeData::write(), SWC::Ranger::CommitLog::Fragment::write(), SWC::Common::Files::Schema::write(), SWC::Ranger::CellStore::Write::write_blocks_index(), and SWC::Ranger::CellStore::Write::write_trailer().
|
constexpr |
Definition at line 207 of file Serialization.h.
References SWC_ENCODE_VI_0, SWC_ENCODE_VI_1, and SWC_THROW_UNPOSSIBLE.
Referenced by SWC::DB::Cell::Key::add(), SWC::DB::Cell::Key::encode(), SWC::DB::Cell::Serial::Value::FieldUpdate_LIST::encode(), SWC::DB::Cell::Serial::Value::FieldUpdate_LIST_ITEMS< UpdateField_T, ValueT >::encode(), SWC::DB::Cell::Serial::Value::Field::encode(), SWC::DB::Specs::Serial::Value::Field::encode(), and SWC::DB::Cell::Key::insert().
|
constexpr |
Definition at line 243 of file Serialization.h.
References SWC_ENCODE_VI_0, SWC_ENCODE_VI_1, and SWC_THROW_UNPOSSIBLE.
Referenced by SWC::Comm::Serializable::encode(), SWC::DB::Cell::KeyVec::encode(), SWC::DB::Specs::Column::encode(), SWC::DB::Specs::Flags::encode(), SWC::DB::Specs::Fraction::encode(), SWC::DB::Specs::Key::encode(), SWC::DB::Specs::Scan::encode(), SWC::DB::Specs::UpdateOP::encode(), SWC::DB::Specs::Value::encode(), SWC::DB::SchemaPrimitives::encode(), SWC::DB::Schema::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::encode(), encode(), SWC::Ranger::CellStore::Readers::encode(), SWC::Ranger::CellStore::Block::Header::encode_idx(), SWC::DB::Cell::Serial::Value::FieldUpdate_Ext< UpdateField_T >::ext_encode(), SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::internal_encode(), SWC::Comm::Protocol::Bkr::Params::CellsUpdateRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnCompactRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnListReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RangeCreateRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RangeRemoveRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RangeUnloadedRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::ColumnCompactRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeLocateRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeUnloadRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspRes::internal_encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::AppendReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::AppendRsp::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::CloseReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::CreateReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::FlushReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::OpenReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::OpenRsp::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::PreadReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::ReadReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::SeekReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::SyncReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::WriteReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnUpdate::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RgrUpdate::internal_encode(), SWC::DB::Cells::Cell::set_value(), SWC::DB::Cells::Cell::write(), and SWC::Ranger::CellStore::Write::write_blocks_index().
|
constexpr |
Definition at line 286 of file Serialization.h.
References SWC_ENCODE_VI_0, SWC_ENCODE_VI_1, and SWC_THROW_UNPOSSIBLE.
Referenced by SWC::DB::Specs::Column::encode(), SWC::DB::Specs::Flags::encode(), SWC::DB::Specs::Interval::encode(), SWC::DB::Specs::IntervalUpdate::encode(), SWC::DB::Specs::KeyIntervals::encode(), SWC::DB::Specs::Values::encode(), SWC::DB::SchemaPrimitives::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::RangeStatus::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::Range::encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::Column::encode(), SWC::FS::Dirent::encode(), SWC::Manager::MngrStatus::encode(), SWC::Manager::Ranger::encode(), SWC::DB::RgrData::encode(), SWC::DB::Cell::Serial::Value::Field_INT64::encode(), SWC::DB::Specs::Serial::Value::Field_INT64::encode(), SWC::DB::Specs::Serial::Value::Field_LIST_INT64::encode(), encode_bytes(), SWC::Ranger::CellStore::Block::Header::encode_idx(), SWC::Comm::Protocol::Bkr::Params::CellsSelectReq::internal_encode(), SWC::Comm::Protocol::Bkr::Params::CellsSelectReqRef::internal_encode(), SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::internal_encode(), SWC::Comm::Protocol::Bkr::Params::CellsUpdateReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnCompactReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnGetReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnGetRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnListRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::MngrActiveReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RangeCreateReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RangeCreateRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RangeRemoveReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RangeUnloadedReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::Report::ReqColumnStatus::internal_encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::internal_encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::internal_encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RgrGetReq::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::RgrMngId::internal_encode(), SWC::Comm::Protocol::Rgr::Params::ColumnCompactReq::internal_encode(), SWC::Comm::Protocol::Rgr::Params::ColumnDelete::internal_encode(), SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadReq::internal_encode(), SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedReq::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeLoad::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeLoaded::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeLocateReq::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeLocateRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectReq::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectReqRef::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectRsp::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateReq::internal_encode(), SWC::Comm::Protocol::Rgr::Params::RangeUnload::internal_encode(), SWC::Comm::Protocol::Rgr::Params::Report::ReqColumn::internal_encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspRes::internal_encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspCids::internal_encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnRids::internal_encode(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::AppendRsp::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::LengthRsp::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::PreadReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::ReadRsp::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::ReaddirRsp::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::SeekReq::internal_encode(), SWC::Comm::Protocol::FsBroker::Params::SeekRsp::internal_encode(), SWC::Comm::Protocol::Mngr::Params::ColumnUpdate::internal_encode(), SWC::DB::Specs::Value::set_counter(), SWC::DB::Cells::Cell::set_counter(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::set_from(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::write(), and SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::write().
|
noexcept |
Definition at line 63 of file Resolver.h.
Referenced by SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::encoded_length(), SWC::DB::RgrData::encoded_length(), SWC::Manager::MngrStatus::encoded_length(), SWC::Manager::Ranger::encoded_length(), encoded_length(), SWC::Comm::Protocol::Mngr::Params::MngrActiveRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RgrMngId::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::internal_encoded_length(), and SWC::Comm::Protocol::Mngr::Params::MngrState::internal_encoded_length().
|
noexcept |
Definition at line 54 of file Resolver.cc.
References encoded_length(), and encoded_length_vi32().
|
constexprnoexcept |
Definition at line 537 of file Serialization.h.
References encoded_length_vi64().
Referenced by SWC::Comm::Buffers::create_error_message(), SWC::DB::Specs::Serial::Value::Field_LIST_BYTES::encode(), SWC::DB::Specs::IntervalUpdate::encoded_length(), SWC::DB::Schema::encoded_length(), SWC::FS::Dirent::encoded_length(), SWC::DB::Cell::Serial::Value::Field_BYTES::encoded_length(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::encoded_length(), SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::encoded_length(), SWC::DB::Specs::Serial::Value::Field_BYTES::encoded_length(), SWC::DB::Specs::Serial::Value::Field_LIST_INT64::encoded_length(), SWC::DB::Specs::Serial::Value::Field_LIST_BYTES::encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnGetReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnListReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::CreateReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::ExistsReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::LengthReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::MkdirsReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::OpenReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::ReadAllReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::ReaddirReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::RemoveReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::RenameReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::RmdirReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::WriteReq::internal_encoded_length(), SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::set_from(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::write(), and SWC::DB::Cell::Serial::Value::Field_LIST_BYTES::write().
|
constexprnoexcept |
Definition at line 517 of file Serialization.h.
Referenced by decode_double(), encode_double(), SWC::DB::Cell::Serial::Value::Field_DOUBLE::encoded_length(), and SWC::DB::Specs::Serial::Value::Field_DOUBLE::encoded_length().
|
constexprnoexcept |
Definition at line 345 of file Serialization.h.
|
constexprnoexcept |
Definition at line 390 of file Serialization.h.
|
constexprnoexcept |
Definition at line 441 of file Serialization.h.
|
constexprnoexcept |
Definition at line 199 of file Serialization.h.
References MAX_V1B, MAX_V2B, and MAX_V3B.
Referenced by SWC::DB::Cell::Key::add(), SWC::DB::Cell::Key::encoded_length(), SWC::DB::Cell::Serial::Value::Field::encoded_length(), SWC::DB::Specs::Serial::Value::Field::encoded_length(), SWC::DB::Cell::Serial::Value::FieldUpdate_LIST::encoded_length(), SWC::DB::Cell::Serial::Value::FieldUpdate_LIST_ITEMS< UpdateField_T, ValueT >::encoded_length(), and SWC::DB::Cell::Key::insert().
|
constexprnoexcept |
Definition at line 234 of file Serialization.h.
References MAX_V1B, MAX_V2B, MAX_V3B, and MAX_V4B.
Referenced by SWC::Comm::Serializable::encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::encoded_length(), SWC::Ranger::CellStore::Readers::encoded_length(), SWC::Comm::BufferInfo::encoded_length(), SWC::DB::Cell::KeyVec::encoded_length(), SWC::DB::Specs::Column::encoded_length(), SWC::DB::Specs::Flags::encoded_length(), SWC::DB::Specs::Fraction::encoded_length(), SWC::DB::Specs::Key::encoded_length(), SWC::DB::Specs::Scan::encoded_length(), SWC::DB::Specs::UpdateOP::encoded_length(), SWC::DB::Specs::Value::encoded_length(), SWC::DB::SchemaPrimitives::encoded_length(), SWC::DB::Schema::encoded_length(), SWC::DB::Cells::Cell::encoded_length(), encoded_length(), SWC::Ranger::CellStore::Block::Header::encoded_length_idx(), SWC::DB::Cell::Serial::Value::FieldUpdate_Ext< UpdateField_T >::ext_encoded_length(), SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::internal_encoded_length(), SWC::Comm::Protocol::Bkr::Params::CellsUpdateRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnCompactRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnListReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RangeCreateRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RangeRemoveRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RangeUnloadedRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::ColumnCompactRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeLocateRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeUnloadRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::RspRes::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::AppendReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::AppendRsp::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::CloseReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::CreateReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::FlushReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::OpenReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::OpenRsp::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::PreadReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::ReadReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::SeekReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::SyncReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::WriteReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnUpdate::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RgrUpdate::internal_encoded_length(), SWC::DB::Cells::Cell::set_value(), and SWC::Ranger::CellStore::Write::write_blocks_index().
|
constexprnoexcept |
Definition at line 272 of file Serialization.h.
References MAX_V1B, MAX_V2B, MAX_V3B, MAX_V4B, MAX_V5B, MAX_V6B, MAX_V7B, MAX_V8B, and MAX_V9B.
Referenced by SWC::DB::Specs::Serial::Value::Field_LIST_INT64::encode(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::RangeStatus::encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::Ranger::encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::Manager::encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::Range::encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::Column::encoded_length(), SWC::DB::Specs::Column::encoded_length(), SWC::DB::Specs::Flags::encoded_length(), SWC::DB::Specs::Interval::encoded_length(), SWC::DB::Specs::IntervalUpdate::encoded_length(), SWC::DB::Specs::KeyIntervals::encoded_length(), SWC::DB::Specs::Values::encoded_length(), SWC::DB::RgrData::encoded_length(), SWC::DB::SchemaPrimitives::encoded_length(), SWC::FS::Dirent::encoded_length(), SWC::Manager::MngrStatus::encoded_length(), SWC::Manager::Ranger::encoded_length(), SWC::DB::Cell::Serial::Value::Field_INT64::encoded_length(), SWC::DB::Specs::Serial::Value::Field_INT64::encoded_length(), SWC::DB::Specs::Serial::Value::Field_LIST_INT64::encoded_length(), encoded_length_bytes(), SWC::Ranger::CellStore::Block::Header::encoded_length_idx(), SWC::Comm::Protocol::Bkr::Params::CellsSelectReq::internal_encoded_length(), SWC::Comm::Protocol::Bkr::Params::CellsSelectReqRef::internal_encoded_length(), SWC::Comm::Protocol::Bkr::Params::CellsSelectRsp::internal_encoded_length(), SWC::Comm::Protocol::Bkr::Params::CellsUpdateReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnCompactReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnGetReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnGetRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnListRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::MngrActiveReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RangeCreateReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RangeCreateRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RangeRemoveReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RangeUnloadedReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::ReqColumnStatus::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::RspColumnStatus::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::RspRangersStatus::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::Report::RspManagersStatus::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RgrGetReq::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RgrGetRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::RgrMngId::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::ColumnCompactReq::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::ColumnDelete::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadReq::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedReq::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeLoad::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeLoaded::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeLocateReq::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeLocateRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectReq::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectReqRef::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeQuerySelectRsp::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateReq::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::RangeUnload::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::ReqColumn::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::RspRes::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::RspCids::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnRids::internal_encoded_length(), SWC::Comm::Protocol::Rgr::Params::Report::RspColumnsRanges::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::AppendRsp::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::CombiPreadReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::LengthRsp::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::PreadReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::ReadRsp::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::ReaddirRsp::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::SeekReq::internal_encoded_length(), SWC::Comm::Protocol::FsBroker::Params::SeekRsp::internal_encoded_length(), SWC::Comm::Protocol::Mngr::Params::ColumnUpdate::internal_encoded_length(), SWC::Ranger::Range::on_change(), SWC::Common::Query::Update::Metric::Item_Net< SWC::Comm::Protocol::FsBroker::Commands >::report(), SWC::Common::Query::Update::Metric::Item_FS::report(), SWC::client::Query::Update::Handlers::Metric::Item_MinMaxAvgCount::report(), SWC::client::Query::Update::Handlers::Metric::Item_CountVolume::report(), SWC::DB::Specs::Value::set_counter(), SWC::DB::Cells::Cell::set_counter(), SWC::DB::Cell::Serial::Value::Field_LIST_INT64::set_from(), and SWC::DB::Cell::Serial::Value::Field_LIST_INT64::write().
|
noexcept |
Definition at line 59 of file Serialization.h.
|
noexcept |
Definition at line 50 of file Serialization.h.
Referenced by decode_double(), decode_i16(), decode_i24(), decode_i32(), decode_i64(), encode_bytes(), encode_bytes_fixed(), encode_double(), encode_i16(), encode_i24(), encode_i32(), and encode_i64().
|
constexpr |
Definition at line 44 of file Serialization.h.
|
constexpr |
Definition at line 45 of file Serialization.h.
|
constexpr |
Definition at line 46 of file Serialization.h.
|
constexpr |
Definition at line 34 of file Serialization.h.
Referenced by encoded_length_vi24(), encoded_length_vi32(), and encoded_length_vi64().
|
constexpr |
Definition at line 35 of file Serialization.h.
Referenced by encoded_length_vi24(), encoded_length_vi32(), and encoded_length_vi64().
|
constexpr |
Definition at line 36 of file Serialization.h.
Referenced by encoded_length_vi24(), encoded_length_vi32(), and encoded_length_vi64().
|
constexpr |
Definition at line 37 of file Serialization.h.
Referenced by encoded_length_vi32(), and encoded_length_vi64().
|
constexpr |
Definition at line 38 of file Serialization.h.
Referenced by encoded_length_vi64().
|
constexpr |
Definition at line 39 of file Serialization.h.
Referenced by encoded_length_vi64().
|
constexpr |
Definition at line 40 of file Serialization.h.
Referenced by encoded_length_vi64().
|
constexpr |
Definition at line 41 of file Serialization.h.
Referenced by encoded_length_vi64().
|
constexpr |
Definition at line 42 of file Serialization.h.
Referenced by encoded_length_vi64().