]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
perfcounters: fix unittest for new admin_socket interface
authorSage Weil <sage.weil@dreamhost.com>
Sat, 7 Jan 2012 03:09:10 +0000 (19:09 -0800)
committerSage Weil <sage.weil@dreamhost.com>
Sat, 7 Jan 2012 04:54:57 +0000 (20:54 -0800)
Broken by b389685afa1be00b5147855bf71c50042bfbfa6c.

Signed-off-by: Sage Weil <sage.weil@dreamhost.com>
src/test/perf_counters.cc

index 9d8b13dcf7d09dae9b6fadd48bc40649c0ea8be1..2612b016eba7bb81fb73db7f8743c686eac9c81f 100644 (file)
@@ -40,7 +40,7 @@ TEST(PerfCounters, SimpleTest) {
   g_ceph_context->_conf->apply_changes(NULL);
   AdminSocketClient client(get_rand_socket_path());
   std::string message;
-  ASSERT_EQ("", client.get_message(&message));
+  ASSERT_EQ("", client.do_request("perfcounters_dump", &message));
   ASSERT_EQ("{}", message);
 }
 
@@ -82,18 +82,18 @@ TEST(PerfCounters, SinglePerfCounters) {
   g_ceph_context->_conf->apply_changes(NULL);
   AdminSocketClient client(get_rand_socket_path());
   std::string msg;
-  ASSERT_EQ("", client.get_message(&msg));
+  ASSERT_EQ("", client.do_request("perfcounters_dump", &msg));
   ASSERT_EQ(sd("{'test_perfcounter_1':{'element1':0,"
            "'element2':0,'element3':{'avgcount':0,'sum':0}}}"), msg);
   fake_pf->inc(TEST_PERFCOUNTERS1_ELEMENT_1);
   fake_pf->fset(TEST_PERFCOUNTERS1_ELEMENT_2, 0.5);
   fake_pf->finc(TEST_PERFCOUNTERS1_ELEMENT_3, 100.0);
-  ASSERT_EQ("", client.get_message(&msg));
+  ASSERT_EQ("", client.do_request("perfcounters_dump", &msg));
   ASSERT_EQ(sd("{'test_perfcounter_1':{'element1':1,"
            "'element2':0.5,'element3':{'avgcount':1,'sum':100}}}"), msg);
   fake_pf->finc(TEST_PERFCOUNTERS1_ELEMENT_3, 0.0);
   fake_pf->finc(TEST_PERFCOUNTERS1_ELEMENT_3, 25.0);
-  ASSERT_EQ("", client.get_message(&msg));
+  ASSERT_EQ("", client.do_request("perfcounters_dump", &msg));
   ASSERT_EQ(sd("{'test_perfcounter_1':{'element1':1,'element2':0.5,"
            "'element3':{'avgcount':3,'sum':125}}}"), msg);
 }
@@ -126,24 +126,24 @@ TEST(PerfCounters, MultiplePerfCounters) {
   AdminSocketClient client(get_rand_socket_path());
   std::string msg;
 
-  ASSERT_EQ("", client.get_message(&msg));
+  ASSERT_EQ("", client.do_request("perfcounters_dump", &msg));
   ASSERT_EQ(sd("{'test_perfcounter_1':{'element1':0,'element2':0,'element3':"
            "{'avgcount':0,'sum':0}},'test_perfcounter_2':{'foo':0,'bar':0}}"), msg);
 
   fake_pf1->inc(TEST_PERFCOUNTERS1_ELEMENT_1);
   fake_pf1->inc(TEST_PERFCOUNTERS1_ELEMENT_1, 5);
-  ASSERT_EQ("", client.get_message(&msg));
+  ASSERT_EQ("", client.do_request("perfcounters_dump", &msg));
   ASSERT_EQ(sd("{'test_perfcounter_1':{'element1':6,'element2':0,'element3':"
            "{'avgcount':0,'sum':0}},'test_perfcounter_2':{'foo':0,'bar':0}}"), msg);
 
   coll->remove(fake_pf2);
-  ASSERT_EQ("", client.get_message(&msg));
+  ASSERT_EQ("", client.do_request("perfcounters_dump", &msg));
   ASSERT_EQ(sd("{'test_perfcounter_1':{'element1':6,'element2':0,"
            "'element3':{'avgcount':0,'sum':0}}}"), msg);
-  ASSERT_EQ("", client.get_schema(&msg));
+  ASSERT_EQ("", client.do_request("perfcounters_schema", &msg));
   ASSERT_EQ(sd("{'test_perfcounter_1':{'element1':{'type':2},"
               "'element2':{'type':1},'element3':{'type':5}}}"), msg);
   coll->clear();
-  ASSERT_EQ("", client.get_message(&msg));
+  ASSERT_EQ("", client.do_request("perfcounters_dump", &msg));
   ASSERT_EQ("{}", msg);
 }