1 files changed, 57 insertions, 0 deletions

diff --git a/source3/modules/vfs_aio_posix.c b/source3/modules/vfs_aio_posix.c
index 97b102b5e4..3629541e61 100644
--- a/source3/modules/vfs_aio_posix.c
+++ b/source3/modules/vfs_aio_posix.c
@@ -209,6 +209,61 @@ static ssize_t aio_posix_recv(struct tevent_req *req, int *err)
 	return state->ret;
 }
 
+static struct tevent_req *aio_posix_fsync_send(
+	struct vfs_handle_struct *handle, TALLOC_CTX *mem_ctx,
+	struct tevent_context *ev, struct files_struct *fsp)
+{
+	struct tevent_req *req;
+	struct aio_posix_state *state;
+	struct aiocb *a;
+	int ret;
+
+	req = tevent_req_create(mem_ctx, &state, struct aio_posix_state);
+	if (req == NULL) {
+		return NULL;
+	}
+
+	a = &state->acb;
+
+	a->aio_fildes = fsp->fh->fd;
+	a->aio_sigevent.sigev_notify = SIGEV_SIGNAL;
+	a->aio_sigevent.sigev_signo  = RT_SIGNAL_AIO;
+	a->aio_sigevent.sigev_value.sival_ptr = req;
+
+	ret = aio_fsync(O_SYNC, a);
+	if (ret == 0) {
+		talloc_set_destructor(state, aio_posix_state_destructor);
+		return req;
+	}
+
+	if (errno == EAGAIN) {
+		/*
+		 * aio overloaded, do the sync fallback
+		 */
+		state->ret = fsync(fsp->fh->fd);
+		if (state->ret == -1) {
+			state->err = errno;
+		}
+		tevent_req_done(req);
+		return tevent_req_post(req, ev);
+	}
+
+	tevent_req_error(req, errno);
+	return tevent_req_post(req, ev);
+}
+
+static int aio_posix_int_recv(struct tevent_req *req, int *err)
+{
+	struct aio_posix_state *state = tevent_req_data(
+		req, struct aio_posix_state);
+
+	if (tevent_req_is_unix_error(req, err)) {
+		return -1;
+	}
+	*err = state->err;
+	return state->ret;
+}
+
 static int aio_posix_connect(vfs_handle_struct *handle, const char *service,
 			     const char *user)
 {
@@ -233,6 +288,8 @@ static struct vfs_fn_pointers vfs_aio_posix_fns = {
 	.pread_recv_fn = aio_posix_recv,
 	.pwrite_send_fn = aio_posix_pwrite_send,
 	.pwrite_recv_fn = aio_posix_recv,
+	.fsync_send_fn = aio_posix_fsync_send,
+	.fsync_recv_fn = aio_posix_int_recv,
 };
 
 NTSTATUS vfs_aio_posix_init(void);