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;
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();
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);
}
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;
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;
}
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);
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);
// 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;