engines/glusterfs_sync.c

   1 /*
   2  * glusterfs engine
   3  *
   4  * IO engine using Glusterfs's gfapi sync interface
   5  *
   6  */
   7
   8 #include "gfapi.h"
   9
  10 #define LAST_POS(f)     ((f)->engine_pos)
  11 static int fio_gf_prep(struct thread_data *td, struct io_u *io_u)
  12 {
  13         struct fio_file *f = io_u->file;
  14         struct gf_data *g = td->io_ops_data;
  15
  16         dprint(FD_FILE, "fio prep\n");
  17
  18         if (!ddir_rw(io_u->ddir))
  19                 return 0;
  20
  21         if (LAST_POS(f) != -1ULL && LAST_POS(f) == io_u->offset)
  22                 return 0;
  23
  24         if (glfs_lseek(g->fd, io_u->offset, SEEK_SET) < 0) {
  25                 td_verror(td, errno, "lseek");
  26                 return 1;
  27         }
  28
  29         return 0;
  30 }
  31
  32 static enum fio_q_status fio_gf_queue(struct thread_data *td, struct io_u *io_u)
  33 {
  34         struct gf_data *g = td->io_ops_data;
  35         int ret = 0;
  36
  37         dprint(FD_FILE, "fio queue len %llu\n", io_u->xfer_buflen);
  38         fio_ro_check(td, io_u);
  39
  40         if (io_u->ddir == DDIR_READ)
  41                 ret = glfs_read(g->fd, io_u->xfer_buf, io_u->xfer_buflen, 0);
  42         else if (io_u->ddir == DDIR_WRITE)
  43                 ret = glfs_write(g->fd, io_u->xfer_buf, io_u->xfer_buflen, 0);
  44         else if (io_u->ddir == DDIR_SYNC)
  45 #if defined(CONFIG_GF_NEW_API)
  46                 ret = glfs_fsync(g->fd, NULL, NULL);
  47 #else
  48                 ret = glfs_fsync(g->fd);
  49 #endif
  50         else if (io_u->ddir == DDIR_DATASYNC)
  51 #if defined(CONFIG_GF_NEW_API)
  52                 ret = glfs_fdatasync(g->fd, NULL, NULL);
  53 #else
  54                 ret = glfs_fdatasync(g->fd);
  55 #endif
  56         else {
  57                 log_err("unsupported operation.\n");
  58                 io_u->error = EINVAL;
  59                 return FIO_Q_COMPLETED;
  60         }
  61         dprint(FD_FILE, "fio len %llu ret %d\n", io_u->xfer_buflen, ret);
  62         if (io_u->file && ret >= 0 && ddir_rw(io_u->ddir))
  63                 LAST_POS(io_u->file) = io_u->offset + ret;
  64
  65         if (ret != (int)io_u->xfer_buflen) {
  66                 if (ret >= 0) {
  67                         io_u->resid = io_u->xfer_buflen - ret;
  68                         io_u->error = 0;
  69                         return FIO_Q_COMPLETED;
  70                 } else
  71                         io_u->error = errno;
  72         }
  73
  74         if (io_u->error) {
  75                 log_err("IO failed.\n");
  76                 td_verror(td, io_u->error, "xfer");
  77         }
  78
  79         return FIO_Q_COMPLETED;
  80
  81 }
  82
  83 static struct ioengine_ops ioengine = {
  84         .name = "gfapi",
  85         .version = FIO_IOOPS_VERSION,
  86         .init = fio_gf_setup,
  87         .cleanup = fio_gf_cleanup,
  88         .prep = fio_gf_prep,
  89         .queue = fio_gf_queue,
  90         .open_file = fio_gf_open_file,
  91         .close_file = fio_gf_close_file,
  92         .unlink_file = fio_gf_unlink_file,
  93         .get_file_size = fio_gf_get_file_size,
  94         .options = gfapi_options,
  95         .option_struct_size = sizeof(struct gf_options),
  96         .flags = FIO_SYNCIO | FIO_DISKLESSIO,
  97 };
  98
  99 static void fio_init fio_gf_register(void)
 100 {
 101         register_ioengine(&ioengine);
 102 }
 103
 104 static void fio_exit fio_gf_unregister(void)
 105 {
 106         unregister_ioengine(&ioengine);
 107 }