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> |
| 66 | inline flatbuffers::Offset<T> CopyFlatBuffer( |
| 67 | const T *t1, flatbuffers::FlatBufferBuilder *fbb) { |
| 68 | return MergeFlatBuffers<T>(reinterpret_cast<const flatbuffers::Table *>(t1), |
| 69 | nullptr, fbb); |
| 70 | } |
| 71 | |
| 72 | template <class T> |
Austin Schuh | 40485ed | 2019-10-26 21:51:44 -0700 | [diff] [blame] | 73 | inline FlatbufferDetachedBuffer<T> CopyFlatBuffer(const T *t) { |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 74 | flatbuffers::FlatBufferBuilder fbb; |
Austin Schuh | d7b15da | 2020-02-17 15:06:11 -0800 | [diff] [blame] | 75 | fbb.ForceDefaults(true); |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 76 | fbb.Finish(CopyFlatBuffer<T>(t, &fbb)); |
Austin Schuh | 40485ed | 2019-10-26 21:51:44 -0700 | [diff] [blame] | 77 | return FlatbufferDetachedBuffer<T>(fbb.Release()); |
Austin Schuh | e93d864 | 2019-10-13 15:27:07 -0700 | [diff] [blame] | 78 | } |
| 79 | |
Austin Schuh | 30d7db9 | 2020-01-26 16:45:47 -0800 | [diff] [blame] | 80 | // Compares 2 flatbuffers. Returns true if they match, false otherwise. |
| 81 | bool CompareFlatBuffer(const flatbuffers::TypeTable *typetable, |
| 82 | const flatbuffers::Table *t1, |
| 83 | const flatbuffers::Table *t2); |
| 84 | |
| 85 | template <class T> |
| 86 | inline bool CompareFlatBuffer(const T *t1, const T *t2) { |
| 87 | return CompareFlatBuffer(T::MiniReflectTypeTable(), |
| 88 | reinterpret_cast<const flatbuffers::Table *>(t1), |
| 89 | reinterpret_cast<const flatbuffers::Table *>(t2)); |
| 90 | } |
| 91 | |
Austin Schuh | 09d7ffa | 2019-10-03 23:43:34 -0700 | [diff] [blame] | 92 | } // namespace aos |
| 93 | |
| 94 | #endif // AOS_FLATBUFFER_MERGE_H_ |