ceph之rbd读写API 测试

重温战场

　　rados、rbd读写API测试：



  1 //compile:
  2 //gcc ceph_test_v2.c  -lrbd -lrados  -g -Wall
  3
  4 #include <stdio.h>
  5 #include <stdlib.h>
  6 #include <string.h>
  7 #include <rados/librados.h>
  8 #include <rbd/librbd.h>
  9
10 static int print_progress_percent(uint64_t offset, uint64_t src_size,void *data)
11 {
12     float percent = ((float)offset*100)/src_size;
13     printf("%3.2f%% done\n", percent);
14     return 0;
15 }
16
17 int main(int argc, char** argv)
18 {
19     rados_t cluster;
20     char cluster_name[] = "ceph";
21     char user_name[] = "client.admin";
22     uint64_t flags = 0;
23     int i=0;
24
25     rados_ioctx_t io;
26     char *poolname = "kvm";
27
28     //Initialize the cluster handle with the "ceph" cluster name
29     //and the "client.admin" user name
30     int rt_num;
31     rt_num = rados_create2(&cluster, cluster_name, user_name, flags);
32     if(rt_num<0){
33         printf("%s: Couldn't create the cluster handle! %s\n", argv[0], strerror(-rt_num));
34         return -1;
35     }else{
36         printf("\nCreated a cluster handle success. \n");
37     }   
38     
39     //Read a ceph configuration file to configure the cluster handle
40     rt_num = rados_conf_read_file(cluster, "/etc/ceph/ceph.conf");
41     if(rt_num<0){
42         printf("%s:can't read config file: %s\n", argv[0], strerror(-rt_num));
43         return -1;
44     }else{
45         printf("\nRead the config file. \n");
46     }
47
48     //Read command line arguments
49     /*
50     rt_num = rados_conf_parse_argv(cluster, argc, argv);
51     if(rt_num<0){
52         printf("%s:cannot parse command line arguments:%s\n", argv[0], strerror(-rt_num));
53         return -1;
54     }else{
55         printf("\nRead the command line arguments.\n");
56     }*/
57
58     //Connect to the cluster
59     rt_num = rados_connect(cluster);
60     if(rt_num<0){
61         printf("%s:cannot connect to cluster:%s\n", argv[0], strerror(-rt_num));
62         return -1;
63     }else{
64         printf("\nConnected to the cluster.\n");
65     }
66
67     //create io handle
68     rt_num = rados_ioctx_create(cluster, poolname, &io);
69     if(rt_num<0){
70         printf("%s:cannot open rados pool %s:%s", argv[0], poolname, strerror(-rt_num));
71         rados_shutdown(cluster);
72         return -1;
73     }else{
74         printf("\nCreated I/O context. \n");
75     }
76
77     const char* name = "3400.img";
78     const char* name_01 = "3000.img";
79     /*const char* name_02 = "rbd_test_02.img";
80     uint64_t size = 1073741824;
81     uint64_t features = 1073741824;
82     int order = 22;     //warning
83     //int rbd_create2(rados_ioctx_t io, const char *name, uint64_t size, uint64_t features, int *order);
84     rt_num = rbd_create( io, name, size, &order);
85     if( rt_num ==0 ){
86         printf("\nrbd_create success !!\n");
87     }else{
88         printf("\nrbd_create failed !!%s\n", strerror(-rt_num));
89     }*/
90
91
92     rbd_image_t image;
93     //rbd_image_info_t info;
94     //size_t  infosize;
95
96     //rt_num = rbd_stat(image, &info, sizeof(info));
97     //if(rt_num < 0){
98     //  printf("rbd_stat error !!\n");
99     //}
100     //printf("rbd_stat rt_num:%d, size:%d", rt_num, (int)info.size);
101
102     //int rbd_remove_with_progress(rados_ioctx_t io, const char *name,librbd_progress_fn_t cb, void *cbdata);
103     //librbd_progress_fn_t cb;
104     //void* cbdata = NULL;
105     printf("\nremove img name:%s\n", name_01);
106     rt_num = rbd_remove_with_progress(io, name_01, print_progress_percent, NULL);
107     if(rt_num ==0){
108         printf("\nrbd_remove success !!\n");
109     }
110
111     //int rbd_open(rados_ioctx_t io, const char *name, rbd_image_t *image, const char *snap_name);
112     rt_num = rbd_open( io, name, &image, NULL);
113                                                      if( rt_num ==0 ){
114         printf("\nrbd_open success !!\n");
115     }else{
116         printf("\nrbd_open failed !!%s\n", strerror(-rt_num));
117     }
118
119     size_t num = 156384;
120     char* buf=(char*)malloc(num);
121     char buf1[30]="";
122     uint64_t ofs = 0;
123     ssize_t  ok_size = 0;
124     i = 10;
125     //ssize_t rbd_write(rbd_image_t image, uint64_t ofs, size_t len, const char *buf);
126     for(;i>0;i--){
127         ok_size = rbd_write(image, ofs, num , buf);
128         if(ok_size == num){
129             ofs = ok_size + ofs;
130             printf("rbd_write ok!! ofs: %lu\n", ofs);
131         }else{
132             printf("rbd_write fail!!\n");
133         }
134     }
135
136     rbd_image_info_t info_tmp;
137     rt_num = rbd_stat(image, &info_tmp, sizeof(info_tmp));
138     if(rt_num < 0){
139         printf("\nrbd_stat failed %s\n", name);
140     }else{
141         printf("\nrbd_stat size :%d\n", (int)info_tmp.size);
142     }
143
144
145     ofs = 0;
146     rt_num = rbd_get_size(image, &ofs);
147     if(rt_num >= 0){
148         printf("\nrbd_get_size %d\n", (int)ofs);
149     }
150     printf("\nrbd_get_size return_num: %d\n", rt_num);
151     ofs = 0;
152     //ssize_t rbd_read(rbd_image_t image, uint64_t ofs, size_t len, char *buf);
153     for(i=0;i<10;i++){
154         ok_size = rbd_read(image, ofs, 10, buf1);
155         if(ok_size >0){
156             ofs = 10+ofs;
157             printf("\nthe content is:%s", buf1);
158         }else{
159             printf("rbd_read fail!!\n");
160         }
161     }
162
163     //int rbd_aio_write(rbd_image_t image, uint64_t off, size_t len, const char *buf, rbd_completion_t c);
164     //int rbd_aio_read(rbd_image_t image, uint64_t off, size_t len, char *buf, rbd_completion_t c);
165
166     /*
167      rt_num = rbd_open_read_only( io, name_01, image, NULL);
168      if(rt_num == 0){
169         printf("\nrbd_open_read_only success !!\n");
170      }else{
171         printf("\nrbd_open_read_only fail !!\n");
172      }
173     */
174
175
176
177     rt_num = rbd_close(image);
178     if(rt_num == 0){
179         printf("\nrbd_close success !!\n");
180     }else{
181         printf("\nrbd_close failed !!%s\n", strerror(-rt_num));
182     }
183
184     printf("\nClosing the connection\n");
185     rados_ioctx_destroy(io);
186     printf("\nShut down the handle\n");
187     rados_shutdown(cluster);
188     return 0;
189 }