diff --git a/test/blackbox/BlackboxTestsPersistence.cpp b/test/blackbox/BlackboxTestsPersistence.cpp index c289bec66e9..482847db473 100644 --- a/test/blackbox/BlackboxTestsPersistence.cpp +++ b/test/blackbox/BlackboxTestsPersistence.cpp @@ -76,6 +76,8 @@ class BlackBoxPersistence : public ::testing::Test } } + std::cout << "Last received sequence was " << reader.get_last_received_sequence_number() << std::endl; + std::cout << "Destroying reader..." << std::endl; reader.destroy(); std::cout << "Destroying writer..." << std::endl; diff --git a/test/blackbox/RTPSWithRegistrationReader.hpp b/test/blackbox/RTPSWithRegistrationReader.hpp index df76dee9690..c47c4b11d75 100644 --- a/test/blackbox/RTPSWithRegistrationReader.hpp +++ b/test/blackbox/RTPSWithRegistrationReader.hpp @@ -223,6 +223,10 @@ class RTPSWithRegistrationReader }); } + eprosima::fastrtps::rtps::SequenceNumber_t get_last_received_sequence_number() const + { + return last_seq_; + } void wait_discovery() { @@ -304,7 +308,7 @@ class RTPSWithRegistrationReader std::cout << "Initializing persistent READER " << reader_attr_.endpoint.persistence_guid << " with file " << filename << std::endl; - return durability(eprosima::fastrtps::rtps::DurabilityKind_t::PERSISTENT) + return durability(eprosima::fastrtps::rtps::DurabilityKind_t::TRANSIENT) .add_property("dds.persistence.plugin", "builtin.SQLITE3") .add_property("dds.persistence.sqlite3.filename", filename); }