]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
tools: clean up dead code in immutable obj cache
authorYuan Zhou <yuan.zhou@intel.com>
Wed, 23 Jan 2019 16:19:14 +0000 (00:19 +0800)
committerYuan Zhou <yuan.zhou@intel.com>
Thu, 21 Mar 2019 16:16:28 +0000 (00:16 +0800)
Signed-off-by: Yuan Zhou <yuan.zhou@intel.com>
src/test/immutable_object_cache/test_message.cc
src/tools/immutable_object_cache/CacheClient.cc
src/tools/immutable_object_cache/SocketCommon.h
src/tools/immutable_object_cache/Types.cc
src/tools/immutable_object_cache/Types.h

index c8360ec0f5c147e96e2a340cf3261d3b6bb23f1c..bcaed1d5fc4c368ededba1911da90713a4e0f8a8 100644 (file)
@@ -5,8 +5,6 @@ using namespace ceph::immutable_obj_cache;
 
 TEST(test_for_message, test_1) 
 {
-  std::string pool_name("this is a pool name");
-  std::string image_name("this is an image name");
   std::string oid_name("this is a oid name");
 
   ObjectCacheMsgHeader header;
@@ -23,11 +21,8 @@ TEST(test_for_message, test_1)
 
   req.m_head = header;
 
-  req.m_data.m_image_size = 111111;
   req.m_data.m_read_offset = 222222;
   req.m_data.m_read_len = 333333;
-  req.m_data.m_pool_name = pool_name;
-  req.m_data.m_image_name = image_name;
   req.m_data.m_oid = oid_name;
 
   req.encode();
@@ -49,10 +44,7 @@ TEST(test_for_message, test_1)
   ASSERT_EQ(req_decode->m_head.reserved, header.reserved);
 
 
-  ASSERT_EQ(req_decode->m_data.m_image_size, 111111);
   ASSERT_EQ(req_decode->m_data.m_read_offset, 222222);
   ASSERT_EQ(req_decode->m_data.m_read_len, 333333);
-  ASSERT_EQ(req_decode->m_data.m_pool_name, pool_name);
-  ASSERT_EQ(req_decode->m_data.m_image_name, image_name);
   ASSERT_EQ(req_decode->m_data.m_oid, oid_name);
 }
index 71bc6d11abc48d147eeb8d1715a384bef1971784..317faefb329da26072c71b7d4b5df639addc4ff4 100644 (file)
@@ -111,7 +111,6 @@ namespace immutable_obj_cache {
 
     req->m_data.m_pool_id = pool_id;
     req->m_data.m_snap_id = snap_id;
-    req->m_data.m_pool_name = "";
     req->m_data.m_pool_namespace = pool_nspace;
     req->m_data.m_oid = oid;
     req->m_process_msg = on_finish;
index 7c914213d16ffc7aa2ed9efe6f508c5c551df8b2..1831e2715a5a48ddaa2aa694eb93916195cc5dcc 100644 (file)
@@ -12,8 +12,7 @@ static const int RBDSC_READ            =  0X12;
 static const int RBDSC_LOOKUP          =  0X13;
 static const int RBDSC_REGISTER_REPLY  =  0X14;
 static const int RBDSC_READ_REPLY      =  0X15;
-static const int RBDSC_LOOKUP_REPLY    =  0X16;
-static const int RBDSC_READ_RADOS      =  0X17;
+static const int RBDSC_READ_RADOS      =  0X16;
 
 static const int ASIO_ERROR_READ = 0X01;
 static const int ASIO_ERROR_WRITE = 0X02;
index a6748a5862766a6dcb19fb0cbe7f07d3e8b8b31d..4d341dd45b2c1d2f80f05e0825eef5b5033054aa 100644 (file)
@@ -29,13 +29,10 @@ void ObjectCacheMsgHeader::decode(bufferlist::const_iterator& it) {
 }
 
 void ObjectCacheMsgData::encode(bufferlist& bl) {
-  ceph::encode(m_image_size, bl);
   ceph::encode(m_read_offset, bl);
   ceph::encode(m_read_len, bl);
   ceph::encode(m_pool_id, bl);
   ceph::encode(m_snap_id, bl);
-  ceph::encode(m_pool_name, bl);
-  ceph::encode(m_image_name, bl);
   ceph::encode(m_oid, bl);
   ceph::encode(m_pool_namespace, bl);
   ceph::encode(m_cache_path, bl);
@@ -43,13 +40,10 @@ void ObjectCacheMsgData::encode(bufferlist& bl) {
 
 void ObjectCacheMsgData::decode(bufferlist& bl) {
   auto i = bl.cbegin();
-  ceph::decode(m_image_size, i);
   ceph::decode(m_read_offset, i);
   ceph::decode(m_read_len, i);
   ceph::decode(m_pool_id, i);
   ceph::decode(m_snap_id, i);
-  ceph::decode(m_pool_name, i);
-  ceph::decode(m_image_name, i);
   ceph::decode(m_oid, i);
   ceph::decode(m_pool_namespace, i);
   ceph::decode(m_cache_path, i);
index 675dc84ed29fc6be5bdb9a4f8d0a7fa35ec88cf2..cbe5f4da97a3e8d32288c46add80db1a42b5442b 100644 (file)
@@ -25,13 +25,10 @@ struct ObjectCacheMsgHeader {
 // TODO : cleanup useless data
 class ObjectCacheMsgData {
 public:
-  uint64_t m_image_size;
   uint64_t m_read_offset;
   uint64_t m_read_len;
   uint64_t m_pool_id;
   uint64_t m_snap_id;
-  std::string m_pool_name;
-  std::string m_image_name;
   std::string m_oid;
   std::string m_pool_namespace; // TODO : Jason suggestion
   std::string m_cache_path;