shared/async: introduce asynchronous_close_many() helper

diff --git a/src/shared/async.c b/src/shared/async.c
index e0c7e7dcaab44b9206ed205345d2410b46dedfa4..acde1b11d7d66abb4c646df8673ce331ccda8d9d 100644 (file)
--- a/src/shared/async.c
+++ b/src/shared/async.c
@@ -133,6 +133,13 @@ int asynchronous_close(int fd) {
         return -EBADF; /* return an invalidated fd */
 }
 
+void asynchronous_close_many(const int fds[], size_t n_fds) {
+        assert(fds || n_fds == 0);
+
+        FOREACH_ARRAY(i, fds, n_fds)
+                asynchronous_close(*i);
+}
+
 int asynchronous_rm_rf(const char *p, RemoveFlags flags) {
         int r;
 

diff --git a/src/shared/async.h b/src/shared/async.h
index 2f5bbd51a52f3664202117d87d8ca59fe4c44c3a..d8604f874621806938a86539fec76621d651cda4 100644 (file)
--- a/src/shared/async.h
+++ b/src/shared/async.h
@@ -21,7 +21,10 @@
 
 int asynchronous_sync(pid_t *ret_pid);
 int asynchronous_fsync(int fd, pid_t *ret_pid);
+
 int asynchronous_close(int fd);
-int asynchronous_rm_rf(const char *p, RemoveFlags flags);
+void asynchronous_close_many(const int fds[], size_t n_fds);
 
 DEFINE_TRIVIAL_CLEANUP_FUNC(int, asynchronous_close);
+
+int asynchronous_rm_rf(const char *p, RemoveFlags flags);