RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-20 17:37:29 +00:00
Code Issues Packages Projects Releases Wiki Activity

Test rados_exec, C and C++ version

Browse Source 
* Test rados_exec, C and C++ version

* add test_exec action

Signed-off-by: Colin McCabe <colin.mccabe@dreamhost.com>
This commit is contained in:
Colin Patrick McCabe 2011-08-17 13:52:14 -07:00
parent 3c3089ff7d
commit f3260643b6
2 changed files with 52 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/cls_rbd.cc
View File

@ -20,6 +20,7 @@ cls_method_handle_t h_snapshot_add;
cls_method_handle_t h_snapshot_remove;
cls_method_handle_t h_snapshot_revert;
cls_method_handle_t h_assign_bid;
cls_method_handle_t h_test_exec;
static int snap_read_header(cls_method_context_t hctx, bufferlist& bl)
{
@ -366,6 +367,15 @@ int rbd_assign_bid(cls_method_context_t hctx, bufferlist *in, bufferlist *out)
return out->length();
}
/* Used for testing rados_exec */
static int test_exec(cls_method_context_t hctx, bufferlist *in, bufferlist *out)
{
bufferlist bl;
std::string testing123("testing123");
::encode(testing123, *out);
return out->length();
}
void __cls_init()
{
CLS_LOG("Loaded rbd class!");
@ -379,6 +389,8 @@ void __cls_init()
/* assign a unique block id for rbd blocks */
cls_register_cxx_method(h_class, "assign_bid", CLS_METHOD_RD | CLS_METHOD_WR | CLS_METHOD_PUBLIC, rbd_assign_bid, &h_assign_bid);
cls_register_cxx_method(h_class, "test_exec", CLS_METHOD_RD | CLS_METHOD_PUBLIC, test_exec, &h_test_exec);
return;
}

59
src/test/rados-api/misc.cc
View File

@ -114,25 +114,46 @@ TEST(LibRadosMisc, TmapUpdatePP) {
ASSERT_EQ(0, destroy_one_pool_pp(pool_name, cluster));
}
//TEST(LibRadosMisc, Exec) {
// char buf[128];
// char buf2[sizeof(buf)];
// char buf3[sizeof(buf)];
// rados_t cluster;
// rados_ioctx_t ioctx;
// std::string pool_name = get_temp_pool_name();
// ASSERT_EQ("", create_one_pool(pool_name, &cluster));
// rados_ioctx_create(cluster, pool_name.c_str(), &ioctx);
// memset(buf, 0xcc, sizeof(buf));
// ASSERT_EQ((int)sizeof(buf), rados_write(ioctx, "foo", buf, sizeof(buf), 0));
// strncpy(buf2, "abracadabra", sizeof(buf2));
// memset(buf3, 0, sizeof(buf3));
// ASSERT_EQ(0, rados_exec(ioctx, "foo", "crypto", "md5",
// buf2, strlen(buf2) + 1, buf3, sizeof(buf3)));
// ASSERT_EQ(string("06fce6115b1efc638e0cc2026f69ec43"), string(buf3));
// rados_ioctx_destroy(ioctx);
// ASSERT_EQ(0, destroy_one_pool(pool_name, &cluster));
//}
TEST(LibRadosMisc, Exec) {
char buf[128];
rados_t cluster;
rados_ioctx_t ioctx;
std::string pool_name = get_temp_pool_name();
ASSERT_EQ("", create_one_pool(pool_name, &cluster));
rados_ioctx_create(cluster, pool_name.c_str(), &ioctx);
memset(buf, 0xcc, sizeof(buf));
ASSERT_EQ((int)sizeof(buf), rados_write(ioctx, "foo", buf, sizeof(buf), 0));
char buf2[512];
int res = rados_exec(ioctx, "foo", "rbd", "test_exec",
NULL, 0, buf2, sizeof(buf2));
ASSERT_GT(res, 0);
bufferlist bl;
bl.append(buf2, res);
bufferlist::iterator iter = bl.begin();
std::string outstring;
::decode(outstring, iter);
ASSERT_EQ(outstring, string("testing123"));
rados_ioctx_destroy(ioctx);
ASSERT_EQ(0, destroy_one_pool(pool_name, &cluster));
}
TEST(LibRadosMisc, ExecPP) {
Rados cluster;
std::string pool_name = get_temp_pool_name();
ASSERT_EQ("", create_one_pool_pp(pool_name, cluster));
IoCtx ioctx;
cluster.ioctx_create(pool_name.c_str(), ioctx);
bufferlist bl;
ASSERT_EQ(0, ioctx.write("foo", bl, 0, 0));
bufferlist bl2, out;
ASSERT_EQ(0, ioctx.exec("foo", "rbd", "test_exec", bl2, out));
bufferlist::iterator iter = out.begin();
std::string outstring;
::decode(outstring, iter);
ASSERT_EQ(outstring, string("testing123"));
ioctx.close();
ASSERT_EQ(0, destroy_one_pool_pp(pool_name, cluster));
}
//int rados_tmap_update(rados_ioctx_t io, const char *o, const char *cmdbuf, size_t cmdbuflen);