#ifndef UPBC_MESSAGE_LAYOUT_H #define UPBC_MESSAGE_LAYOUT_H #include "absl/base/macros.h" #include "absl/container/flat_hash_map.h" #include "google/protobuf/descriptor.h" namespace upbc { class MessageLayout { public: struct Size { void Add(const Size& other) { size32 += other.size32; size64 += other.size64; } void MaxFrom(const Size& other) { size32 = std::max(size32, other.size32); size64 = std::max(size64, other.size64); } void AlignUp(const Size& align) { size32 = Align(size32, align.size32); size64 = Align(size64, align.size64); } int64_t size32; int64_t size64; }; struct SizeAndAlign { Size size; Size align; void MaxFrom(const SizeAndAlign& other) { size.MaxFrom(other.size); align.MaxFrom(other.align); } }; MessageLayout(const google::protobuf::Descriptor* descriptor) { ComputeLayout(descriptor); } Size GetFieldOffset(const google::protobuf::FieldDescriptor* field) const { return GetMapValue(field_offsets_, field); } Size GetOneofCaseOffset( const google::protobuf::OneofDescriptor* oneof) const { return GetMapValue(oneof_case_offsets_, oneof); } int GetHasbitIndex(const google::protobuf::FieldDescriptor* field) const { return GetMapValue(hasbit_indexes_, field); } Size message_size() const { return size_; } static bool HasHasbit(const google::protobuf::FieldDescriptor* field); static SizeAndAlign SizeOfUnwrapped( const google::protobuf::FieldDescriptor* field); private: void ComputeLayout(const google::protobuf::Descriptor* descriptor); void PlaceNonOneofFields(const google::protobuf::Descriptor* descriptor); void PlaceOneofFields(const google::protobuf::Descriptor* descriptor); Size Place(SizeAndAlign size_and_align); template static V GetMapValue(const absl::flat_hash_map& map, K key) { auto iter = map.find(key); if (iter == map.end()) { fprintf(stderr, "No value for field.\n"); abort(); } return iter->second; } static bool IsPowerOfTwo(size_t val) { return (val & (val - 1)) == 0; } static size_t Align(size_t val, size_t align) { ABSL_ASSERT(IsPowerOfTwo(align)); return (val + align - 1) & ~(align - 1); } static SizeAndAlign SizeOf(const google::protobuf::FieldDescriptor* field); static int64_t FieldLayoutRank( const google::protobuf::FieldDescriptor* field); absl::flat_hash_map field_offsets_; absl::flat_hash_map hasbit_indexes_; absl::flat_hash_map oneof_case_offsets_; Size maxalign_; Size size_; }; // Returns fields in order of "hotness", eg. how frequently they appear in // serialized payloads. Ideally this will use a profile. When we don't have // that, we assume that fields with smaller numbers are used more frequently. inline std::vector FieldHotnessOrder( const google::protobuf::Descriptor* message) { std::vector fields; for (int i = 0; i < message->field_count(); i++) { fields.push_back(message->field(i)); } std::sort(fields.begin(), fields.end(), [](const google::protobuf::FieldDescriptor* a, const google::protobuf::FieldDescriptor* b) { return a->number() < b->number(); }); return fields; } } // namespace upbc #endif // UPBC_MESSAGE_LAYOUT_H