Merge "Stream Message objects with data properly"
diff --git a/aos/network/multinode_timestamp_filter.cc b/aos/network/multinode_timestamp_filter.cc
index a076eb2..edfa582 100644
--- a/aos/network/multinode_timestamp_filter.cc
+++ b/aos/network/multinode_timestamp_filter.cc
@@ -754,15 +754,18 @@
void MultiNodeNoncausalOffsetEstimator::Start(
std::vector<monotonic_clock::time_point> times) {
- std::fstream s("/tmp/timestamp_noncausal_starttime.csv", s.trunc | s.out);
- CHECK(s.is_open());
- for (const Node *node : configuration::GetNodes(configuration())) {
- const size_t node_index =
- configuration::GetNodeIndex(configuration(), node);
- s << node->name()->string_view() << ", " << std::setprecision(12)
- << std::fixed
- << chrono::duration<double>(times[node_index].time_since_epoch()).count()
- << "\n";
+ if (FLAGS_timestamps_to_csv) {
+ std::fstream s("/tmp/timestamp_noncausal_starttime.csv", s.trunc | s.out);
+ CHECK(s.is_open());
+ for (const Node *node : configuration::GetNodes(configuration())) {
+ const size_t node_index =
+ configuration::GetNodeIndex(configuration(), node);
+ s << node->name()->string_view() << ", " << std::setprecision(12)
+ << std::fixed
+ << chrono::duration<double>(times[node_index].time_since_epoch())
+ .count()
+ << "\n";
+ }
}
}