diff --git a/src/test/msgr/test_msgr.cc b/src/test/msgr/test_msgr.cc index 2a55393c779..9e71ba61246 100644 --- a/src/test/msgr/test_msgr.cc +++ b/src/test/msgr/test_msgr.cc @@ -1357,8 +1357,10 @@ class MarkdownDispatcher : public Dispatcher { Mutex::Locker l(lock); count.inc(); conns.insert(m->get_connection()); - if (conns.size() < 2 && !last_mark) + if (conns.size() < 2 && !last_mark) { + m->put(); return true; + } last_mark = true; usleep(rand() % 500);