msg/simple/DispatchQueue: inject internal delays in special event dispatch

E.g., connection reset.  This will help uncover subtle races.

Signed-off-by: Sage Weil <sage@redhat.com>

diff --git a/src/msg/simple/DispatchQueue.cc b/src/msg/simple/DispatchQueue.cc
index fed198e49849780b3333f3af0ba9eee5771b72d7..be46c360e88188dcc49c656f2a44cb2f05d15f3e 100644 (file)
--- a/src/msg/simple/DispatchQueue.cc
+++ b/src/msg/simple/DispatchQueue.cc
@@ -150,6 +150,15 @@ void DispatchQueue::entry()
       lock.Unlock();
 
       if (qitem.is_code()) {
+       if (cct->_conf->ms_inject_internal_delays &&
+           cct->_conf->ms_inject_delay_probability &&
+           (rand() % 10000)/10000.0 < cct->_conf->ms_inject_delay_probability) {
+         utime_t t;
+         t.set_from_double(cct->_conf->ms_inject_internal_delays);
+         ldout(cct, 1) << "DispatchQueue::entry  inject delay of " << t
+                       << dendl;
+         t.sleep();
+       }
        switch (qitem.get_code()) {
        case D_BAD_REMOTE_RESET:
          msgr->ms_deliver_handle_remote_reset(qitem.get_connection());