|
Zbigniew Jędrzejewski-Szmek |
7f93bc |
From 075d60ceb2efdafcdf5586653b912eeed84194e0 Mon Sep 17 00:00:00 2001
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
From: Lennart Poettering <lennart@poettering.net>
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
Date: Fri, 2 May 2014 17:56:05 +0200
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
Subject: [PATCH] async: add asynchronous close() call
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
(cherry picked from commit 8a474b0c04a5a3608dda53edc1ddaa932ba177bf)
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
(cherry picked from commit 43f1b28bc457c92f85332dda752d5426cde466ae)
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
---
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
src/core/async.c | 22 ++++++++++++++++++++++
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
src/core/async.h | 2 ++
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
2 files changed, 24 insertions(+)
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
diff --git a/src/core/async.c b/src/core/async.c
|
|
Zbigniew Jędrzejewski-Szmek |
1cc3df |
index af527bea4e..3876deda70 100644
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
--- a/src/core/async.c
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+++ b/src/core/async.c
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
@@ -24,6 +24,7 @@
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
#include "async.h"
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
#include "log.h"
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+#include "util.h"
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
int asynchronous_job(void* (*func)(void *p), void *arg) {
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
pthread_attr_t a;
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
@@ -70,3 +71,24 @@ int asynchronous_sync(void) {
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
return asynchronous_job(sync_thread, NULL);
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
}
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+static void *close_thread(void *p) {
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ safe_close(PTR_TO_INT(p));
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ return NULL;
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+}
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+int asynchronous_close(int fd) {
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ int r;
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ /* This is supposed to behave similar to safe_close(), but
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ * actually invoke close() asynchronously, so that it will
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ * never block. Ideally the kernel would have an API for this,
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ * but it doesn't, so we work around it, and hide this as a
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ * far away as we can. */
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ r = asynchronous_job(close_thread, INT_TO_PTR(fd));
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ if (r < 0)
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ safe_close(fd);
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+ return -1;
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+}
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
diff --git a/src/core/async.h b/src/core/async.h
|
|
Zbigniew Jędrzejewski-Szmek |
1cc3df |
index 6601b4dc4b..7f1ef79532 100644
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
--- a/src/core/async.h
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+++ b/src/core/async.h
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
@@ -22,4 +22,6 @@
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
***/
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
int asynchronous_job(void* (*func)(void *p), void *arg);
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
int asynchronous_sync(void);
|
|
Zbigniew Jędrzejewski-Szmek |
a59965 |
+int asynchronous_close(int fd);
|