// Copyright (c) 2023, 2024, Oracle and/or its affiliates. // // This program is free software; you can redistribute it and/or modify // it under the terms of the GNU General Public License, version 2.0, // as published by the Free Software Foundation. // // This program is designed to work with certain software (including // but not limited to OpenSSL) that is licensed under separate terms, // as designated in a particular file or component or in included license // documentation. The authors of MySQL hereby grant you an additional // permission to link the program and your derivative works with the // separately licensed software that they have either included with // the program or referenced in the documentation. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License, version 2.0, for more details. // // You should have received a copy of the GNU General Public License // along with this program; if not, write to the Free Software // Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. #ifndef MYSQL_SERIALIZATION_READ_ARCHIVE_BINARY_H #define MYSQL_SERIALIZATION_READ_ARCHIVE_BINARY_H #include #include "mysql/serialization/archive.h" #include "mysql/serialization/archive_binary_field_max_size_calculator.h" #include "mysql/serialization/primitive_type_codec.h" #include "mysql/serialization/serialization_types.h" /// @file /// Experimental API header /// @addtogroup GroupLibsMysqlSerialization /// @{ namespace mysql::serialization { /// @brief Binary, read only archive implementation based on vector of bytes class Read_archive_binary : public Archive { public: using Internal_type = const unsigned char *; /// @copydoc Archive::operator>> template Read_archive_binary &operator>>(Field_type &&arg); /// @copydoc Archive::get_size template static std::size_t get_size(Field_type &&arg) { static constexpr auto value_size = Field_type::value_size; using value_type = typename std::decay_t::value_type; return Primitive_type_codec::template count_write_bytes< value_size>(arg.get()); } /// @copydoc Archive::get_max_size template static constexpr std::size_t get_max_size() { return Archive_binary_field_max_size_calculator::get_max_size(); } /// @brief Set up internal stream, this implementation of Archive does not /// own memory, it just reads it /// @param[in] stream Captured stream /// @param[in] stream_size Size of stream void set_stream(const unsigned char *stream, std::size_t stream_size) { m_stream = stream; m_stream_size = stream_size; } // internal /// @copydoc Archive::get_raw_data Internal_type &get_raw_data(); /// @copydoc Archive::peek template void peek(Field_type &&field); /// @copydoc Archive::seek_to void seek_to(std::size_t num_pos) { read_pos += num_pos; } /// @copydoc Archive::get_read_pos inline std::size_t get_read_pos() const { return read_pos; } private: const unsigned char *m_stream; ///< Internal data stream std::size_t read_pos{0}; ///< Read position std::size_t m_stream_size{0}; /// length of m_stream }; } // namespace mysql::serialization /// @} #include "mysql/serialization/read_archive_binary_impl.hpp" #endif // MYSQL_SERIALIZATION_READ_ARCHIVE_BINARY_H