diff options
| -rw-r--r-- | src/core/async.c | 22 | ||||
| -rw-r--r-- | src/core/async.h | 2 |
2 files changed, 24 insertions, 0 deletions
diff --git a/src/core/async.c b/src/core/async.c index af527bea4e..3876deda70 100644 --- a/src/core/async.c +++ b/src/core/async.c @@ -24,6 +24,7 @@ #include "async.h" #include "log.h" +#include "util.h" int asynchronous_job(void* (*func)(void *p), void *arg) { pthread_attr_t a; @@ -70,3 +71,24 @@ int asynchronous_sync(void) { return asynchronous_job(sync_thread, NULL); } + +static void *close_thread(void *p) { + safe_close(PTR_TO_INT(p)); + return NULL; +} + +int asynchronous_close(int fd) { + int r; + + /* This is supposed to behave similar to safe_close(), but + * actually invoke close() asynchronously, so that it will + * never block. Ideally the kernel would have an API for this, + * but it doesn't, so we work around it, and hide this as a + * far away as we can. */ + + r = asynchronous_job(close_thread, INT_TO_PTR(fd)); + if (r < 0) + safe_close(fd); + + return -1; +} diff --git a/src/core/async.h b/src/core/async.h index 6601b4dc4b..7f1ef79532 100644 --- a/src/core/async.h +++ b/src/core/async.h @@ -22,4 +22,6 @@ ***/ int asynchronous_job(void* (*func)(void *p), void *arg); + int asynchronous_sync(void); +int asynchronous_close(int fd); |