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_keyed_reliable_deadline

Signed-off-by: elianalf <62831776+elianalf@users.noreply.github.com>
  • Loading branch information
@elianalf
elianalf committed Apr 3, 2024
1 parent 7fea8ef commit fc4cfa8
Showing 1 changed file with 18 additions and 18 deletions.
36 changes: 18 additions & 18 deletions test/blackbox/common/DDSBlackboxTestsOwnershipQos.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -721,29 +721,29 @@ 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(30));
std::this_thread::sleep_for(std::chrono::milliseconds(20));

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

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

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

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

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

writer1.send_sample(data.front());
denied_samples.push_back(data.front());
Expand All @@ -752,15 +752,15 @@ 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(30));
std::this_thread::sleep_for(std::chrono::milliseconds(20));

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

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

reader.block_for_seq({0, 7});
ASSERT_EQ(denied_samples.size(), reader.data_not_received().size());
Expand Down Expand Up @@ -800,49 +800,49 @@ TEST_P(OwnershipQos, exclusive_kind_keyed_reliable_deadline)
data.pop_front();
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(20));

writer2.send_sample(data.front());
data.pop_front();
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(20));

writer1.send_sample(data.front());
denied_samples.push_back(data.front());
data.pop_front();
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(20));

writer2.send_sample(data.front());
data.pop_front();
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(20));

writer1.send_sample(data.front());
denied_samples.push_back(data.front());
data.pop_front();
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(20));

writer2.send_sample(data.front());
data.pop_front();
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(20));

writer1.send_sample(data.front());
denied_samples.push_back(data.front());
data.pop_front();
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();
Expand All @@ -853,7 +853,7 @@ TEST_P(OwnershipQos, exclusive_kind_keyed_reliable_deadline)
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();
Expand All @@ -864,7 +864,7 @@ TEST_P(OwnershipQos, exclusive_kind_keyed_reliable_deadline)
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();
Expand Down

0 comments on commit fc4cfa8

Please sign in to comment.