Merge "Prevent aos_send from sending invalid messages"
diff --git a/aos/aos_send.cc b/aos/aos_send.cc
index 980ebc7..8533f47 100644
--- a/aos/aos_send.cc
+++ b/aos/aos_send.cc
@@ -58,7 +58,14 @@
flatbuffers::FlatBufferBuilder fbb(sender->fbb_allocator()->size(),
sender->fbb_allocator());
fbb.ForceDefaults(true);
- fbb.Finish(aos::JsonToFlatbuffer(message_to_send, channel->schema(), &fbb));
+ flatbuffers::Offset<flatbuffers::Table> msg_offset =
+ aos::JsonToFlatbuffer(message_to_send, channel->schema(), &fbb);
+
+ if (msg_offset.IsNull()) {
+ return 1;
+ }
+
+ fbb.Finish(msg_offset);
if (FLAGS_rate < 0) {
sender->CheckOk(sender->Send(fbb.GetSize()));