blob: 78442278443d8383fcb7c16b9ad24b8b457910fa [file] [log] [blame]
Austin Schuh09d7ffa2019-10-03 23:43:34 -07001#ifndef AOS_FLATBUFFER_MERGE_H_
2#define AOS_FLATBUFFER_MERGE_H_
3
4#include <cstddef>
5#include <string>
6
Austin Schuhe93d8642019-10-13 15:27:07 -07007#include "aos/flatbuffers.h"
Austin Schuh09d7ffa2019-10-03 23:43:34 -07008#include "flatbuffers/flatbuffers.h"
9
10namespace aos {
11
Austin Schuhe93d8642019-10-13 15:27:07 -070012flatbuffers::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.
20flatbuffers::Offset<flatbuffers::Table> MergeFlatBuffers(
21 const flatbuffers::TypeTable *typetable, const flatbuffers::Table *t1,
22 const flatbuffers::Table *t2, flatbuffers::FlatBufferBuilder *fbb);
Austin Schuh09d7ffa2019-10-03 23:43:34 -070023
24template <class T>
Austin Schuhe93d8642019-10-13 15:27:07 -070025inline 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
31template <class T>
32inline flatbuffers::DetachedBuffer MergeFlatBuffers(const uint8_t *data1,
33 const uint8_t *data2) {
Austin Schuh09d7ffa2019-10-03 23:43:34 -070034 return MergeFlatBuffers(T::MiniReflectTypeTable(), data1, data2);
35}
36
Austin Schuhe93d8642019-10-13 15:27:07 -070037template <class T>
38inline 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
45template <class T>
Austin Schuh40485ed2019-10-26 21:51:44 -070046inline aos::FlatbufferDetachedBuffer<T> MergeFlatBuffers(
47 const aos::Flatbuffer<T> &fb1, const aos::Flatbuffer<T> &fb2) {
48const uint8_t *data1 = fb1.data();
49const uint8_t *data2 = fb2.data();
50 return aos::FlatbufferDetachedBuffer<T>(
51 MergeFlatBuffers(T::MiniReflectTypeTable(), data1, data2));
Austin Schuhe93d8642019-10-13 15:27:07 -070052}
53
54template <class T>
Austin Schuh40485ed2019-10-26 21:51:44 -070055inline aos::FlatbufferDetachedBuffer<T> MergeFlatBuffers(const T *fb1,
56 const T *fb2) {
James Kuszmaulf3a3be22020-01-04 12:12:00 -080057 flatbuffers::FlatBufferBuilder fbb;
Austin Schuhd7b15da2020-02-17 15:06:11 -080058 fbb.ForceDefaults(true);
James Kuszmaulf3a3be22020-01-04 12:12:00 -080059 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 Schuhe93d8642019-10-13 15:27:07 -070063}
64
65template <class T>
Austin Schuhe6958212020-10-19 11:48:14 -070066inline 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
73template <class T>
Austin Schuhe93d8642019-10-13 15:27:07 -070074inline 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
80template <class T>
Austin Schuhcbe9d5a2020-11-01 23:25:23 -080081inline flatbuffers::Offset<flatbuffers::Vector<flatbuffers::Offset<T>>>
82CopyVectorTable(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
94inline flatbuffers::Offset<
95 flatbuffers::Vector<flatbuffers::Offset<flatbuffers::String>>>
96CopyVectorSharedString(
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
109template <class T>
Austin Schuh40485ed2019-10-26 21:51:44 -0700110inline FlatbufferDetachedBuffer<T> CopyFlatBuffer(const T *t) {
Austin Schuhe93d8642019-10-13 15:27:07 -0700111 flatbuffers::FlatBufferBuilder fbb;
Austin Schuhd7b15da2020-02-17 15:06:11 -0800112 fbb.ForceDefaults(true);
Austin Schuhe93d8642019-10-13 15:27:07 -0700113 fbb.Finish(CopyFlatBuffer<T>(t, &fbb));
Austin Schuh40485ed2019-10-26 21:51:44 -0700114 return FlatbufferDetachedBuffer<T>(fbb.Release());
Austin Schuhe93d8642019-10-13 15:27:07 -0700115}
116
Austin Schuh30d7db92020-01-26 16:45:47 -0800117// Compares 2 flatbuffers. Returns true if they match, false otherwise.
118bool CompareFlatBuffer(const flatbuffers::TypeTable *typetable,
119 const flatbuffers::Table *t1,
120 const flatbuffers::Table *t2);
121
122template <class T>
123inline 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 Schuh97789fc2020-08-01 14:42:45 -0700129template <class T>
130inline bool CompareFlatBuffer(const aos::Flatbuffer<T> &t1,
131 const aos::Flatbuffer<T> &t2) {
132 return t1.span() == t2.span();
133}
134
Austin Schuh09d7ffa2019-10-03 23:43:34 -0700135} // namespace aos
136
137#endif // AOS_FLATBUFFER_MERGE_H_