Skip to content

Commit

Permalink
Refs #20653: Increase sleep to miss the deadline in test exclusive_ki…
Browse files Browse the repository at this point in the history
…nd_non_keyed_reliable_deadline

Signed-off-by: elianalf <[email protected]>
  • Loading branch information
elianalf committed Mar 27, 2024
1 parent a0bd331 commit 7fea8ef
Showing 1 changed file with 10 additions and 10 deletions.
20 changes: 10 additions & 10 deletions test/blackbox/common/DDSBlackboxTestsOwnershipQos.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -721,46 +721,46 @@ TEST_P(OwnershipQos, exclusive_kind_non_keyed_reliable_deadline)

writer1.send_sample(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(30));

writer2.send_sample(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(30));

writer1.send_sample(data.front());
denied_samples.push_back(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(30));

writer2.send_sample(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(30));

writer1.send_sample(data.front());
denied_samples.push_back(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(30));

writer2.send_sample(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(30));

writer1.send_sample(data.front());
denied_samples.push_back(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(110));

writer1.send_sample(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(30));

writer1.send_sample(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(30));

writer1.send_sample(data.front());
data.pop_front();
std::this_thread::sleep_for(std::chrono::milliseconds(50));
std::this_thread::sleep_for(std::chrono::milliseconds(30));

reader.block_for_seq({0, 7});
ASSERT_EQ(denied_samples.size(), reader.data_not_received().size());
Expand Down

0 comments on commit 7fea8ef

Please sign in to comment.