#include "path-util.h"
#include "process-util.h"
#include "signal-util.h"
+#include "time-util.h"
#include "tests.h"
#include "tmpfile-util.h"
ASSERT_OK(asynchronous_sync(NULL));
}
+static void wait_fd_closed(int fd) {
+ for (unsigned trial = 0; trial < 100; trial++) {
+ usleep_safe(100 * USEC_PER_MSEC);
+ if (fcntl(fd, F_GETFD) < 0) {
+ assert_se(errno == EBADF);
+ return;
+ }
+ }
+
+ assert_not_reached();
+}
+
TEST(asynchronous_close) {
_cleanup_(unlink_tempfilep) char name[] = "/tmp/test-asynchronous_close.XXXXXX";
int fd, r;
fd = mkostemp_safe(name);
ASSERT_OK(fd);
asynchronous_close(fd);
-
- sleep(1);
-
- ASSERT_EQ(fcntl(fd, F_GETFD), -1);
- assert_se(errno == EBADF);
+ wait_fd_closed(fd);
r = safe_fork("(subreaper)", FORK_RESET_SIGNALS|FORK_CLOSE_ALL_FDS|FORK_DEATHSIG_SIGKILL|FORK_LOG|FORK_WAIT, NULL);
ASSERT_OK(r);
fd = open("/dev/null", O_RDONLY|O_CLOEXEC);
ASSERT_OK(fd);
asynchronous_close(fd);
-
- sleep(1);
-
- ASSERT_EQ(fcntl(fd, F_GETFD), -1);
- assert_se(errno == EBADF);
+ wait_fd_closed(fd);
_exit(EXIT_SUCCESS);
}