#include "path-util.h"
#include "process-util.h"
#include "socket-util.h"
+#include "stat-util.h"
#include "strv.h"
#include "time-util.h"
-#include "util.h"
#define SNDBUF_SIZE (8*1024*1024)
_public_ int sd_listen_fds(int unset_environment) {
const char *e;
- int n, r, fd;
+ int n, r;
pid_t pid;
e = getenv("LISTEN_PID");
goto finish;
}
- for (fd = SD_LISTEN_FDS_START; fd < SD_LISTEN_FDS_START + n; fd ++) {
+ for (int fd = SD_LISTEN_FDS_START; fd < SD_LISTEN_FDS_START + n; fd ++) {
r = fd_cloexec(fd, true);
if (r < 0)
goto finish;
return -errno;
}
- return
- st_path.st_dev == st_fd.st_dev &&
- st_path.st_ino == st_fd.st_ino;
+ return stat_inode_same(&st_path, &st_fd);
}
return 1;
}
if (S_ISREG(st_fd.st_mode) && S_ISREG(st_path.st_mode))
- return
- st_path.st_dev == st_fd.st_dev &&
- st_path.st_ino == st_fd.st_ino;
+ return stat_inode_same(&st_path, &st_fd);
else if (S_ISCHR(st_fd.st_mode) && S_ISCHR(st_path.st_mode))
return st_path.st_rdev == st_fd.st_rdev;
else
return 1;
}
-static int sd_is_socket_internal(int fd, int type, int listening) {
+static int is_socket_internal(int fd, int type, int listening) {
struct stat st_fd;
assert_return(fd >= 0, -EBADF);
assert_return(fd >= 0, -EBADF);
assert_return(family >= 0, -EINVAL);
- r = sd_is_socket_internal(fd, type, listening);
+ r = is_socket_internal(fd, type, listening);
if (r <= 0)
return r;
assert_return(fd >= 0, -EBADF);
assert_return(IN_SET(family, 0, AF_INET, AF_INET6), -EINVAL);
- r = sd_is_socket_internal(fd, type, listening);
+ r = is_socket_internal(fd, type, listening);
if (r <= 0)
return r;
assert_return(addr_len >= sizeof(sa_family_t), -ENOBUFS);
assert_return(IN_SET(addr->sa_family, AF_INET, AF_INET6), -EPFNOSUPPORT);
- r = sd_is_socket_internal(fd, type, listening);
+ r = is_socket_internal(fd, type, listening);
if (r <= 0)
return r;
assert_return(fd >= 0, -EBADF);
- r = sd_is_socket_internal(fd, type, listening);
+ r = is_socket_internal(fd, type, listening);
if (r <= 0)
return r;
}
if (path) {
- char fpath[PATH_MAX];
+ _cleanup_free_ char *fpath = NULL;
struct stat a, b;
assert_return(path_is_absolute(path), -EINVAL);
if (fstat(fd, &a) < 0)
return -errno;
- strncpy(stpcpy(fpath, "/dev/mqueue"), path, sizeof(fpath) - 12);
- fpath[sizeof(fpath)-1] = 0;
+ fpath = path_join("/dev/mqueue", path);
+ if (!fpath)
+ return -ENOMEM;
if (stat(fpath, &b) < 0)
return -errno;
- if (a.st_dev != b.st_dev ||
- a.st_ino != b.st_ino)
+ if (!stat_inode_same(&a, &b))
return 0;
}
.msg_iovlen = 1,
.msg_name = &sockaddr,
};
- _cleanup_close_ int fd = -1;
+ _cleanup_close_ int fd = -EBADF;
struct cmsghdr *cmsg = NULL;
const char *e;
bool send_ucred;
r = safe_atou64(s, &u);
if (r < 0)
goto finish;
- if (u <= 0 || u >= USEC_INFINITY) {
+ if (!timestamp_is_set(u)) {
r = -EINVAL;
goto finish;
}