Skip to content

Commit 2a36636

Browse files
Revert "Return sample notifying changes on instance state (#5957)" (#5973)
This reverts commit c8c509c.
1 parent cfd3160 commit 2a36636

File tree

11 files changed

+225
-527
lines changed

11 files changed

+225
-527
lines changed

src/cpp/fastdds/subscriber/DataReaderImpl.cpp

Lines changed: 26 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -388,28 +388,6 @@ bool DataReaderImpl::wait_for_unread_message(
388388
void DataReaderImpl::set_read_communication_status(
389389
bool trigger_value)
390390
{
391-
if (trigger_value)
392-
{
393-
auto user_reader = user_datareader_;
394-
395-
//First check if we can handle with on_data_on_readers
396-
SubscriberListener* subscriber_listener =
397-
subscriber_->get_listener_for(StatusMask::data_on_readers());
398-
if (subscriber_listener != nullptr)
399-
{
400-
subscriber_listener->on_data_on_readers(subscriber_->user_subscriber_);
401-
}
402-
else
403-
{
404-
// If not, try with on_data_available
405-
DataReaderListener* listener = get_listener_for(StatusMask::data_available());
406-
if (listener != nullptr)
407-
{
408-
listener->on_data_available(user_reader);
409-
}
410-
}
411-
}
412-
413391
StatusMask notify_status = StatusMask::data_on_readers();
414392
subscriber_->user_subscriber_->get_statuscondition().get_impl()->set_status(notify_status, trigger_value);
415393

@@ -741,6 +719,11 @@ ReturnCode_t DataReaderImpl::read_or_take_next_sample(
741719
return ReturnCode_t::RETCODE_NOT_ENABLED;
742720
}
743721

722+
if (history_.getHistorySize() == 0)
723+
{
724+
return ReturnCode_t::RETCODE_NO_DATA;
725+
}
726+
744727
#if HAVE_STRICT_REALTIME
745728
auto max_blocking_time = std::chrono::steady_clock::now() +
746729
std::chrono::microseconds(::TimeConv::Time_t2MicroSecondsInt64(qos_.reliability().max_blocking_time));
@@ -935,6 +918,25 @@ void DataReaderImpl::InnerDataReaderListener::on_data_available(
935918

936919
if (data_reader_->on_data_available(writer_guid, first_sequence, last_sequence))
937920
{
921+
auto user_reader = data_reader_->user_datareader_;
922+
923+
//First check if we can handle with on_data_on_readers
924+
SubscriberListener* subscriber_listener =
925+
data_reader_->subscriber_->get_listener_for(StatusMask::data_on_readers());
926+
if (subscriber_listener != nullptr)
927+
{
928+
subscriber_listener->on_data_on_readers(data_reader_->subscriber_->user_subscriber_);
929+
}
930+
else
931+
{
932+
// If not, try with on_data_available
933+
DataReaderListener* listener = data_reader_->get_listener_for(StatusMask::data_available());
934+
if (listener != nullptr)
935+
{
936+
listener->on_data_available(user_reader);
937+
}
938+
}
939+
938940
data_reader_->set_read_communication_status(true);
939941
}
940942
}
@@ -1174,10 +1176,7 @@ void DataReaderImpl::update_subscription_matched_status(
11741176

11751177
if (count_change < 0)
11761178
{
1177-
if (history_.writer_not_alive(iHandle2GUID(status.last_publication_handle)))
1178-
{
1179-
set_read_communication_status(true);
1180-
}
1179+
history_.writer_not_alive(iHandle2GUID(status.last_publication_handle));
11811180
try_notify_read_conditions();
11821181
}
11831182
}
@@ -1450,10 +1449,7 @@ LivelinessChangedStatus& DataReaderImpl::update_liveliness_status(
14501449
{
14511450
if (0 < status.not_alive_count_change)
14521451
{
1453-
if (history_.writer_not_alive(iHandle2GUID(status.last_publication_handle)))
1454-
{
1455-
set_read_communication_status(true);
1456-
}
1452+
history_.writer_not_alive(iHandle2GUID(status.last_publication_handle));
14571453
try_notify_read_conditions();
14581454
}
14591455

src/cpp/fastdds/subscriber/DataReaderImpl/ReadTakeCommand.hpp

Lines changed: 1 addition & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -181,18 +181,6 @@ struct ReadTakeCommand
181181
++it;
182182
}
183183

184-
// Check if there is a state notification sample available
185-
if (!finished_ && instance_->second->has_state_notification_sample)
186-
{
187-
// Add sample and info to collections
188-
bool deserialization_error = false;
189-
bool added = add_sample(nullptr, deserialization_error);
190-
if (added && take_samples)
191-
{
192-
instance_->second->has_state_notification_sample = false;
193-
}
194-
}
195-
196184
if (current_slot_ > first_slot)
197185
{
198186
history_.instance_viewed_nts(instance_->second);
@@ -407,34 +395,7 @@ struct ReadTakeCommand
407395
}
408396

409397
SampleInfo& info = sample_infos_[current_slot_];
410-
const DataReaderInstance& instance = *instance_->second;
411-
if (item)
412-
{
413-
generate_info(info, instance, item);
414-
}
415-
else
416-
{
417-
fastrtps::rtps::Time_t current_time;
418-
fastrtps::rtps::Time_t::now(current_time);
419-
420-
info.sample_state = NOT_READ_SAMPLE_STATE;
421-
info.instance_state = instance.instance_state;
422-
info.view_state = instance.view_state;
423-
info.disposed_generation_count = instance.disposed_generation_count;
424-
info.no_writers_generation_count = instance.no_writers_generation_count;
425-
info.sample_rank = 0;
426-
info.generation_rank = 0;
427-
info.absolute_generation_rank = 0;
428-
info.source_timestamp = current_time;
429-
info.reception_timestamp = current_time;
430-
info.instance_handle = instance_->first;
431-
info.publication_handle = HANDLE_NIL;
432-
433-
info.sample_identity = fastrtps::rtps::SampleIdentity{};
434-
info.related_sample_identity = fastrtps::rtps::SampleIdentity{};
435-
436-
info.valid_data = false;
437-
}
398+
generate_info(info, *instance_->second, item);
438399
}
439400

440401
bool check_datasharing_validity(

src/cpp/fastdds/subscriber/history/DataReaderHistory.cpp

Lines changed: 2 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -666,7 +666,7 @@ void DataReaderHistory::check_and_remove_instance(
666666
{
667667
DataReaderInstance* instance = instance_info->second.get();
668668

669-
if (instance->cache_changes.empty() && (false == instance->has_state_notification_sample))
669+
if (instance->cache_changes.empty())
670670
{
671671
if (InstanceStateKind::ALIVE_INSTANCE_STATE != instance->instance_state &&
672672
instance->alive_writers.empty() &&
@@ -892,24 +892,13 @@ bool DataReaderHistory::update_instance_nts(
892892
return ret;
893893
}
894894

895-
bool DataReaderHistory::writer_not_alive(
895+
void DataReaderHistory::writer_not_alive(
896896
const GUID_t& writer_guid)
897897
{
898-
bool ret_val = false;
899-
900898
for (auto& it : instances_)
901899
{
902-
bool had_notification_sample = it.second->has_state_notification_sample;
903900
it.second->writer_removed(counters_, writer_guid);
904-
if (it.second->has_state_notification_sample && !had_notification_sample)
905-
{
906-
// Mark instance as data available
907-
data_available_instances_[it.first] = it.second;
908-
ret_val = true;
909-
}
910901
}
911-
912-
return ret_val;
913902
}
914903

915904
StateFilter DataReaderHistory::get_mask_status() const noexcept

src/cpp/fastdds/subscriber/history/DataReaderHistory.hpp

Lines changed: 1 addition & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -348,15 +348,7 @@ class DataReaderHistory : public eprosima::fastrtps::rtps::ReaderHistory
348348
bool update_instance_nts(
349349
CacheChange_t* const change);
350350

351-
/*!
352-
* @brief Inform the history that a writer should be considered as not alive.
353-
*
354-
* @param [in] writer_guid GUID of the writer that should be considered as not alive.
355-
*
356-
* @return true if a state notification sample was added to at least one instance.
357-
* This would mean that DATA_AVAILABLE status (and listener) shall be notified.
358-
*/
359-
bool writer_not_alive(
351+
void writer_not_alive(
360352
const fastrtps::rtps::GUID_t& writer_guid);
361353

362354
void check_and_remove_instance(

src/cpp/fastdds/subscriber/history/DataReaderInstance.hpp

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -58,8 +58,6 @@ struct DataReaderInstance
5858
int32_t disposed_generation_count = 0;
5959
//! Current no_writers generation of the instance
6060
int32_t no_writers_generation_count = 0;
61-
//! Whether the instance has a state notification sample available
62-
bool has_state_notification_sample = false;
6361

6462
DataReaderInstance(
6563
const eprosima::fastrtps::ResourceLimitedContainerConfig& changes_allocation,
@@ -134,7 +132,6 @@ struct DataReaderInstance
134132
break;
135133
}
136134

137-
has_state_notification_sample = false;
138135
return ret_val;
139136
}
140137

@@ -160,7 +157,6 @@ struct DataReaderInstance
160157
if (alive_writers.empty() && (InstanceStateKind::ALIVE_INSTANCE_STATE == instance_state))
161158
{
162159
instance_state = InstanceStateKind::NOT_ALIVE_NO_WRITERS_INSTANCE_STATE;
163-
has_state_notification_sample = true;
164160
}
165161
if (ALIVE_INSTANCE_STATE == instance_state)
166162
{
@@ -295,7 +291,6 @@ struct DataReaderInstance
295291
{
296292
instance_state = InstanceStateKind::NOT_ALIVE_NO_WRITERS_INSTANCE_STATE;
297293
counters_update(counters.instances_alive, counters.instances_no_writers, counters, false);
298-
has_state_notification_sample = true;
299294
}
300295

301296
ret_val = true;

test/blackbox/api/dds-pim/PubSubReader.hpp

Lines changed: 3 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,6 @@
3737
#include <Windows.h>
3838
#endif // _MSC_VER
3939

40-
#include <fastdds/dds/common/InstanceHandle.hpp>
4140
#include <fastdds/dds/core/condition/GuardCondition.hpp>
4241
#include <fastdds/dds/core/condition/StatusCondition.hpp>
4342
#include <fastdds/dds/core/condition/WaitSet.hpp>
@@ -1738,10 +1737,7 @@ class PubSubReader
17381737

17391738
if (ReturnCode_t::RETCODE_OK == datareader_->take(data_seq, info_seq))
17401739
{
1741-
if (info_seq[0].publication_handle != eprosima::fastdds::dds::HANDLE_NIL)
1742-
{
1743-
current_processed_count_++;
1744-
}
1740+
current_processed_count_++;
17451741
return true;
17461742
}
17471743
return false;
@@ -1753,10 +1749,7 @@ class PubSubReader
17531749
eprosima::fastdds::dds::SampleInfo dds_info;
17541750
if (datareader_->take_next_sample(data, &dds_info) == ReturnCode_t::RETCODE_OK)
17551751
{
1756-
if (dds_info.publication_handle != eprosima::fastdds::dds::HANDLE_NIL)
1757-
{
1758-
current_processed_count_++;
1759-
}
1752+
current_processed_count_++;
17601753
return true;
17611754
}
17621755
return false;
@@ -1966,8 +1959,7 @@ class PubSubReader
19661959
ReturnCode_t success = take_ ?
19671960
datareader->take_next_sample(data, &info) :
19681961
datareader->read_next_sample(data, &info);
1969-
if ((ReturnCode_t::RETCODE_OK == success) &&
1970-
(info.publication_handle != eprosima::fastdds::dds::HANDLE_NIL))
1962+
if (ReturnCode_t::RETCODE_OK == success)
19711963
{
19721964
returnedValue = true;
19731965

@@ -2029,12 +2021,6 @@ class PubSubReader
20292021
type& data = datas[i];
20302022
eprosima::fastdds::dds::SampleInfo& info = infos[i];
20312023

2032-
// Skip unknown samples
2033-
if (info.publication_handle == eprosima::fastdds::dds::HANDLE_NIL)
2034-
{
2035-
continue;
2036-
}
2037-
20382024
// Check order of changes.
20392025
LastSeqInfo seq_info{ info.instance_handle, info.sample_identity.writer_guid() };
20402026
ASSERT_LT(last_seq[seq_info], info.sample_identity.sequence_number());

0 commit comments

Comments
 (0)