Create an enum for sender errors
Will replace usages of bools, and will now currently only be used
for indicating that messages were sent too fast
After we merge this commit we will replace this enum with a general
Status class for all of aos, similar to absl::Status.
Change-Id: I4b5b2e7685744b3c6826a241cd3c84190eaa96ee
Signed-off-by: milind-u <milind.upadhyay@gmail.com>
diff --git a/aos/events/shm_event_loop_test.cc b/aos/events/shm_event_loop_test.cc
index 7e1444b..01ca92b 100644
--- a/aos/events/shm_event_loop_test.cc
+++ b/aos/events/shm_event_loop_test.cc
@@ -144,7 +144,7 @@
aos::Sender<TestMessage>::Builder msg = sender.MakeBuilder();
TestMessage::Builder builder = msg.MakeBuilder<TestMessage>();
builder.add_value(200);
- msg.Send(builder.Finish());
+ msg.CheckOk(msg.Send(builder.Finish()));
}
EXPECT_FALSE(IsRealtime());
@@ -185,7 +185,7 @@
aos::Sender<TestMessage>::Builder msg = sender.MakeBuilder();
TestMessage::Builder builder = msg.MakeBuilder<TestMessage>();
builder.add_value(200);
- msg.Send(builder.Finish());
+ msg.CheckOk(msg.Send(builder.Finish()));
});
factory()->Run();
@@ -280,7 +280,7 @@
auto builder = sender.MakeBuilder();
TestMessage::Builder test_builder(*builder.fbb());
test_builder.add_value(1);
- CHECK(builder.Send(test_builder.Finish()));
+ builder.CheckOk(builder.Send(test_builder.Finish()));
});
factory()->Run();
EXPECT_TRUE(ran);
@@ -317,7 +317,7 @@
auto builder = sender.MakeBuilder();
TestMessage::Builder test_builder(*builder.fbb());
test_builder.add_value(1);
- CHECK(builder.Send(test_builder.Finish()));
+ builder.CheckOk(builder.Send(test_builder.Finish()));
}
ASSERT_TRUE(fetcher.Fetch());
@@ -336,13 +336,13 @@
EXPECT_DEATH(
{
++static_cast<char *>(sender->data())[-1 - i];
- sender->Send(0);
+ sender->CheckOk(sender->Send(0));
},
"Somebody wrote outside the buffer of their message");
EXPECT_DEATH(
{
++static_cast<char *>(sender->data())[sender->size() + i];
- sender->Send(0);
+ sender->CheckOk(sender->Send(0));
},
"Somebody wrote outside the buffer of their message");
}
@@ -361,7 +361,7 @@
auto builder = sender.MakeBuilder();
TestMessage::Builder test_builder(*builder.fbb());
test_builder.add_value(0);
- CHECK(builder.Send(test_builder.Finish()));
+ builder.CheckOk(builder.Send(test_builder.Finish()));
}
EXPECT_DEATH(fetcher.FetchNext(),
"The next message is no longer "
@@ -387,7 +387,7 @@
auto builder = sender.MakeBuilder();
TestMessage::Builder test_builder(*builder.fbb());
test_builder.add_value(0);
- CHECK(builder.Send(test_builder.Finish()));
+ builder.CheckOk(builder.Send(test_builder.Finish()));
}
EXPECT_DEATH(fetcher.FetchNext(),
"The next message is no longer "
@@ -410,7 +410,7 @@
auto builder = sender.MakeBuilder();
TestMessage::Builder test_builder(*builder.fbb());
test_builder.add_value(0);
- CHECK(builder.Send(test_builder.Finish()));
+ builder.CheckOk(builder.Send(test_builder.Finish()));
}
EXPECT_DEATH(fetcher.FetchNext(),
"The next message is no longer "
@@ -429,7 +429,7 @@
auto builder = sender.MakeBuilder();
TestMessage::Builder test_builder(*builder.fbb());
test_builder.add_value(0);
- CHECK(builder.Send(test_builder.Finish()));
+ builder.CheckOk(builder.Send(test_builder.Finish()));
}
EXPECT_DEATH(fetcher.FetchNext(),
"The next message is no longer "