remove ceph code

[stor4nfv.git] / src / ceph / src / test / test_workqueue.cc

diff --git a/src/ceph/src/test/test_workqueue.cc b/src/ceph/src/test/test_workqueue.cc
deleted file mode 100644 (file)
index e1787fe..0000000
--- a/src/ceph/src/test/test_workqueue.cc
+++ /dev/null
@@ -1,55 +0,0 @@
-#include "gtest/gtest.h"
-
-#include "common/WorkQueue.h"
-#include "common/ceph_argparse.h"
-
-TEST(WorkQueue, StartStop)
-{
-  ThreadPool tp(g_ceph_context, "foo", "tp_foo", 10, "");
-  
-  tp.start();
-  tp.pause();
-  tp.pause_new();
-  tp.unpause();
-  tp.unpause();
-  tp.drain();
-  tp.stop();
-}
-
-TEST(WorkQueue, Resize)
-{
-  ThreadPool tp(g_ceph_context, "bar", "tp_bar", 2, "osd_peering_wq_threads");
-  
-  tp.start();
-
-  sleep(1);
-  ASSERT_EQ(2, tp.get_num_threads());
-
-  g_conf->set_val("osd peering wq threads", "5");
-  g_conf->apply_changes(&cout);
-  sleep(1);
-  ASSERT_EQ(5, tp.get_num_threads());
-
-  g_conf->set_val("osd peering wq threads", "3");
-  g_conf->apply_changes(&cout);
-  sleep(1);
-  ASSERT_EQ(3, tp.get_num_threads());
-
-  g_conf->set_val("osd peering wq threads", "0");
-  g_conf->apply_changes(&cout);
-  sleep(1);
-  ASSERT_EQ(0, tp.get_num_threads());
-
-  g_conf->set_val("osd peering wq threads", "15");
-  g_conf->apply_changes(&cout);
-  sleep(1);
-  ASSERT_EQ(15, tp.get_num_threads());
-
-  g_conf->set_val("osd peering wq threads", "-1");
-  g_conf->apply_changes(&cout);
-  sleep(1);
-  ASSERT_EQ(15, tp.get_num_threads());
-
-  sleep(1);
-  tp.stop();
-}