4 * common Glusterfs's gfapi interface
10 struct fio_option gfapi_options[] = {
13 .lname = "Glusterfs volume",
14 .type = FIO_OPT_STR_STORE,
15 .help = "Name of the Glusterfs volume",
16 .off1 = offsetof(struct gf_options, gf_vol),
17 .category = FIO_OPT_C_ENGINE,
18 .group = FIO_OPT_G_GFAPI,
22 .lname = "Glusterfs brick name",
23 .type = FIO_OPT_STR_STORE,
24 .help = "Name of the Glusterfs brick to connect",
25 .off1 = offsetof(struct gf_options, gf_brick),
26 .category = FIO_OPT_C_ENGINE,
27 .group = FIO_OPT_G_GFAPI,
34 int fio_gf_setup(struct thread_data *td)
37 struct gf_data *g = NULL;
38 struct gf_options *opt = td->eo;
39 struct stat sb = { 0, };
41 dprint(FD_IO, "fio setup\n");
46 g = malloc(sizeof(struct gf_data));
48 log_err("malloc failed.\n");
55 g->fs = glfs_new(opt->gf_vol);
57 log_err("glfs_new failed.\n");
60 glfs_set_logging(g->fs, "/tmp/fio_gfapi.log", 7);
62 r = glfs_set_volfile_server(g->fs, "tcp", opt->gf_brick, 0);
64 log_err("glfs_set_volfile_server failed.\n");
69 log_err("glfs_init failed. Is glusterd running on brick?\n");
73 r = glfs_lstat(g->fs, ".", &sb);
75 log_err("glfs_lstat failed.\n");
78 dprint(FD_FILE, "fio setup %p\n", g->fs);
85 td->io_ops->data = NULL;
89 void fio_gf_cleanup(struct thread_data *td)
91 struct gf_data *g = td->io_ops->data;
101 td->io_ops->data = NULL;
105 int fio_gf_get_file_size(struct thread_data *td, struct fio_file *f)
109 struct gf_data *g = td->io_ops->data;
111 dprint(FD_FILE, "get file size %s\n", f->file_name);
116 if (fio_file_size_known(f))
119 ret = glfs_lstat(g->fs, f->file_name, &buf);
121 log_err("glfs_lstat failed.\n");
125 f->real_file_size = buf.st_size;
126 fio_file_set_size_known(f);
132 int fio_gf_open_file(struct thread_data *td, struct fio_file *f)
137 struct gf_data *g = td->io_ops->data;
138 struct stat sb = { 0, };
143 } else if (td_read(td)) {
151 flags |= OS_O_DIRECT;
155 dprint(FD_FILE, "fio file %s open mode %s td rw %s\n", f->file_name,
156 flags & O_RDONLY ? "ro" : "rw", td_read(td) ? "read" : "write");
157 g->fd = glfs_creat(g->fs, f->file_name, flags, 0644);
160 log_err("glfs_creat failed.\n");
163 /* file for read doesn't exist or shorter than required, create/extend it */
165 if (glfs_lstat(g->fs, f->file_name, &sb)
166 || sb.st_size < f->real_file_size) {
167 dprint(FD_FILE, "fio extend file %s from %ld to %ld\n",
168 f->file_name, sb.st_size, f->real_file_size);
169 ret = glfs_ftruncate(g->fd, f->real_file_size);
171 log_err("failed fio extend file %s to %ld\n",
172 f->file_name, f->real_file_size);
174 unsigned long long left;
179 /* fill the file, copied from extend_file */
180 b = malloc(td->o.max_bs[DDIR_WRITE]);
182 left = f->real_file_size;
183 while (left && !td->terminate) {
184 bs = td->o.max_bs[DDIR_WRITE];
188 fill_io_buffer(td, b, bs, bs);
190 r = glfs_write(g->fd, b, bs, 0);
192 "fio write %d of %ld file %s\n",
193 r, f->real_file_size,
208 ("fio: ENOSPC on laying out "
224 glfs_lseek(g->fd, 0, SEEK_SET);
226 if (td->terminate && td->o.unlink) {
227 dprint(FD_FILE, "terminate unlink %s\n",
229 glfs_unlink(g->fs, f->file_name);
230 } else if (td->o.create_fsync) {
231 if (glfs_fsync(g->fd) < 0) {
233 "failed to sync, close %s\n",
235 td_verror(td, errno, "fsync");
244 #if defined(GFAPI_USE_FADVISE)
248 r = glfs_fadvise(g->fd, 0, f->real_file_size,
251 r = glfs_fadvise(g->fd, 0, f->real_file_size,
252 POSIX_FADV_SEQUENTIAL);
255 dprint(FD_FILE, "fio %p fadvise %s status %d\n", g->fs,
260 dprint(FD_FILE, "fio %p created %s\n", g->fs, f->file_name);
267 int fio_gf_close_file(struct thread_data *td, struct fio_file *f)
270 struct gf_data *g = td->io_ops->data;
272 dprint(FD_FILE, "fd close %s\n", f->file_name);
275 if (g->fd && glfs_close(g->fd) < 0)
283 int fio_gf_unlink_file(struct thread_data *td, struct fio_file *f)
286 struct gf_data *g = td->io_ops->data;
288 dprint(FD_FILE, "fd unlink %s\n", f->file_name);
291 if (g->fd && glfs_close(g->fd) < 0)
294 glfs_unlink(g->fs, f->file_name);
302 td->io_ops->data = NULL;