15263807472

/* SPDX-License-Identifier: LGPL-2.1-or-later */

#include <fcntl.h>
#include <sys/stat.h>
#include <unistd.h>

#include "alloc-util.h"
#include "errno-util.h"
#include "fd-util.h"
#include "fs-util.h"
#include "log.h"
#include "path-util.h"
#include "string-util.h"
#include "sync-util.h"

int fsync_directory_of_file(int fd) {
        _cleanup_close_ int dfd = -EBADF;
        struct stat st;
        int r;

        assert(fd >= 0);

        /* We only reasonably can do this for regular files and directories, or for O_PATH fds, hence check
         * for the inode type first */
        if (fstat(fd, &st) < 0)
                return -errno;

        if (S_ISDIR(st.st_mode)) {
                dfd = openat(fd, "..", O_RDONLY|O_DIRECTORY|O_CLOEXEC, 0);
                if (dfd < 0)
                        return -errno;

        } else if (!S_ISREG(st.st_mode)) { /* Regular files are OK regardless if O_PATH or not, for all other
                                            * types check O_PATH flag */
                r = fd_is_opath(fd);
                if (r < 0)
                        return r;
                if (!r) /* If O_PATH this refers to the inode in the fs, in which case we can sensibly do
                         * what is requested. Otherwise this refers to a socket, fifo or device node, where
                         * the concept of a containing directory doesn't make too much sense. */
                        return -ENOTTY;
        }

        if (dfd < 0) {
                _cleanup_free_ char *path = NULL;

                r = fd_get_path(fd, &path);
                if (r < 0) {
                        log_debug_errno(r, "Failed to query /proc/self/fd/%d%s: %m",
                                        fd,
                                        r == -ENOSYS ? ", ignoring" : "");

                        if (r == -ENOSYS)
                                /* If /proc is not available, we're most likely running in some
                                 * chroot environment, and syncing the directory is not very
                                 * important in that case. Let's just silently do nothing. */
                                return 0;

                        return r;
                }

                if (!path_is_absolute(path))
                        return -EINVAL;

                dfd = open_parent(path, O_CLOEXEC|O_NOFOLLOW, 0);
                if (dfd < 0)
                        return dfd;
        }

        return RET_NERRNO(fsync(dfd));
}

int fsync_full(int fd) {
        int r, q;

        /* Sync both the file and the directory */

        r = RET_NERRNO(fsync(fd));

        q = fsync_directory_of_file(fd);
        if (r < 0) /* Return earlier error */
                return r;
        if (q == -ENOTTY) /* Ignore if the 'fd' refers to a block device or so which doesn't really have a
                           * parent dir */
                return 0;
        return q;
}

int fsync_path_at(int at_fd, const char *path) {
        _cleanup_close_ int opened_fd = -EBADF;
        int fd;

        if (isempty(path)) {
                if (at_fd == AT_FDCWD) {
                        opened_fd = open(".", O_RDONLY|O_DIRECTORY|O_CLOEXEC);
                        if (opened_fd < 0)
                                return -errno;

                        fd = opened_fd;
                } else
                        fd = at_fd;
        } else {
                opened_fd = openat(at_fd, path, O_RDONLY|O_CLOEXEC|O_NONBLOCK);
                if (opened_fd < 0)
                        return -errno;

                fd = opened_fd;
        }

        return RET_NERRNO(fsync(fd));
}

int fsync_parent_at(int at_fd, const char *path) {
        _cleanup_close_ int opened_fd = -EBADF;

        if (isempty(path)) {
                if (at_fd != AT_FDCWD)
                        return fsync_directory_of_file(at_fd);

                opened_fd = open("..", O_RDONLY|O_DIRECTORY|O_CLOEXEC);
                if (opened_fd < 0)
                        return -errno;

                return RET_NERRNO(fsync(opened_fd));
        }

        opened_fd = openat(at_fd, path, O_PATH|O_CLOEXEC|O_NOFOLLOW);
        if (opened_fd < 0)
                return -errno;

        return fsync_directory_of_file(opened_fd);
}

int fsync_path_and_parent_at(int at_fd, const char *path) {
        _cleanup_close_ int opened_fd = -EBADF;

        if (isempty(path)) {
                if (at_fd != AT_FDCWD)
                        return fsync_full(at_fd);

                opened_fd = open(".", O_RDONLY|O_DIRECTORY|O_CLOEXEC);
        } else
                opened_fd = openat(at_fd, path, O_RDONLY|O_NOFOLLOW|O_NONBLOCK|O_CLOEXEC);
        if (opened_fd < 0)
                return -errno;

        return fsync_full(opened_fd);
}

int syncfs_path(int at_fd, const char *path) {
        _cleanup_close_ int fd = -EBADF;

        if (isempty(path)) {
                if (at_fd != AT_FDCWD)
                        return RET_NERRNO(syncfs(at_fd));

                fd = open(".", O_RDONLY|O_DIRECTORY|O_CLOEXEC);
        } else
                fd = openat(at_fd, path, O_RDONLY|O_CLOEXEC|O_NONBLOCK);
        if (fd < 0)
                return -errno;

        return RET_NERRNO(syncfs(fd));
}

1	/* SPDX-License-Identifier: LGPL-2.1-or-later */
2
3	#include <fcntl.h>
4	#include <sys/stat.h>
5	#include <unistd.h>
6
7	#include "alloc-util.h"
8	#include "errno-util.h"
9	#include "fd-util.h"
10	#include "fs-util.h"
11	#include "log.h"
12	#include "path-util.h"
13	#include "string-util.h"
14	#include "sync-util.h"
15
16	int fsync_directory_of_file(int fd) {	1,789,098✔
17	_cleanup_close_ int dfd = -EBADF;	1,789,098✔
18	struct stat st;	1,789,098✔
19	int r;	1,789,098✔
20
21	assert(fd >= 0);	1,789,098✔
22
23	/* We only reasonably can do this for regular files and directories, or for O_PATH fds, hence check
24	* for the inode type first */
25	if (fstat(fd, &st) < 0)	1,789,098✔
UNCOV 26	return -errno;	×
27
28	if (S_ISDIR(st.st_mode)) {	1,789,098✔
29	dfd = openat(fd, "..", O_RDONLY\|O_DIRECTORY\|O_CLOEXEC, 0);	46✔
30	if (dfd < 0)	46✔
UNCOV 31	return -errno;	×
32
33	} else if (!S_ISREG(st.st_mode)) { /* Regular files are OK regardless if O_PATH or not, for all other	1,789,052✔
34	* types check O_PATH flag */
35	r = fd_is_opath(fd);	4✔
36	if (r < 0)	4✔
37	return r;
38	if (!r) /* If O_PATH this refers to the inode in the fs, in which case we can sensibly do	4✔
39	* what is requested. Otherwise this refers to a socket, fifo or device node, where
40	* the concept of a containing directory doesn't make too much sense. */
41	return -ENOTTY;
42	}
43
44	if (dfd < 0) {
45	_cleanup_free_ char *path = NULL;	1,789,052✔
46
47	r = fd_get_path(fd, &path);	1,789,052✔
48	if (r < 0) {	1,789,052✔
UNCOV 49	log_debug_errno(r, "Failed to query /proc/self/fd/%d%s: %m",	×
50	fd,
51	r == -ENOSYS ? ", ignoring" : "");
52
UNCOV 53	if (r == -ENOSYS)	×
54	/* If /proc is not available, we're most likely running in some
55	* chroot environment, and syncing the directory is not very
56	* important in that case. Let's just silently do nothing. */
57	return 0;
58
UNCOV 59	return r;	×
60	}
61
62	if (!path_is_absolute(path))	1,789,052✔
63	return -EINVAL;
64
65	dfd = open_parent(path, O_CLOEXEC\|O_NOFOLLOW, 0);	1,789,052✔
66	if (dfd < 0)	1,789,052✔
67	return dfd;
68	}
69
70	return RET_NERRNO(fsync(dfd));	1,789,098✔
71	}
72
73	int fsync_full(int fd) {	1,787,159✔
74	int r, q;	1,787,159✔
75
76	/* Sync both the file and the directory */
77
78	r = RET_NERRNO(fsync(fd));	1,787,159✔
79
80	q = fsync_directory_of_file(fd);	1,787,159✔
81	if (r < 0) /* Return earlier error */	1,787,159✔
82	return r;
83	if (q == -ENOTTY) /* Ignore if the 'fd' refers to a block device or so which doesn't really have a	1,787,159✔
84	* parent dir */
UNCOV 85	return 0;	×
86	return q;
87	}
88
89	int fsync_path_at(int at_fd, const char *path) {	1✔
90	_cleanup_close_ int opened_fd = -EBADF;	1✔
91	int fd;	1✔
92
93	if (isempty(path)) {	1✔
94	if (at_fd == AT_FDCWD) {	×
95	opened_fd = open(".", O_RDONLY\|O_DIRECTORY\|O_CLOEXEC);	×
96	if (opened_fd < 0)	×
UNCOV 97	return -errno;	×
98
99	fd = opened_fd;
100	} else
101	fd = at_fd;
102	} else {
103	opened_fd = openat(at_fd, path, O_RDONLY\|O_CLOEXEC\|O_NONBLOCK);	1✔
104	if (opened_fd < 0)	1✔
UNCOV 105	return -errno;	×
106
107	fd = opened_fd;
108	}
109
110	return RET_NERRNO(fsync(fd));	1✔
111	}
112
113	int fsync_parent_at(int at_fd, const char *path) {	132✔
114	_cleanup_close_ int opened_fd = -EBADF;	132✔
115
116	if (isempty(path)) {	132✔
117	if (at_fd != AT_FDCWD)	×
UNCOV 118	return fsync_directory_of_file(at_fd);	×
119
120	opened_fd = open("..", O_RDONLY\|O_DIRECTORY\|O_CLOEXEC);	×
121	if (opened_fd < 0)	×
UNCOV 122	return -errno;	×
123
UNCOV 124	return RET_NERRNO(fsync(opened_fd));	×
125	}
126
127	opened_fd = openat(at_fd, path, O_PATH\|O_CLOEXEC\|O_NOFOLLOW);	132✔
128	if (opened_fd < 0)	132✔
UNCOV 129	return -errno;	×
130
131	return fsync_directory_of_file(opened_fd);	132✔
132	}
133
134	int fsync_path_and_parent_at(int at_fd, const char *path) {	32✔
135	_cleanup_close_ int opened_fd = -EBADF;	32✔
136
137	if (isempty(path)) {	32✔
138	if (at_fd != AT_FDCWD)	×
UNCOV 139	return fsync_full(at_fd);	×
140
UNCOV 141	opened_fd = open(".", O_RDONLY\|O_DIRECTORY\|O_CLOEXEC);	×
142	} else
143	opened_fd = openat(at_fd, path, O_RDONLY\|O_NOFOLLOW\|O_NONBLOCK\|O_CLOEXEC);	32✔
144	if (opened_fd < 0)	32✔
UNCOV 145	return -errno;	×
146
147	return fsync_full(opened_fd);	32✔
148	}
149
150	int syncfs_path(int at_fd, const char *path) {	617✔
151	_cleanup_close_ int fd = -EBADF;	617✔
152
153	if (isempty(path)) {	617✔
154	if (at_fd != AT_FDCWD)	×
UNCOV 155	return RET_NERRNO(syncfs(at_fd));	×
156
UNCOV 157	fd = open(".", O_RDONLY\|O_DIRECTORY\|O_CLOEXEC);	×
158	} else
159	fd = openat(at_fd, path, O_RDONLY\|O_CLOEXEC\|O_NONBLOCK);	617✔
160	if (fd < 0)	617✔
UNCOV 161	return -errno;	×
162
163	return RET_NERRNO(syncfs(fd));	617✔
164	}

systemd / systemd / 15263807472

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous