diff options
Diffstat (limited to 'source3/lib/asys/asys.c')
| -rw-r--r-- | source3/lib/asys/asys.c | 43 |
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; |