// // MessagePack for C++ static resolution routine // // Copyright (C) 2008-2016 FURUHASHI Sadayuki and KONDO Takatoshi // // Distributed under the Boost Software License, Version 1.0. // (See accompanying file LICENSE_1_0.txt or copy at // http://www.boost.org/LICENSE_1_0.txt) // #ifndef MSGPACK_V1_TYPE_MAP_HPP #define MSGPACK_V1_TYPE_MAP_HPP #include "rpc/msgpack/v1/adaptor/map_decl.hpp" #include "rpc/msgpack/adaptor/adaptor_base.hpp" #include #include namespace clmdep_msgpack { /// @cond MSGPACK_API_VERSION_NAMESPACE(v1) { /// @endcond namespace type { template class assoc_vector : public std::vector< std::pair, Alloc > { #if !defined(MSGPACK_USE_CPP03) using std::vector, Alloc>::vector; #endif // !defined(MSGPACK_USE_CPP03) }; namespace detail { template struct pair_first_less { bool operator() (const std::pair& x, const std::pair& y) const { return Compare()(x.first, y.first); } }; } } //namespace type namespace adaptor { #if !defined(MSGPACK_USE_CPP03) template struct as< type::assoc_vector, typename std::enable_if::value || clmdep_msgpack::has_as::value>::type> { type::assoc_vector operator()(clmdep_msgpack::object const& o) const { if (o.type != clmdep_msgpack::type::MAP) { throw clmdep_msgpack::type_error(); } type::assoc_vector v; v.reserve(o.via.map.size); clmdep_msgpack::object_kv* p = o.via.map.ptr; clmdep_msgpack::object_kv* const pend = o.via.map.ptr + o.via.map.size; for (; p < pend; ++p) { v.emplace_back(p->key.as(), p->val.as()); } std::sort(v.begin(), v.end(), type::detail::pair_first_less()); return v; } }; #endif // !defined(MSGPACK_USE_CPP03) template struct convert > { clmdep_msgpack::object const& operator()(clmdep_msgpack::object const& o, type::assoc_vector& v) const { if (o.type != clmdep_msgpack::type::MAP) { throw clmdep_msgpack::type_error(); } v.resize(o.via.map.size); if (o.via.map.size != 0) { clmdep_msgpack::object_kv* p = o.via.map.ptr; clmdep_msgpack::object_kv* const pend = o.via.map.ptr + o.via.map.size; std::pair* it(&v.front()); for (; p < pend; ++p, ++it) { p->key.convert(it->first); p->val.convert(it->second); } std::sort(v.begin(), v.end(), type::detail::pair_first_less()); } return o; } }; template struct pack > { template clmdep_msgpack::packer& operator()(clmdep_msgpack::packer& o, const type::assoc_vector& v) const { uint32_t size = checked_get_container_size(v.size()); o.pack_map(size); for (typename type::assoc_vector::const_iterator it(v.begin()), it_end(v.end()); it != it_end; ++it) { o.pack(it->first); o.pack(it->second); } return o; } }; template struct object_with_zone > { void operator()(clmdep_msgpack::object::with_zone& o, const type::assoc_vector& v) const { o.type = clmdep_msgpack::type::MAP; if (v.empty()) { o.via.map.ptr = MSGPACK_NULLPTR; o.via.map.size = 0; } else { uint32_t size = checked_get_container_size(v.size()); clmdep_msgpack::object_kv* p = static_cast(o.zone.allocate_align(sizeof(clmdep_msgpack::object_kv)*size, MSGPACK_ZONE_ALIGNOF(clmdep_msgpack::object_kv))); clmdep_msgpack::object_kv* const pend = p + size; o.via.map.ptr = p; o.via.map.size = size; typename type::assoc_vector::const_iterator it(v.begin()); do { p->key = clmdep_msgpack::object(it->first, o.zone); p->val = clmdep_msgpack::object(it->second, o.zone); ++p; ++it; } while(p < pend); } } }; #if !defined(MSGPACK_USE_CPP03) template struct as< std::map, typename std::enable_if::value || clmdep_msgpack::has_as::value>::type> { std::map operator()(clmdep_msgpack::object const& o) const { if (o.type != clmdep_msgpack::type::MAP) { throw clmdep_msgpack::type_error(); } clmdep_msgpack::object_kv* p(o.via.map.ptr); clmdep_msgpack::object_kv* const pend(o.via.map.ptr + o.via.map.size); std::map v; for (; p != pend; ++p) { v.emplace(p->key.as(), p->val.as()); } return v; } }; #endif // !defined(MSGPACK_USE_CPP03) template struct convert > { clmdep_msgpack::object const& operator()(clmdep_msgpack::object const& o, std::map& v) const { if (o.type != clmdep_msgpack::type::MAP) { throw clmdep_msgpack::type_error(); } clmdep_msgpack::object_kv* p(o.via.map.ptr); clmdep_msgpack::object_kv* const pend(o.via.map.ptr + o.via.map.size); std::map tmp; for (; p != pend; ++p) { K key; p->key.convert(key); #if __cplusplus >= 201103L p->val.convert(tmp[std::move(key)]); #else p->val.convert(tmp[key]); #endif } #if __cplusplus >= 201103L v = std::move(tmp); #else tmp.swap(v); #endif return o; } }; template struct pack > { template clmdep_msgpack::packer& operator()(clmdep_msgpack::packer& o, const std::map& v) const { uint32_t size = checked_get_container_size(v.size()); o.pack_map(size); for (typename std::map::const_iterator it(v.begin()), it_end(v.end()); it != it_end; ++it) { o.pack(it->first); o.pack(it->second); } return o; } }; template struct object_with_zone > { void operator()(clmdep_msgpack::object::with_zone& o, const std::map& v) const { o.type = clmdep_msgpack::type::MAP; if (v.empty()) { o.via.map.ptr = MSGPACK_NULLPTR; o.via.map.size = 0; } else { uint32_t size = checked_get_container_size(v.size()); clmdep_msgpack::object_kv* p = static_cast(o.zone.allocate_align(sizeof(clmdep_msgpack::object_kv)*size, MSGPACK_ZONE_ALIGNOF(clmdep_msgpack::object_kv))); clmdep_msgpack::object_kv* const pend = p + size; o.via.map.ptr = p; o.via.map.size = size; typename std::map::const_iterator it(v.begin()); do { #if (__GNUC__ > 4 || (__GNUC__ == 4 && __GNUC_MINOR__ >= 7)) && !defined(__clang__) #pragma GCC diagnostic push #pragma GCC diagnostic ignored "-Wmaybe-uninitialized" #endif // (__GNUC__ > 4 || (__GNUC__ == 4 && __GNUC_MINOR__ >= 7)) && !defined(__clang__) p->key = clmdep_msgpack::object(it->first, o.zone); p->val = clmdep_msgpack::object(it->second, o.zone); #if (__GNUC__ > 4 || (__GNUC__ == 4 && __GNUC_MINOR__ >= 7)) && !defined(__clang__) #pragma GCC diagnostic pop #endif // (__GNUC__ > 4 || (__GNUC__ == 4 && __GNUC_MINOR__ >= 7)) && !defined(__clang__) ++p; ++it; } while(p < pend); } } }; #if !defined(MSGPACK_USE_CPP03) template struct as< std::multimap, typename std::enable_if::value || clmdep_msgpack::has_as::value>::type> { std::multimap operator()(clmdep_msgpack::object const& o) const { if (o.type != clmdep_msgpack::type::MAP) { throw clmdep_msgpack::type_error(); } clmdep_msgpack::object_kv* p(o.via.map.ptr); clmdep_msgpack::object_kv* const pend(o.via.map.ptr + o.via.map.size); std::multimap v; for (; p != pend; ++p) { v.emplace(p->key.as(), p->val.as()); } return v; } }; #endif // !defined(MSGPACK_USE_CPP03) template struct convert > { clmdep_msgpack::object const& operator()(clmdep_msgpack::object const& o, std::multimap& v) const { if (o.type != clmdep_msgpack::type::MAP) { throw clmdep_msgpack::type_error(); } clmdep_msgpack::object_kv* p(o.via.map.ptr); clmdep_msgpack::object_kv* const pend(o.via.map.ptr + o.via.map.size); std::multimap tmp; for (; p != pend; ++p) { std::pair value; p->key.convert(value.first); p->val.convert(value.second); #if __cplusplus >= 201103L tmp.insert(std::move(value)); #else tmp.insert(value); #endif } #if __cplusplus >= 201103L v = std::move(tmp); #else tmp.swap(v); #endif return o; } }; template struct pack > { template clmdep_msgpack::packer& operator()(clmdep_msgpack::packer& o, const std::multimap& v) const { uint32_t size = checked_get_container_size(v.size()); o.pack_map(size); for (typename std::multimap::const_iterator it(v.begin()), it_end(v.end()); it != it_end; ++it) { o.pack(it->first); o.pack(it->second); } return o; } }; template struct object_with_zone > { void operator()(clmdep_msgpack::object::with_zone& o, const std::multimap& v) const { o.type = clmdep_msgpack::type::MAP; if (v.empty()) { o.via.map.ptr = MSGPACK_NULLPTR; o.via.map.size = 0; } else { uint32_t size = checked_get_container_size(v.size()); clmdep_msgpack::object_kv* p = static_cast(o.zone.allocate_align(sizeof(clmdep_msgpack::object_kv)*size, MSGPACK_ZONE_ALIGNOF(clmdep_msgpack::object_kv))); clmdep_msgpack::object_kv* const pend = p + size; o.via.map.ptr = p; o.via.map.size = size; typename std::multimap::const_iterator it(v.begin()); do { p->key = clmdep_msgpack::object(it->first, o.zone); p->val = clmdep_msgpack::object(it->second, o.zone); ++p; ++it; } while(p < pend); } } }; } // namespace adaptor /// @cond } // MSGPACK_API_VERSION_NAMESPACE(v1) /// @endcond } // namespace clmdep_msgpack #endif // MSGPACK_V1_TYPE_MAP_HPP