From 656955ebe92b443148f8d8925737651330814825 Mon Sep 17 00:00:00 2001 From: Jens Axboe Date: Wed, 10 Dec 2014 08:12:56 -0700 Subject: [PATCH] gluster: wire up sync/datasync opcodes Signed-off-by: Jens Axboe --- engines/glusterfs_async.c | 2 ++ engines/glusterfs_sync.c | 4 ++++ 2 files changed, 6 insertions(+) diff --git a/engines/glusterfs_async.c b/engines/glusterfs_async.c index 95ca84ef..8283f8be 100644 --- a/engines/glusterfs_async.c +++ b/engines/glusterfs_async.c @@ -117,6 +117,8 @@ static int fio_gf_async_queue(struct thread_data fio_unused * td, r = glfs_discard_async(g->fd, io_u->offset, io_u->xfer_buflen, gf_async_cb, io_u); #endif + else if (io_u->ddir == DDIR_DATASYNC) + r = glfs_fdatasync_async(g->fd, gf_async_cb, io_u); else if (io_u->ddir == DDIR_SYNC) r = glfs_fsync_async(g->fd, gf_async_cb, io_u); else diff --git a/engines/glusterfs_sync.c b/engines/glusterfs_sync.c index 235d74f6..6de4ee29 100644 --- a/engines/glusterfs_sync.c +++ b/engines/glusterfs_sync.c @@ -41,6 +41,10 @@ static int fio_gf_queue(struct thread_data *td, struct io_u *io_u) ret = glfs_read(g->fd, io_u->xfer_buf, io_u->xfer_buflen, 0); else if (io_u->ddir == DDIR_WRITE) ret = glfs_write(g->fd, io_u->xfer_buf, io_u->xfer_buflen, 0); + else if (io_u->ddir == DDIR_SYNC) + ret = glfs_fsync(g->fd); + else if (io_u->ddir == DDIR_DATASYNC) + ret = glfs_fdatasync(g->fd); else { log_err("unsupported operation.\n"); return -EINVAL; -- 2.25.1