Austin Schuh | 09d7ffa | 2019-10-03 23:43:34 -0700 | [diff] [blame] | 1 | #ifndef AOS_FLATBUFFER_MERGE_H_ |
| 2 | #define AOS_FLATBUFFER_MERGE_H_ |
| 3 | |
| 4 | #include <cstddef> |
| 5 | #include <string> |
| 6 | |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 7 | #include "aos/flatbuffers.h" |
Austin Schuh | 09d7ffa | 2019-10-03 23:43:34 -0700 | [diff] [blame] | 8 | #include "flatbuffers/flatbuffers.h" |
| 9 | |
| 10 | namespace aos { |
| 11 | |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 12 | flatbuffers::DetachedBuffer MergeFlatBuffers( |
| 13 | const flatbuffers::TypeTable *typetable, const uint8_t *data1, |
| 14 | const uint8_t *data2); |
| 15 | |
| 16 | // Merges 2 flat buffers with the provided type table into the builder. Returns |
| 17 | // the offset to the flatbuffers. |
| 18 | // One or both of t1 and t2 must be non-null. If one is null, this method |
| 19 | // coppies instead of merging. |
| 20 | flatbuffers::Offset<flatbuffers::Table> MergeFlatBuffers( |
| 21 | const flatbuffers::TypeTable *typetable, const flatbuffers::Table *t1, |
| 22 | const flatbuffers::Table *t2, flatbuffers::FlatBufferBuilder *fbb); |
Austin Schuh | 09d7ffa | 2019-10-03 23:43:34 -0700 | [diff] [blame] | 23 | |
| 24 | template <class T> |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 25 | inline flatbuffers::Offset<T> MergeFlatBuffers( |
| 26 | const flatbuffers::Table *t1, |
| 27 | const flatbuffers::Table *t2, flatbuffers::FlatBufferBuilder *fbb) { |
| 28 | return MergeFlatBuffers(T::MiniReflectTypeTable(), t1, t2, fbb).o; |
| 29 | } |
| 30 | |
| 31 | template <class T> |
| 32 | inline flatbuffers::DetachedBuffer MergeFlatBuffers(const uint8_t *data1, |
| 33 | const uint8_t *data2) { |
Austin Schuh | 09d7ffa | 2019-10-03 23:43:34 -0700 | [diff] [blame] | 34 | return MergeFlatBuffers(T::MiniReflectTypeTable(), data1, data2); |
| 35 | } |
| 36 | |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 37 | template <class T> |
| 38 | inline flatbuffers::DetachedBuffer MergeFlatBuffers( |
| 39 | const flatbuffers::DetachedBuffer &data1, |
| 40 | const flatbuffers::DetachedBuffer &data2) { |
| 41 | return MergeFlatBuffers(T::MiniReflectTypeTable(), data1.data(), |
| 42 | data2.data()); |
| 43 | } |
| 44 | |
| 45 | template <class T> |
Austin Schuh | 40485ed | 2019-10-26 21:51:44 -0700 | [diff] [blame] | 46 | inline aos::FlatbufferDetachedBuffer<T> MergeFlatBuffers( |
| 47 | const aos::Flatbuffer<T> &fb1, const aos::Flatbuffer<T> &fb2) { |
| 48 | const uint8_t *data1 = fb1.data(); |
| 49 | const uint8_t *data2 = fb2.data(); |
| 50 | return aos::FlatbufferDetachedBuffer<T>( |
| 51 | MergeFlatBuffers(T::MiniReflectTypeTable(), data1, data2)); |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 52 | } |
| 53 | |
| 54 | template <class T> |
Austin Schuh | 40485ed | 2019-10-26 21:51:44 -0700 | [diff] [blame] | 55 | inline aos::FlatbufferDetachedBuffer<T> MergeFlatBuffers(const T *fb1, |
| 56 | const T *fb2) { |
James Kuszmaul | f3a3be2 | 2020-01-04 12:12:00 -0800 | [diff] [blame] | 57 | flatbuffers::FlatBufferBuilder fbb; |
Austin Schuh | d7b15da | 2020-02-17 15:06:11 -0800 | [diff] [blame] | 58 | fbb.ForceDefaults(true); |
James Kuszmaul | f3a3be2 | 2020-01-04 12:12:00 -0800 | [diff] [blame] | 59 | fbb.Finish(MergeFlatBuffers<T>( |
| 60 | reinterpret_cast<const flatbuffers::Table *>(fb1), |
| 61 | reinterpret_cast<const flatbuffers::Table *>(fb2), &fbb)); |
| 62 | return aos::FlatbufferDetachedBuffer<T>(fbb.Release()); |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 63 | } |
| 64 | |
| 65 | template <class T> |
Austin Schuh | e695821 | 2020-10-19 11:48:14 -0700 | [diff] [blame] | 66 | inline flatbuffers::Offset<T> MergeFlatBuffers( |
| 67 | const T *fb1, const T *fb2, flatbuffers::FlatBufferBuilder *fbb) { |
| 68 | return MergeFlatBuffers<T>(reinterpret_cast<const flatbuffers::Table *>(fb1), |
| 69 | reinterpret_cast<const flatbuffers::Table *>(fb2), |
| 70 | fbb); |
| 71 | } |
| 72 | |
| 73 | template <class T> |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 74 | inline flatbuffers::Offset<T> CopyFlatBuffer( |
| 75 | const T *t1, flatbuffers::FlatBufferBuilder *fbb) { |
| 76 | return MergeFlatBuffers<T>(reinterpret_cast<const flatbuffers::Table *>(t1), |
| 77 | nullptr, fbb); |
| 78 | } |
| 79 | |
| 80 | template <class T> |
Austin Schuh | cbe9d5a | 2020-11-01 23:25:23 -0800 | [diff] [blame] | 81 | inline flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<T>>> |
| 82 | CopyVectorTable(const flatbuffers::Vector<flatbuffers::Offset<T>> *t1, |
| 83 | flatbuffers::FlatBufferBuilder *fbb) { |
| 84 | if (t1 == nullptr) { |
| 85 | return 0; |
| 86 | } |
| 87 | std::vector<flatbuffers::Offset<T>> v; |
| 88 | for (const T *t : *t1) { |
| 89 | v.emplace_back(CopyFlatBuffer(t, fbb)); |
| 90 | } |
| 91 | return fbb->CreateVector(v); |
| 92 | } |
| 93 | |
| 94 | inline flatbuffers::Offset< |
| 95 | flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>> |
| 96 | CopyVectorSharedString( |
| 97 | const flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>> *t1, |
| 98 | flatbuffers::FlatBufferBuilder *fbb) { |
| 99 | if (t1 == nullptr) { |
| 100 | return 0; |
| 101 | } |
| 102 | std::vector<flatbuffers::Offset<flatbuffers::String>> v; |
| 103 | for (const flatbuffers::String *t : *t1) { |
| 104 | v.emplace_back(fbb->CreateSharedString(t)); |
| 105 | } |
| 106 | return fbb->CreateVector(v); |
| 107 | } |
| 108 | |
| 109 | template <class T> |
Austin Schuh | 40485ed | 2019-10-26 21:51:44 -0700 | [diff] [blame] | 110 | inline FlatbufferDetachedBuffer<T> CopyFlatBuffer(const T *t) { |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 111 | flatbuffers::FlatBufferBuilder fbb; |
Austin Schuh | d7b15da | 2020-02-17 15:06:11 -0800 | [diff] [blame] | 112 | fbb.ForceDefaults(true); |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 113 | fbb.Finish(CopyFlatBuffer<T>(t, &fbb)); |
Austin Schuh | 40485ed | 2019-10-26 21:51:44 -0700 | [diff] [blame] | 114 | return FlatbufferDetachedBuffer<T>(fbb.Release()); |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 115 | } |
| 116 | |
Austin Schuh | 30d7db9 | 2020-01-26 16:45:47 -0800 | [diff] [blame] | 117 | // Compares 2 flatbuffers. Returns true if they match, false otherwise. |
| 118 | bool CompareFlatBuffer(const flatbuffers::TypeTable *typetable, |
| 119 | const flatbuffers::Table *t1, |
| 120 | const flatbuffers::Table *t2); |
| 121 | |
| 122 | template <class T> |
| 123 | inline bool CompareFlatBuffer(const T *t1, const T *t2) { |
| 124 | return CompareFlatBuffer(T::MiniReflectTypeTable(), |
| 125 | reinterpret_cast<const flatbuffers::Table *>(t1), |
| 126 | reinterpret_cast<const flatbuffers::Table *>(t2)); |
| 127 | } |
| 128 | |
Austin Schuh | 97789fc | 2020-08-01 14:42:45 -0700 | [diff] [blame] | 129 | template <class T> |
| 130 | inline bool CompareFlatBuffer(const aos::Flatbuffer<T> &t1, |
| 131 | const aos::Flatbuffer<T> &t2) { |
| 132 | return t1.span() == t2.span(); |
| 133 | } |
| 134 | |
Austin Schuh | 09d7ffa | 2019-10-03 23:43:34 -0700 | [diff] [blame] | 135 | } // namespace aos |
| 136 | |
| 137 | #endif // AOS_FLATBUFFER_MERGE_H_ |