RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-19 08:57:27 +00:00
Code Issues Packages Projects Releases Wiki Activity

rgw/amqp: remove a test that requires syncronization

Browse Source 
betwen the amqp manager internal thread and the test itself
amqp reconnect should be tested by system test instead

Signed-off-by: Yuval Lifshitz <yuvalif@yahoo.com>
This commit is contained in:
Yuval Lifshitz 2019-11-10 11:57:57 +02:00
parent 7715cd4b6a
commit 10a27ef809
1 changed files with 0 additions and 54 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
src/test/rgw/test_rgw_amqp.cc
View File

@ -454,57 +454,3 @@ TEST_F(TestAMQP, RetryFailWrite)
amqp_mock::set_valid_host("localhost");
}
int fail_after = -1;
int recover_after = -1;
bool expect_zero_rc = true;
void my_callback_triggering_failure(int rc) {
if (expect_zero_rc) {
EXPECT_EQ(rc, 0);
} else {
EXPECT_NE(rc, 0);
}
++callbacks_invoked;
if (fail_after == callbacks_invoked) {
amqp_mock::FAIL_NEXT_READ = true;
expect_zero_rc = false;
}
if (recover_after == callbacks_invoked) {
amqp_mock::FAIL_NEXT_READ = false;
}
}
TEST_F(TestAMQP, AcksWithReconnect)
{
callbacks_invoked = 0;
const std::string host("localhost1");
amqp_mock::set_valid_host(host);
conn = amqp::connect("amqp://" + host, "ex1");
EXPECT_TRUE(conn);
amqp_mock::set_multiple(59);
// failure will take effect after: max(59, 70)
fail_after = 70;
// all callback are flushed during failure, so, recover will take effect after: max(90, 100)
recover_after = 90;
const auto NUMBER_OF_CALLS = 100;
for (auto i = 0; i < NUMBER_OF_CALLS; ++i) {
auto rc = publish_with_confirm(conn, "topic", "message", my_callback_triggering_failure);
EXPECT_EQ(rc, 0);
}
// connection failes before multiple acks
wait_until_drained();
EXPECT_EQ(callbacks_invoked, NUMBER_OF_CALLS);
// publish more mesages
expect_zero_rc = true;
for (auto i = 0; i < NUMBER_OF_CALLS; ++i) {
auto rc = publish_with_confirm(conn, "topic", "message", my_callback_triggering_failure);
EXPECT_EQ(rc, 0);
}
wait_until_drained();
EXPECT_EQ(callbacks_invoked, 2*NUMBER_OF_CALLS);
callbacks_invoked = 0;
amqp_mock::set_valid_host("localhost");
fail_after = -1;
}