From: Colin Patrick McCabe <cmccabe@alumni.cmu.edu>
Date: Wed, 3 Nov 2010 22:35:34 +0000 (-0700)
Subject: TestTimers: add test for out-of-order timer insert
X-Git-Tag: v0.24~229^2~4
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=b0e737461a4f8825cef7991bd18567da13c2c739;p=ceph.git

TestTimers: add test for out-of-order timer insert

Signed-off-by: Colin McCabe <colinm@hq.newdream.net>
---

diff --git a/src/test/TestTimers.cc b/src/test/TestTimers.cc
index 8d7859279e1..47b2bec137a 100644
--- a/src/test/TestTimers.cc
+++ b/src/test/TestTimers.cc
@@ -46,10 +46,10 @@ protected:
   int num;
 };
 
-class CancellationTestContext : public TestContext
+class StrictOrderTestContext : public TestContext
 {
 public:
-  CancellationTestContext (int num_)
+  StrictOrderTestContext (int num_)
     : TestContext(num_)
   {
   }
@@ -57,12 +57,12 @@ public:
   virtual void finish(int r)
   {
     array_lock.Lock();
-    cout << "CancellationTestContext " << num << std::endl;
+    cout << "StrictOrderTestContext " << num << std::endl;
     array[num] = num;
     array_lock.Unlock();
   }
 
-  virtual ~CancellationTestContext()
+  virtual ~StrictOrderTestContext()
   {
   }
 };
@@ -92,7 +92,7 @@ static int basic_timer_test(T &timer, Mutex *lock)
   for (int i = 0; i < MAX_TEST_CONTEXTS; ++i) {
     if (lock)
       lock->Lock();
-    utime_t inc(2 * i, 0); 
+    utime_t inc(2 * i, 0);
     utime_t t = g_clock.now() + inc;
     timer.add_event_at(t, test_contexts[i]);
     if (lock)
@@ -118,6 +118,53 @@ static int basic_timer_test(T &timer, Mutex *lock)
   return ret;
 }
 
+static int test_out_of_order_insertion(SafeTimer &timer, Mutex *lock)
+{
+  int ret = 0;
+  memset(&array, 0, sizeof(array));
+  array_idx = 0;
+  memset(&test_contexts, 0, sizeof(test_contexts));
+
+  cout << __PRETTY_FUNCTION__ << std::endl;
+
+  test_contexts[0] = new StrictOrderTestContext(0);
+  test_contexts[1] = new StrictOrderTestContext(1);
+
+  {
+    utime_t inc(100, 0);
+    utime_t t = g_clock.now() + inc;
+    lock->Lock();
+    timer.add_event_at(t, test_contexts[0]);
+    lock->Unlock();
+  }
+
+  {
+    utime_t inc(2, 0);
+    utime_t t = g_clock.now() + inc;
+    lock->Lock();
+    timer.add_event_at(t, test_contexts[1]);
+    lock->Unlock();
+  }
+
+  int secs = 0;
+  for (; secs < 100 ; ++secs) {
+    sleep(1);
+    array_lock.Lock();
+    int a = array[1];
+    array_lock.Unlock();
+    if (a == 1)
+      break;
+  }
+
+  if (secs == 100) {
+    ret = 1;
+    cout << "error: expected array[" << 1 << "] = " << 1
+	 << "; got " << array[1] << " instead." << std::endl;
+  }
+
+  return ret;
+}
+
 static int test_timers(void)
 {
   int ret = 0;
@@ -179,7 +226,7 @@ static int safe_timer_cancellation_test(SafeTimer &safe_timer, Mutex& safe_timer
   memset(&test_contexts, 0, sizeof(test_contexts));
 
   for (int i = 0; i < MAX_TEST_CONTEXTS; ++i) {
-    test_contexts[i] = new CancellationTestContext(i);
+    test_contexts[i] = new StrictOrderTestContext(i);
   }
 
   safe_timer_lock.Lock();
@@ -232,6 +279,10 @@ static int test_safe_timers(void)
   if (ret)
     goto done;
 
+  ret = test_out_of_order_insertion(safe_timer, &safe_timer_lock);
+  if (ret)
+    goto done;
+
 done:
   print_status("test_safe_timers", ret);
   return ret;