summaryrefslogtreecommitdiff
path: root/source3/lib
diff options
context:
space:
mode:
Diffstat (limited to 'source3/lib')
-rw-r--r--source3/lib/asys/asys.c43
1 files changed, 43 insertions, 0 deletions
diff --git a/source3/lib/asys/asys.c b/source3/lib/asys/asys.c
index 766a716f9a..9937d2482d 100644
--- a/source3/lib/asys/asys.c
+++ b/source3/lib/asys/asys.c
@@ -35,9 +35,14 @@ struct asys_pread_args {
off_t offset;
};
+struct asys_fsync_args {
+ int fildes;
+};
+
union asys_job_args {
struct asys_pwrite_args pwrite_args;
struct asys_pread_args pread_args;
+ struct asys_fsync_args fsync_args;
};
struct asys_job {
@@ -232,6 +237,44 @@ static void asys_pread_do(void *private_data)
}
}
+static void asys_fsync_do(void *private_data);
+
+int asys_fsync(struct asys_context *ctx, int fildes, void *private_data)
+{
+ struct asys_job *job;
+ struct asys_fsync_args *args;
+ int jobid;
+ int ret;
+
+ ret = asys_new_job(ctx, &jobid, &job);
+ if (ret != 0) {
+ return ret;
+ }
+ job->private_data = private_data;
+
+ args = &job->args.fsync_args;
+ args->fildes = fildes;
+
+ ret = pthreadpool_add_job(ctx->pool, jobid, asys_fsync_do, job);
+ if (ret != 0) {
+ return ret;
+ }
+ job->busy = 1;
+
+ return 0;
+}
+
+static void asys_fsync_do(void *private_data)
+{
+ struct asys_job *job = (struct asys_job *)private_data;
+ struct asys_fsync_args *args = &job->args.fsync_args;
+
+ job->ret = fsync(args->fildes);
+ if (job->ret == -1) {
+ job->err = errno;
+ }
+}
+
void asys_cancel(struct asys_context *ctx, void *private_data)
{
unsigned i;