From: Jens Axboe <axboe@fb.com>
Date: Wed, 10 Dec 2014 15:12:56 +0000 (-0700)
Subject: gluster: wire up sync/datasync opcodes
X-Git-Tag: fio-2.2.0~25
X-Git-Url: https://git.kernel.dk/?p=fio.git;a=commitdiff_plain;h=656955ebe92b443148f8d8925737651330814825;hp=3b577774803435109e070cc8f4313fc485c9160f

gluster: wire up sync/datasync opcodes

Signed-off-by: Jens Axboe <axboe@fb.com>
---

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;