colin/NetworkManager
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

systemd: update code from upstream (2019-02-05)

Browse Source 
This is a direct dump from systemd git.

======

SYSTEMD_DIR=../systemd
COMMIT=6d6308f6774b4c684de7f3aab12cb752c59d5e2f

(
  cd "$SYSTEMD_DIR"
  git checkout "$COMMIT"
  git reset --hard
  git clean -fdx
)

git ls-files -z :/src/systemd/src/ \
                :/shared/systemd/src/ \
                :/shared/nm-utils/unaligned.h | \
  xargs -0 rm -f

nm_copy_sd_shared() {
    mkdir -p "./shared/systemd/$(dirname "$1")"
    cp "$SYSTEMD_DIR/$1" "./shared/systemd/$1"
}

nm_copy_sd_core() {
    mkdir -p "./src/systemd/$(dirname "$1")"
    cp "$SYSTEMD_DIR/$1" "./src/systemd/$1"
}

nm_copy_sd_nmutils() {
    mkdir -p "./shared/nm-utils/"
    cp "$SYSTEMD_DIR/$1" "./shared/nm-utils/${1##*/}"
}

nm_copy_sd_core "src/libsystemd-network/arp-util.c"
nm_copy_sd_core "src/libsystemd-network/arp-util.h"
nm_copy_sd_core "src/libsystemd-network/dhcp-identifier.c"
nm_copy_sd_core "src/libsystemd-network/dhcp-identifier.h"
nm_copy_sd_core "src/libsystemd-network/dhcp-internal.h"
nm_copy_sd_core "src/libsystemd-network/dhcp-lease-internal.h"
nm_copy_sd_core "src/libsystemd-network/dhcp-network.c"
nm_copy_sd_core "src/libsystemd-network/dhcp-option.c"
nm_copy_sd_core "src/libsystemd-network/dhcp-packet.c"
nm_copy_sd_core "src/libsystemd-network/dhcp-protocol.h"
nm_copy_sd_core "src/libsystemd-network/dhcp6-internal.h"
nm_copy_sd_core "src/libsystemd-network/dhcp6-lease-internal.h"
nm_copy_sd_core "src/libsystemd-network/dhcp6-network.c"
nm_copy_sd_core "src/libsystemd-network/dhcp6-option.c"
nm_copy_sd_core "src/libsystemd-network/dhcp6-protocol.h"
nm_copy_sd_core "src/libsystemd-network/lldp-internal.h"
nm_copy_sd_core "src/libsystemd-network/lldp-neighbor.c"
nm_copy_sd_core "src/libsystemd-network/lldp-neighbor.h"
nm_copy_sd_core "src/libsystemd-network/lldp-network.c"
nm_copy_sd_core "src/libsystemd-network/lldp-network.h"
nm_copy_sd_core "src/libsystemd-network/network-internal.c"
nm_copy_sd_core "src/libsystemd-network/network-internal.h"
nm_copy_sd_core "src/libsystemd-network/sd-dhcp-client.c"
nm_copy_sd_core "src/libsystemd-network/sd-dhcp-lease.c"
nm_copy_sd_core "src/libsystemd-network/sd-dhcp6-client.c"
nm_copy_sd_core "src/libsystemd-network/sd-dhcp6-lease.c"
nm_copy_sd_core "src/libsystemd-network/sd-ipv4acd.c"
nm_copy_sd_core "src/libsystemd-network/sd-ipv4ll.c"
nm_copy_sd_core "src/libsystemd-network/sd-lldp.c"
nm_copy_sd_core "src/libsystemd/sd-event/event-source.h"
nm_copy_sd_core "src/libsystemd/sd-event/event-util.c"
nm_copy_sd_core "src/libsystemd/sd-event/event-util.h"
nm_copy_sd_core "src/libsystemd/sd-event/sd-event.c"
nm_copy_sd_core "src/libsystemd/sd-id128/id128-util.c"
nm_copy_sd_core "src/libsystemd/sd-id128/id128-util.h"
nm_copy_sd_core "src/libsystemd/sd-id128/sd-id128.c"
nm_copy_sd_core "src/shared/dns-domain.c"
nm_copy_sd_core "src/shared/dns-domain.h"
nm_copy_sd_core "src/systemd/_sd-common.h"
nm_copy_sd_core "src/systemd/sd-dhcp-client.h"
nm_copy_sd_core "src/systemd/sd-dhcp-lease.h"
nm_copy_sd_core "src/systemd/sd-dhcp6-client.h"
nm_copy_sd_core "src/systemd/sd-dhcp6-lease.h"
nm_copy_sd_core "src/systemd/sd-event.h"
nm_copy_sd_core "src/systemd/sd-id128.h"
nm_copy_sd_core "src/systemd/sd-ipv4acd.h"
nm_copy_sd_core "src/systemd/sd-ipv4ll.h"
nm_copy_sd_core "src/systemd/sd-lldp.h"
nm_copy_sd_core "src/systemd/sd-ndisc.h"
nm_copy_sd_nmutils "src/basic/unaligned.h"
nm_copy_sd_shared "src/basic/alloc-util.c"
nm_copy_sd_shared "src/basic/alloc-util.h"
nm_copy_sd_shared "src/basic/async.h"
nm_copy_sd_shared "src/basic/env-file.c"
nm_copy_sd_shared "src/basic/env-file.h"
nm_copy_sd_shared "src/basic/env-util.c"
nm_copy_sd_shared "src/basic/env-util.h"
nm_copy_sd_shared "src/basic/escape.c"
nm_copy_sd_shared "src/basic/escape.h"
nm_copy_sd_shared "src/basic/ether-addr-util.c"
nm_copy_sd_shared "src/basic/ether-addr-util.h"
nm_copy_sd_shared "src/basic/extract-word.c"
nm_copy_sd_shared "src/basic/extract-word.h"
nm_copy_sd_shared "src/basic/fd-util.c"
nm_copy_sd_shared "src/basic/fd-util.h"
nm_copy_sd_shared "src/basic/fileio.c"
nm_copy_sd_shared "src/basic/fileio.h"
nm_copy_sd_shared "src/basic/fs-util.c"
nm_copy_sd_shared "src/basic/fs-util.h"
nm_copy_sd_shared "src/basic/hash-funcs.c"
nm_copy_sd_shared "src/basic/hash-funcs.h"
nm_copy_sd_shared "src/basic/hashmap.c"
nm_copy_sd_shared "src/basic/hashmap.h"
nm_copy_sd_shared "src/basic/hexdecoct.c"
nm_copy_sd_shared "src/basic/hexdecoct.h"
nm_copy_sd_shared "src/basic/hostname-util.c"
nm_copy_sd_shared "src/basic/hostname-util.h"
nm_copy_sd_shared "src/basic/in-addr-util.c"
nm_copy_sd_shared "src/basic/in-addr-util.h"
nm_copy_sd_shared "src/basic/io-util.c"
nm_copy_sd_shared "src/basic/io-util.h"
nm_copy_sd_shared "src/basic/list.h"
nm_copy_sd_shared "src/basic/log.h"
nm_copy_sd_shared "src/basic/macro.h"
nm_copy_sd_shared "src/basic/mempool.c"
nm_copy_sd_shared "src/basic/mempool.h"
nm_copy_sd_shared "src/basic/missing_fcntl.h"
nm_copy_sd_shared "src/basic/missing_type.h"
nm_copy_sd_shared "src/basic/parse-util.c"
nm_copy_sd_shared "src/basic/parse-util.h"
nm_copy_sd_shared "src/basic/path-util.c"
nm_copy_sd_shared "src/basic/path-util.h"
nm_copy_sd_shared "src/basic/prioq.c"
nm_copy_sd_shared "src/basic/prioq.h"
nm_copy_sd_shared "src/basic/process-util.c"
nm_copy_sd_shared "src/basic/process-util.h"
nm_copy_sd_shared "src/basic/random-util.c"
nm_copy_sd_shared "src/basic/random-util.h"
nm_copy_sd_shared "src/basic/refcnt.h"
nm_copy_sd_shared "src/basic/set.h"
nm_copy_sd_shared "src/basic/signal-util.h"
nm_copy_sd_shared "src/basic/siphash24.h"
nm_copy_sd_shared "src/basic/socket-util.c"
nm_copy_sd_shared "src/basic/socket-util.h"
nm_copy_sd_shared "src/basic/sparse-endian.h"
nm_copy_sd_shared "src/basic/stat-util.c"
nm_copy_sd_shared "src/basic/stat-util.h"
nm_copy_sd_shared "src/basic/stdio-util.h"
nm_copy_sd_shared "src/basic/string-table.c"
nm_copy_sd_shared "src/basic/string-table.h"
nm_copy_sd_shared "src/basic/string-util.c"
nm_copy_sd_shared "src/basic/string-util.h"
nm_copy_sd_shared "src/basic/strv.c"
nm_copy_sd_shared "src/basic/strv.h"
nm_copy_sd_shared "src/basic/time-util.c"
nm_copy_sd_shared "src/basic/time-util.h"
nm_copy_sd_shared "src/basic/tmpfile-util.c"
nm_copy_sd_shared "src/basic/tmpfile-util.h"
nm_copy_sd_shared "src/basic/umask-util.h"
nm_copy_sd_shared "src/basic/utf8.c"
nm_copy_sd_shared "src/basic/utf8.h"
nm_copy_sd_shared "src/basic/util.c"
nm_copy_sd_shared "src/basic/util.h"
This commit is contained in:
Thomas Haller
2019-02-05 05:30:49 +01:00
parent 19a64c09a9
commit 8372c0e9c0
26 changed files with 274 additions and 182 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
shared/systemd/src/basic/alloc-util.h
View File

@@ -10,20 +10,28 @@
typedef void (*free_func_t)(void *p); typedef void (*free_func_t)(void *p);
/* If for some reason more than 4M are allocated on the stack, let's abort immediately. It's better than
* proceeding and smashing the stack limits. Note that by default RLIMIT_STACK is 8M on Linux. */
#define ALLOCA_MAX (4U*1024U*1024U)
#define new(t, n) ((t*) malloc_multiply(sizeof(t), (n))) #define new(t, n) ((t*) malloc_multiply(sizeof(t), (n)))
#define new0(t, n) ((t*) calloc((n) ?: 1, sizeof(t))) #define new0(t, n) ((t*) calloc((n) ?: 1, sizeof(t)))
#define newa(t, n) \ #define newa(t, n) \
({ \ ({ \
assert(!size_multiply_overflow(sizeof(t), n)); \ size_t _n_ = n; \
(t*) alloca(sizeof(t)*(n)); \ assert(!size_multiply_overflow(sizeof(t), _n_)); \
assert(sizeof(t)*_n_ <= ALLOCA_MAX); \
(t*) alloca(sizeof(t)*_n_); \
}) })
#define newa0(t, n) \ #define newa0(t, n) \
({ \ ({ \
assert(!size_multiply_overflow(sizeof(t), n)); \ size_t _n_ = n; \
(t*) alloca0(sizeof(t)*(n)); \ assert(!size_multiply_overflow(sizeof(t), _n_)); \
assert(sizeof(t)*_n_ <= ALLOCA_MAX); \
(t*) alloca0(sizeof(t)*_n_); \
}) })
#define newdup(t, p, n) ((t*) memdup_multiply(p, sizeof(t), (n))) #define newdup(t, p, n) ((t*) memdup_multiply(p, sizeof(t), (n)))
@@ -51,16 +59,20 @@ void* memdup_suffix0(const void *p, size_t l) _alloc_(2);
#define memdupa(p, l) \ #define memdupa(p, l) \
({ \ ({ \
void *_q_; \ void *_q_; \
_q_ = alloca(l); \ size_t _l_ = l; \
memcpy(_q_, p, l); \ assert(_l_ <= ALLOCA_MAX); \
_q_ = alloca(_l_); \
memcpy(_q_, p, _l_); \
}) })
#define memdupa_suffix0(p, l) \ #define memdupa_suffix0(p, l) \
({ \ ({ \
void *_q_; \ void *_q_; \
_q_ = alloca(l + 1); \ size_t _l_ = l; \
((uint8_t*) _q_)[l] = 0; \ assert(_l_ <= ALLOCA_MAX); \
memcpy(_q_, p, l); \ _q_ = alloca(_l_ + 1); \
((uint8_t*) _q_)[_l_] = 0; \
memcpy(_q_, p, _l_); \
}) })
static inline void freep(void *p) { static inline void freep(void *p) {
@@ -116,6 +128,7 @@ void* greedy_realloc0(void **p, size_t *allocated, size_t need, size_t size);
({ \ ({ \
char *_new_; \ char *_new_; \
size_t _len_ = n; \ size_t _len_ = n; \
assert(_len_ <= ALLOCA_MAX); \
_new_ = alloca(_len_); \ _new_ = alloca(_len_); \
(void *) memset(_new_, 0, _len_); \ (void *) memset(_new_, 0, _len_); \
}) })
@@ -125,16 +138,18 @@ void* greedy_realloc0(void **p, size_t *allocated, size_t need, size_t size);
({ \ ({ \
void *_ptr_; \ void *_ptr_; \
size_t _mask_ = (align) - 1; \ size_t _mask_ = (align) - 1; \
_ptr_ = alloca((size) + _mask_); \ size_t _size_ = size; \
assert(_size_ <= ALLOCA_MAX); \
_ptr_ = alloca(_size_ + _mask_); \
(void*)(((uintptr_t)_ptr_ + _mask_) & ~_mask_); \ (void*)(((uintptr_t)_ptr_ + _mask_) & ~_mask_); \
}) })
#define alloca0_align(size, align) \ #define alloca0_align(size, align) \
({ \ ({ \
void *_new_; \ void *_new_; \
size_t _size_ = (size); \ size_t _xsize_ = (size); \
_new_ = alloca_align(_size_, (align)); \ _new_ = alloca_align(_xsize_, (align)); \
(void*)memset(_new_, 0, _size_); \ (void*)memset(_new_, 0, _xsize_); \
}) })
/* Takes inspiration from Rusts's Option::take() method: reads and returns a pointer, but at the same time resets it to /* Takes inspiration from Rusts's Option::take() method: reads and returns a pointer, but at the same time resets it to

32
shared/systemd/src/basic/env-file.c
View File

@@ -35,7 +35,6 @@ static int parse_env_file_internal(
VALUE, VALUE,
VALUE_ESCAPE, VALUE_ESCAPE,
SINGLE_QUOTE_VALUE, SINGLE_QUOTE_VALUE,
SINGLE_QUOTE_VALUE_ESCAPE,
DOUBLE_QUOTE_VALUE, DOUBLE_QUOTE_VALUE,
DOUBLE_QUOTE_VALUE_ESCAPE, DOUBLE_QUOTE_VALUE_ESCAPE,
COMMENT, COMMENT,
@@ -113,7 +112,7 @@ static int parse_env_file_internal(
} else if (c == '\'') } else if (c == '\'')
state = SINGLE_QUOTE_VALUE; state = SINGLE_QUOTE_VALUE;
else if (c == '\"') else if (c == '"')
state = DOUBLE_QUOTE_VALUE; state = DOUBLE_QUOTE_VALUE;
else if (c == '\\') else if (c == '\\')
state = VALUE_ESCAPE; state = VALUE_ESCAPE;
@@ -186,8 +185,6 @@ static int parse_env_file_internal(
case SINGLE_QUOTE_VALUE: case SINGLE_QUOTE_VALUE:
if (c == '\'') if (c == '\'')
state = PRE_VALUE; state = PRE_VALUE;
else if (c == '\\')
state = SINGLE_QUOTE_VALUE_ESCAPE;
else { else {
if (!GREEDY_REALLOC(value, value_alloc, n_value+2)) if (!GREEDY_REALLOC(value, value_alloc, n_value+2))
return -ENOMEM; return -ENOMEM;
@@ -197,19 +194,8 @@ static int parse_env_file_internal(
break; break;
case SINGLE_QUOTE_VALUE_ESCAPE:
state = SINGLE_QUOTE_VALUE;
if (!strchr(NEWLINE, c)) {
if (!GREEDY_REALLOC(value, value_alloc, n_value+2))
return -ENOMEM;
value[n_value++] = c;
}
break;
case DOUBLE_QUOTE_VALUE: case DOUBLE_QUOTE_VALUE:
if (c == '\"') if (c == '"')
state = PRE_VALUE; state = PRE_VALUE;
else if (c == '\\') else if (c == '\\')
state = DOUBLE_QUOTE_VALUE_ESCAPE; state = DOUBLE_QUOTE_VALUE_ESCAPE;
@@ -225,12 +211,17 @@ static int parse_env_file_internal(
case DOUBLE_QUOTE_VALUE_ESCAPE: case DOUBLE_QUOTE_VALUE_ESCAPE:
state = DOUBLE_QUOTE_VALUE; state = DOUBLE_QUOTE_VALUE;
if (!strchr(NEWLINE, c)) { if (c == '"') {
if (!GREEDY_REALLOC(value, value_alloc, n_value+2)) if (!GREEDY_REALLOC(value, value_alloc, n_value+2))
return -ENOMEM; return -ENOMEM;
value[n_value++] = '"';
} else if (!strchr(NEWLINE, c)) {
if (!GREEDY_REALLOC(value, value_alloc, n_value+3))
return -ENOMEM;
value[n_value++] = '\\';
value[n_value++] = c; value[n_value++] = c;
} }
break; break;
case COMMENT: case COMMENT:
@@ -253,7 +244,6 @@ static int parse_env_file_internal(
VALUE, VALUE,
VALUE_ESCAPE, VALUE_ESCAPE,
SINGLE_QUOTE_VALUE, SINGLE_QUOTE_VALUE,
SINGLE_QUOTE_VALUE_ESCAPE,
DOUBLE_QUOTE_VALUE, DOUBLE_QUOTE_VALUE,
DOUBLE_QUOTE_VALUE_ESCAPE)) { DOUBLE_QUOTE_VALUE_ESCAPE)) {
@@ -527,7 +517,7 @@ static void write_env_var(FILE *f, const char *v) {
fwrite_unlocked(v, 1, p-v, f); fwrite_unlocked(v, 1, p-v, f);
if (string_has_cc(p, NULL) || chars_intersect(p, WHITESPACE SHELL_NEED_QUOTES)) { if (string_has_cc(p, NULL) || chars_intersect(p, WHITESPACE SHELL_NEED_QUOTES)) {
fputc_unlocked('\"', f); fputc_unlocked('"', f);
for (; *p; p++) { for (; *p; p++) {
if (strchr(SHELL_NEED_ESCAPE, *p)) if (strchr(SHELL_NEED_ESCAPE, *p))
@@ -536,7 +526,7 @@ static void write_env_var(FILE *f, const char *v) {
fputc_unlocked(*p, f); fputc_unlocked(*p, f);
} }
fputc_unlocked('\"', f); fputc_unlocked('"', f);
} else } else
fputs_unlocked(p, f); fputs_unlocked(p, f);

2
shared/systemd/src/basic/env-util.c
View File

@@ -339,7 +339,6 @@ char **strv_env_unset(char **l, const char *p) {
} }
char **strv_env_unset_many(char **l, ...) { char **strv_env_unset_many(char **l, ...) {
char **f, **t; char **f, **t;
if (!l) if (!l)
@@ -408,7 +407,6 @@ int strv_env_replace(char ***l, char *p) {
} }
char **strv_env_set(char **x, const char *p) { char **strv_env_set(char **x, const char *p) {
_cleanup_strv_free_ char **ret = NULL; _cleanup_strv_free_ char **ret = NULL;
size_t n, m; size_t n, m;
char **k; char **k;

6
shared/systemd/src/basic/env-util.h
View File

@@ -13,9 +13,9 @@ bool env_value_is_valid(const char *e);
bool env_assignment_is_valid(const char *e); bool env_assignment_is_valid(const char *e);
enum { enum {
REPLACE_ENV_USE_ENVIRONMENT = 1u, REPLACE_ENV_USE_ENVIRONMENT = 1 << 0,
REPLACE_ENV_ALLOW_BRACELESS = 2u, REPLACE_ENV_ALLOW_BRACELESS = 1 << 1,
REPLACE_ENV_ALLOW_EXTENDED = 4u, REPLACE_ENV_ALLOW_EXTENDED = 1 << 2,
}; };
char *replace_env_n(const char *format, size_t n, char **env, unsigned flags); char *replace_env_n(const char *format, size_t n, char **env, unsigned flags);

12
shared/systemd/src/basic/extract-word.h
View File

@@ -4,12 +4,12 @@
#include "macro.h" #include "macro.h"
typedef enum ExtractFlags { typedef enum ExtractFlags {
EXTRACT_RELAX = 1, EXTRACT_RELAX = 1 << 0,
EXTRACT_CUNESCAPE = 2, EXTRACT_CUNESCAPE = 1 << 1,
EXTRACT_CUNESCAPE_RELAX = 4, EXTRACT_CUNESCAPE_RELAX = 1 << 2,
EXTRACT_QUOTES = 8, EXTRACT_QUOTES = 1 << 3,
EXTRACT_DONT_COALESCE_SEPARATORS = 16, EXTRACT_DONT_COALESCE_SEPARATORS = 1 << 4,
EXTRACT_RETAIN_ESCAPE = 32, EXTRACT_RETAIN_ESCAPE = 1 << 5,
} ExtractFlags; } ExtractFlags;
int extract_first_word(const char **p, char **ret, const char *separators, ExtractFlags flags); int extract_first_word(const char **p, char **ret, const char *separators, ExtractFlags flags);

37
shared/systemd/src/basic/fd-util.c
View File

@@ -189,6 +189,27 @@ _pure_ static bool fd_in_set(int fd, const int fdset[], size_t n_fdset) {
return false; return false;
} }
static int get_max_fd(void) {
struct rlimit rl;
rlim_t m;
/* Return the highest possible fd, based RLIMIT_NOFILE, but enforcing FD_SETSIZE-1 as lower boundary
* and INT_MAX as upper boundary. */
if (getrlimit(RLIMIT_NOFILE, &rl) < 0)
return -errno;
m = MAX(rl.rlim_cur, rl.rlim_max);
if (m < FD_SETSIZE) /* Let's always cover at least 1024 fds */
return FD_SETSIZE-1;
if (m == RLIM_INFINITY || m > INT_MAX) /* Saturate on overflow. After all fds are "int", hence can
* never be above INT_MAX */
return INT_MAX;
return (int) (m - 1);
}
int close_all_fds(const int except[], size_t n_except) { int close_all_fds(const int except[], size_t n_except) {
_cleanup_closedir_ DIR *d = NULL; _cleanup_closedir_ DIR *d = NULL;
struct dirent *de; struct dirent *de;
@@ -198,20 +219,14 @@ int close_all_fds(const int except[], size_t n_except) {
d = opendir("/proc/self/fd"); d = opendir("/proc/self/fd");
if (!d) { if (!d) {
struct rlimit rl;
int fd, max_fd; int fd, max_fd;
/* When /proc isn't available (for example in chroots) the fallback is brute forcing through the fd /* When /proc isn't available (for example in chroots) the fallback is brute forcing through
* table */ * the fd table */
assert_se(getrlimit(RLIMIT_NOFILE, &rl) >= 0); max_fd = get_max_fd();
if (max_fd < 0)
if (rl.rlim_max == 0) return max_fd;
return -EINVAL;
/* Let's take special care if the resource limit is set to unlimited, or actually larger than the range
* of 'int'. Let's avoid implicit overflows. */
max_fd = (rl.rlim_max == RLIM_INFINITY || rl.rlim_max > INT_MAX) ? INT_MAX : (int) (rl.rlim_max - 1);
for (fd = 3; fd >= 0; fd = fd < max_fd ? fd + 1 : -1) { for (fd = 3; fd >= 0; fd = fd < max_fd ? fd + 1 : -1) {
int q; int q;

2
shared/systemd/src/basic/hashmap.c
View File

@@ -345,7 +345,7 @@ static unsigned base_bucket_hash(HashmapBase *h, const void *p) {
} }
#define bucket_hash(h, p) base_bucket_hash(HASHMAP_BASE(h), p) #define bucket_hash(h, p) base_bucket_hash(HASHMAP_BASE(h), p)
static inline void base_set_dirty(HashmapBase *h) { static void base_set_dirty(HashmapBase *h) {
h->dirty = true; h->dirty = true;
} }
#define hashmap_set_dirty(h) base_set_dirty(HASHMAP_BASE(h)) #define hashmap_set_dirty(h) base_set_dirty(HASHMAP_BASE(h))

1
shared/systemd/src/basic/hashmap.h
View File

@@ -326,7 +326,6 @@ static inline void *ordered_hashmap_first_key_and_value(OrderedHashmap *h, void
return internal_hashmap_first_key_and_value(HASHMAP_BASE(h), false, ret); return internal_hashmap_first_key_and_value(HASHMAP_BASE(h), false, ret);
} }
static inline void *hashmap_steal_first(Hashmap *h) { static inline void *hashmap_steal_first(Hashmap *h) {
return internal_hashmap_first_key_and_value(HASHMAP_BASE(h), true, NULL); return internal_hashmap_first_key_and_value(HASHMAP_BASE(h), true, NULL);
} }

37
shared/systemd/src/basic/in-addr-util.c
View File

@@ -495,9 +495,8 @@ int in_addr_parse_prefixlen(int family, const char *p, unsigned char *ret) {
return 0; return 0;
} }
int in_addr_prefix_from_string_internal( int in_addr_prefix_from_string(
const char *p, const char *p,
bool use_default_prefixlen,
int family, int family,
union in_addr_union *ret_prefix, union in_addr_union *ret_prefix,
unsigned char *ret_prefixlen) { unsigned char *ret_prefixlen) {
@@ -531,13 +530,6 @@ int in_addr_prefix_from_string_internal(
r = in_addr_parse_prefixlen(family, e+1, &k); r = in_addr_parse_prefixlen(family, e+1, &k);
if (r < 0) if (r < 0)
return r; return r;
} else if (use_default_prefixlen) {
if (family == AF_INET) {
r = in4_addr_default_prefixlen(&buffer.in, &k);
if (r < 0)
return r;
} else
k = 0;
} else } else
k = FAMILY_ADDRESS_SIZE(family) * 8; k = FAMILY_ADDRESS_SIZE(family) * 8;
@@ -551,7 +543,7 @@ int in_addr_prefix_from_string_internal(
int in_addr_prefix_from_string_auto_internal( int in_addr_prefix_from_string_auto_internal(
const char *p, const char *p,
bool use_default_prefixlen, InAddrPrefixLenMode mode,
int *ret_family, int *ret_family,
union in_addr_union *ret_prefix, union in_addr_union *ret_prefix,
unsigned char *ret_prefixlen) { unsigned char *ret_prefixlen) {
@@ -582,15 +574,24 @@ int in_addr_prefix_from_string_auto_internal(
r = in_addr_parse_prefixlen(family, e+1, &k); r = in_addr_parse_prefixlen(family, e+1, &k);
if (r < 0) if (r < 0)
return r; return r;
} else if (use_default_prefixlen) {
if (family == AF_INET) {
r = in4_addr_default_prefixlen(&buffer.in, &k);
if (r < 0)
return r;
} else
k = 0;
} else } else
k = FAMILY_ADDRESS_SIZE(family) * 8; switch (mode) {
case PREFIXLEN_FULL:
k = FAMILY_ADDRESS_SIZE(family) * 8;
break;
case PREFIXLEN_REFUSE:
return -ENOANO; /* To distinguish this error from others. */
case PREFIXLEN_LEGACY:
if (family == AF_INET) {
r = in4_addr_default_prefixlen(&buffer.in, &k);
if (r < 0)
return r;
} else
k = 0;
break;
default:
assert_not_reached("Invalid prefixlen mode");
}
if (ret_family) if (ret_family)
*ret_family = family; *ret_family = family;

22
shared/systemd/src/basic/in-addr-util.h
View File

@@ -45,19 +45,17 @@ int in4_addr_default_subnet_mask(const struct in_addr *addr, struct in_addr *mas
int in_addr_mask(int family, union in_addr_union *addr, unsigned char prefixlen); int in_addr_mask(int family, union in_addr_union *addr, unsigned char prefixlen);
int in_addr_prefix_covers(int family, const union in_addr_union *prefix, unsigned char prefixlen, const union in_addr_union *address); int in_addr_prefix_covers(int family, const union in_addr_union *prefix, unsigned char prefixlen, const union in_addr_union *address);
int in_addr_parse_prefixlen(int family, const char *p, unsigned char *ret); int in_addr_parse_prefixlen(int family, const char *p, unsigned char *ret);
int in_addr_prefix_from_string_internal(const char *p, bool use_default_prefixlen, int family, union in_addr_union *ret_prefix, unsigned char *ret_prefixlen); int in_addr_prefix_from_string(const char *p, int family, union in_addr_union *ret_prefix, unsigned char *ret_prefixlen);
int in_addr_prefix_from_string_auto_internal(const char *p, bool use_default_prefixlen, int *ret_family, union in_addr_union *ret_prefix, unsigned char *ret_prefixlen);
static inline int in_addr_prefix_from_string(const char *p, int family, union in_addr_union *ret_prefix, unsigned char *ret_prefixlen) { typedef enum InAddrPrefixLenMode {
return in_addr_prefix_from_string_internal(p, false, family, ret_prefix, ret_prefixlen); PREFIXLEN_FULL, /* Default to prefixlen of address size, 32 for IPv4 or 128 for IPv6, if not specified. */
} PREFIXLEN_REFUSE, /* Fail with -ENOANO if prefixlen is not specified. */
PREFIXLEN_LEGACY, /* Default to legacy default prefixlen calculation from address if not specified. */
} InAddrPrefixLenMode;
int in_addr_prefix_from_string_auto_internal(const char *p, InAddrPrefixLenMode mode, int *ret_family, union in_addr_union *ret_prefix, unsigned char *ret_prefixlen);
static inline int in_addr_prefix_from_string_auto(const char *p, int *ret_family, union in_addr_union *ret_prefix, unsigned char *ret_prefixlen) { static inline int in_addr_prefix_from_string_auto(const char *p, int *ret_family, union in_addr_union *ret_prefix, unsigned char *ret_prefixlen) {
return in_addr_prefix_from_string_auto_internal(p, false, ret_family, ret_prefix, ret_prefixlen); return in_addr_prefix_from_string_auto_internal(p, PREFIXLEN_FULL, ret_family, ret_prefix, ret_prefixlen);
}
static inline int in_addr_default_prefix_from_string(const char *p, int family, union in_addr_union *ret_prefix, unsigned char *ret_prefixlen) {
return in_addr_prefix_from_string_internal(p, true, family, ret_prefix, ret_prefixlen);
}
static inline int in_addr_default_prefix_from_string_auto(const char *p, int *ret_family, union in_addr_union *ret_prefix, unsigned char *ret_prefixlen) {
return in_addr_prefix_from_string_auto_internal(p, true, ret_family, ret_prefix, ret_prefixlen);
} }
static inline size_t FAMILY_ADDRESS_SIZE(int family) { static inline size_t FAMILY_ADDRESS_SIZE(int family) {

10
shared/systemd/src/basic/io-util.c
View File

@@ -8,6 +8,7 @@
#include <unistd.h> #include <unistd.h>
#include "io-util.h" #include "io-util.h"
#include "string-util.h"
#include "time-util.h" #include "time-util.h"
int flush_fd(int fd) { int flush_fd(int fd) {
@@ -252,3 +253,12 @@ ssize_t sparse_write(int fd, const void *p, size_t sz, size_t run_length) {
return q - (const uint8_t*) p; return q - (const uint8_t*) p;
} }
char* set_iovec_string_field(struct iovec *iovec, size_t *n_iovec, const char *field, const char *value) {
char *x;
x = strappend(field, value);
if (x)
iovec[(*n_iovec)++] = IOVEC_MAKE_STRING(x);
return x;
}

2
shared/systemd/src/basic/io-util.h
View File

@@ -71,3 +71,5 @@ static inline bool FILE_SIZE_VALID_OR_INFINITY(uint64_t l) {
#define IOVEC_MAKE(base, len) (struct iovec) IOVEC_INIT(base, len) #define IOVEC_MAKE(base, len) (struct iovec) IOVEC_INIT(base, len)
#define IOVEC_INIT_STRING(string) IOVEC_INIT((char*) string, strlen(string)) #define IOVEC_INIT_STRING(string) IOVEC_INIT((char*) string, strlen(string))
#define IOVEC_MAKE_STRING(string) (struct iovec) IOVEC_INIT_STRING(string) #define IOVEC_MAKE_STRING(string) (struct iovec) IOVEC_INIT_STRING(string)
char* set_iovec_string_field(struct iovec *iovec, size_t *n_iovec, const char *field, const char *value);

60
shared/systemd/src/basic/missing_fcntl.h Normal file
View File

@@ -0,0 +1,60 @@
/* SPDX-License-Identifier: LGPL-2.1+ */
#pragma once
#include <fcntl.h>
#ifndef F_LINUX_SPECIFIC_BASE
#define F_LINUX_SPECIFIC_BASE 1024
#endif
#ifndef F_SETPIPE_SZ
#define F_SETPIPE_SZ (F_LINUX_SPECIFIC_BASE + 7)
#endif
#ifndef F_GETPIPE_SZ
#define F_GETPIPE_SZ (F_LINUX_SPECIFIC_BASE + 8)
#endif
#ifndef F_ADD_SEALS
#define F_ADD_SEALS (F_LINUX_SPECIFIC_BASE + 9)
#define F_GET_SEALS (F_LINUX_SPECIFIC_BASE + 10)
#define F_SEAL_SEAL 0x0001 /* prevent further seals from being set */
#define F_SEAL_SHRINK 0x0002 /* prevent file from shrinking */
#define F_SEAL_GROW 0x0004 /* prevent file from growing */
#define F_SEAL_WRITE 0x0008 /* prevent writes */
#endif
#ifndef F_OFD_GETLK
#define F_OFD_GETLK 36
#define F_OFD_SETLK 37
#define F_OFD_SETLKW 38
#endif
#ifndef MAX_HANDLE_SZ
#define MAX_HANDLE_SZ 128
#endif
/* The precise definition of __O_TMPFILE is arch specific; use the
* values defined by the kernel (note: some are hexa, some are octal,
* duplicated as-is from the kernel definitions):
* - alpha, parisc, sparc: each has a specific value;
* - others: they use the "generic" value.
*/
#ifndef __O_TMPFILE
#if defined(__alpha__)
#define __O_TMPFILE 0100000000
#elif defined(__parisc__) || defined(__hppa__)
#define __O_TMPFILE 0400000000
#elif defined(__sparc__) || defined(__sparc64__)
#define __O_TMPFILE 0x2000000
#else
#define __O_TMPFILE 020000000
#endif
#endif
/* a horrid kludge trying to make sure that this will fail on old kernels */
#ifndef O_TMPFILE
#define O_TMPFILE (__O_TMPFILE | O_DIRECTORY)
#endif

2
shared/systemd/src/basic/path-util.h
View File

@@ -131,7 +131,7 @@ char *prefix_root(const char *root, const char *path);
_ret = _path; \ _ret = _path; \
else { \ else { \
_l = strlen(_root) + 1 + strlen(_path) + 1; \ _l = strlen(_root) + 1 + strlen(_path) + 1; \
_n = alloca(_l); \ _n = newa(char, _l); \
_p = stpcpy(_n, _root); \ _p = stpcpy(_n, _root); \
while (_p > _n && _p[-1] == '/') \ while (_p > _n && _p[-1] == '/') \
_p--; \ _p--; \

7
shared/systemd/src/basic/prioq.c
View File

@@ -259,15 +259,14 @@ int prioq_reshuffle(Prioq *q, void *data, unsigned *idx) {
return 1; return 1;
} }
void *prioq_peek(Prioq *q) { void *prioq_peek_by_index(Prioq *q, unsigned idx) {
if (!q) if (!q)
return NULL; return NULL;
if (q->n_items <= 0) if (idx >= q->n_items)
return NULL; return NULL;
return q->items[0].data; return q->items[idx].data;
} }
void *prioq_pop(Prioq *q) { void *prioq_pop(Prioq *q) {

8
shared/systemd/src/basic/prioq.h
View File

@@ -19,8 +19,14 @@ int prioq_put(Prioq *q, void *data, unsigned *idx);
int prioq_remove(Prioq *q, void *data, unsigned *idx); int prioq_remove(Prioq *q, void *data, unsigned *idx);
int prioq_reshuffle(Prioq *q, void *data, unsigned *idx); int prioq_reshuffle(Prioq *q, void *data, unsigned *idx);
void *prioq_peek(Prioq *q) _pure_; void *prioq_peek_by_index(Prioq *q, unsigned idx) _pure_;
static inline void *prioq_peek(Prioq *q) {
return prioq_peek_by_index(q, 0);
}
void *prioq_pop(Prioq *q); void *prioq_pop(Prioq *q);
#define PRIOQ_FOREACH_ITEM(q, p) \
for (unsigned _i = 0; (p = prioq_peek_by_index(q, _i)); _i++)
unsigned prioq_size(Prioq *q) _pure_; unsigned prioq_size(Prioq *q) _pure_;
bool prioq_isempty(Prioq *q) _pure_; bool prioq_isempty(Prioq *q) _pure_;

91
shared/systemd/src/basic/process-util.c
View File

@@ -102,7 +102,8 @@ int get_process_comm(pid_t pid, char **ret) {
int get_process_cmdline(pid_t pid, size_t max_length, bool comm_fallback, char **line) { int get_process_cmdline(pid_t pid, size_t max_length, bool comm_fallback, char **line) {
_cleanup_fclose_ FILE *f = NULL; _cleanup_fclose_ FILE *f = NULL;
bool space = false; bool space = false;
char *k, *ans = NULL; char *k;
_cleanup_free_ char *ans = NULL;
const char *p; const char *p;
int c; int c;
@@ -129,6 +130,13 @@ int get_process_cmdline(pid_t pid, size_t max_length, bool comm_fallback, char *
(void) __fsetlocking(f, FSETLOCKING_BYCALLER); (void) __fsetlocking(f, FSETLOCKING_BYCALLER);
if (max_length == 0) {
/* This is supposed to be a safety guard against runaway command lines. */
long l = sysconf(_SC_ARG_MAX);
assert(l > 0);
max_length = l;
}
if (max_length == 1) { if (max_length == 1) {
/* If there's only room for one byte, return the empty string */ /* If there's only room for one byte, return the empty string */
@@ -136,35 +144,9 @@ int get_process_cmdline(pid_t pid, size_t max_length, bool comm_fallback, char *
if (!ans) if (!ans)
return -ENOMEM; return -ENOMEM;
*line = ans; *line = TAKE_PTR(ans);
return 0; return 0;
} else if (max_length == 0) {
size_t len = 0, allocated = 0;
while ((c = getc(f)) != EOF) {
if (!GREEDY_REALLOC(ans, allocated, len+3)) {
free(ans);
return -ENOMEM;
}
if (isprint(c)) {
if (space) {
ans[len++] = ' ';
space = false;
}
ans[len++] = c;
} else if (len > 0)
space = true;
}
if (len > 0)
ans[len] = '\0';
else
ans = mfree(ans);
} else { } else {
bool dotdotdot = false; bool dotdotdot = false;
size_t left; size_t left;
@@ -227,7 +209,7 @@ int get_process_cmdline(pid_t pid, size_t max_length, bool comm_fallback, char *
_cleanup_free_ char *t = NULL; _cleanup_free_ char *t = NULL;
int h; int h;
free(ans); ans = mfree(ans);
if (!comm_fallback) if (!comm_fallback)
return -ENOENT; return -ENOENT;
@@ -236,37 +218,42 @@ int get_process_cmdline(pid_t pid, size_t max_length, bool comm_fallback, char *
if (h < 0) if (h < 0)
return h; return h;
if (max_length == 0) size_t l = strlen(t);
if (l + 3 <= max_length) {
ans = strjoin("[", t, "]"); ans = strjoin("[", t, "]");
else { if (!ans)
size_t l; return -ENOMEM;
l = strlen(t); } else if (max_length <= 6) {
ans = new(char, max_length);
if (!ans)
return -ENOMEM;
if (l + 3 <= max_length) memcpy(ans, "[...]", max_length-1);
ans = strjoin("[", t, "]"); ans[max_length-1] = 0;
else if (max_length <= 6) { } else {
t[max_length - 6] = 0;
ans = new(char, max_length); /* Chop off final spaces */
if (!ans) delete_trailing_chars(t, WHITESPACE);
return -ENOMEM;
memcpy(ans, "[...]", max_length-1); ans = strjoin("[", t, "...]");
ans[max_length-1] = 0; if (!ans)
} else { return -ENOMEM;
t[max_length - 6] = 0;
/* Chop off final spaces */
delete_trailing_chars(t, WHITESPACE);
ans = strjoin("[", t, "...]");
}
} }
if (!ans)
return -ENOMEM; *line = TAKE_PTR(ans);
return 0;
} }
*line = ans; k = realloc(ans, strlen(ans) + 1);
if (!k)
return -ENOMEM;
ans = NULL;
*line = k;
return 0; return 0;
} }

4
shared/systemd/src/basic/process-util.h
View File

@@ -24,8 +24,8 @@
if (_pid_ == 0) { \ if (_pid_ == 0) { \
_r_ = ("/proc/self/" field); \ _r_ = ("/proc/self/" field); \
} else { \ } else { \
_r_ = alloca(STRLEN("/proc/") + DECIMAL_STR_MAX(pid_t) + 1 + sizeof(field)); \ _r_ = newa(char, STRLEN("/proc/") + DECIMAL_STR_MAX(pid_t) + 1 + sizeof(field)); \
sprintf((char*) _r_, "/proc/"PID_FMT"/" field, _pid_); \ sprintf((char*) _r_, "/proc/"PID_FMT"/" field, _pid_); \
} \ } \
_r_; \ _r_; \
}) })

16
shared/systemd/src/basic/stat-util.c
View File

@@ -67,13 +67,22 @@ int is_device_node(const char *path) {
return !!(S_ISBLK(info.st_mode) || S_ISCHR(info.st_mode)); return !!(S_ISBLK(info.st_mode) || S_ISCHR(info.st_mode));
} }
int dir_is_empty(const char *path) { int dir_is_empty_at(int dir_fd, const char *path) {
_cleanup_closedir_ DIR *d; _cleanup_close_ int fd = -1;
_cleanup_closedir_ DIR *d = NULL;
struct dirent *de; struct dirent *de;
d = opendir(path); if (path)
fd = openat(dir_fd, path, O_RDONLY|O_DIRECTORY|O_CLOEXEC);
else
fd = fcntl(fd, F_DUPFD_CLOEXEC, 3);
if (fd < 0)
return -errno;
d = fdopendir(fd);
if (!d) if (!d)
return -errno; return -errno;
fd = -1;
FOREACH_DIRENT(de, d, return -errno) FOREACH_DIRENT(de, d, return -errno)
return 0; return 0;
@@ -338,7 +347,6 @@ int device_path_make_major_minor(mode_t mode, dev_t devno, char **ret) {
return -ENOMEM; return -ENOMEM;
return 0; return 0;
} }
int device_path_make_canonical(mode_t mode, dev_t devno, char **ret) { int device_path_make_canonical(mode_t mode, dev_t devno, char **ret) {

5
shared/systemd/src/basic/stat-util.h
View File

@@ -15,7 +15,10 @@ int is_dir(const char *path, bool follow);
int is_dir_fd(int fd); int is_dir_fd(int fd);
int is_device_node(const char *path); int is_device_node(const char *path);
int dir_is_empty(const char *path); int dir_is_empty_at(int dir_fd, const char *path);
static inline int dir_is_empty(const char *path) {
return dir_is_empty_at(AT_FDCWD, path);
}
static inline int dir_is_populated(const char *path) { static inline int dir_is_populated(const char *path) {
int r; int r;

3
shared/systemd/src/basic/string-util.h
View File

@@ -6,6 +6,7 @@
#include <stddef.h> #include <stddef.h>
#include <string.h> #include <string.h>
#include "alloc-util.h"
#include "macro.h" #include "macro.h"
/* What is interpreted as whitespace? */ /* What is interpreted as whitespace? */
@@ -111,7 +112,7 @@ char *strjoin_real(const char *x, ...) _sentinel_;
size_t _i_; \ size_t _i_; \
for (_i_ = 0; _i_ < ELEMENTSOF(_appendees_) && _appendees_[_i_]; _i_++) \ for (_i_ = 0; _i_ < ELEMENTSOF(_appendees_) && _appendees_[_i_]; _i_++) \
_len_ += strlen(_appendees_[_i_]); \ _len_ += strlen(_appendees_[_i_]); \
_p_ = _d_ = alloca(_len_ + 1); \ _p_ = _d_ = newa(char, _len_ + 1); \
for (_i_ = 0; _i_ < ELEMENTSOF(_appendees_) && _appendees_[_i_]; _i_++) \ for (_i_ = 0; _i_ < ELEMENTSOF(_appendees_) && _appendees_[_i_]; _i_++) \
_p_ = stpcpy(_p_, _appendees_[_i_]); \ _p_ = stpcpy(_p_, _appendees_[_i_]); \
*_p_ = 0; \ *_p_ = 0; \

15
shared/systemd/src/basic/strv.h
View File

@@ -156,17 +156,10 @@ void strv_print(char **l);
_found; \ _found; \
}) })
#define FOREACH_STRING(x, ...) \ #define FOREACH_STRING(x, y, ...) \
for (char **_l = ({ \ for (char **_l = STRV_MAKE(({ x = y; }), ##__VA_ARGS__); \
char **_ll = STRV_MAKE(__VA_ARGS__); \ x; \
x = _ll ? _ll[0] : NULL; \ x = *(++_l))
_ll; \
}); \
_l && *_l; \
x = ({ \
_l ++; \
_l[0]; \
}))
char **strv_reverse(char **l); char **strv_reverse(char **l);
char **strv_shell_escape(char **l, const char *bad); char **strv_shell_escape(char **l, const char *bad);

1
shared/systemd/src/basic/tmpfile-util.c
View File

@@ -8,6 +8,7 @@
#include "hexdecoct.h" #include "hexdecoct.h"
#include "macro.h" #include "macro.h"
#include "memfd-util.h" #include "memfd-util.h"
#include "missing_fcntl.h"
#include "missing_syscall.h" #include "missing_syscall.h"
#include "path-util.h" #include "path-util.h"
#include "process-util.h" #include "process-util.h"

7
src/systemd/src/libsystemd-network/dhcp-identifier.c
View File

@@ -11,6 +11,7 @@
#include "network-internal.h" #include "network-internal.h"
#include "siphash24.h" #include "siphash24.h"
#include "sparse-endian.h" #include "sparse-endian.h"
#include "stdio-util.h"
#include "virt.h" #include "virt.h"
#define SYSTEMD_PEN 43793 #define SYSTEMD_PEN 43793
@@ -169,10 +170,10 @@ int dhcp_identifier_set_iaid(
if (detect_container() <= 0) { if (detect_container() <= 0) {
/* not in a container, udev will be around */ /* not in a container, udev will be around */
char ifindex_str[2 + DECIMAL_STR_MAX(int)]; char ifindex_str[1 + DECIMAL_STR_MAX(int)];
int r; int r;
sprintf(ifindex_str, "n%d", ifindex); xsprintf(ifindex_str, "n%d", ifindex);
if (sd_device_new_from_device_id(&device, ifindex_str) >= 0) { if (sd_device_new_from_device_id(&device, ifindex_str) >= 0) {
r = sd_device_get_is_initialized(device); r = sd_device_get_is_initialized(device);
if (r < 0) if (r < 0)
@@ -195,7 +196,7 @@ int dhcp_identifier_set_iaid(
if (legacy_unstable_byteorder) if (legacy_unstable_byteorder)
/* for historical reasons (a bug), the bits were swapped and thus /* for historical reasons (a bug), the bits were swapped and thus
* the result was endianness dependant. Preserve that behavior. */ * the result was endianness dependent. Preserve that behavior. */
id32 = __bswap_32(id32); id32 = __bswap_32(id32);
else else
/* the fixed behavior returns a stable byte order. Since LE is expected /* the fixed behavior returns a stable byte order. Since LE is expected

2
src/systemd/src/libsystemd-network/network-internal.c
View File

@@ -52,7 +52,7 @@ int net_get_unique_predictable_data(sd_device *device, uint64_t *result) {
l = strlen(name); l = strlen(name);
sz = sizeof(sd_id128_t) + l; sz = sizeof(sd_id128_t) + l;
v = alloca(sz); v = newa(uint8_t, sz);
/* fetch some persistent data unique to this machine */ /* fetch some persistent data unique to this machine */
r = sd_id128_get_machine((sd_id128_t*) v); r = sd_id128_get_machine((sd_id128_t*) v);

23
src/systemd/src/libsystemd/sd-event/sd-event.c
View File

@@ -470,6 +470,17 @@ static struct clock_data* event_get_clock_data(sd_event *e, EventSourceType t) {
} }
} }
static void event_free_signal_data(sd_event *e, struct signal_data *d) {
assert(e);
if (!d)
return;
hashmap_remove(e->signal_data, &d->priority);
safe_close(d->fd);
free(d);
}
static int event_make_signal_data( static int event_make_signal_data(
sd_event *e, sd_event *e,
int sig, int sig,
@@ -559,11 +570,8 @@ static int event_make_signal_data(
return 0; return 0;
fail: fail:
if (added) { if (added)
d->fd = safe_close(d->fd); event_free_signal_data(e, d);
hashmap_remove(e->signal_data, &d->priority);
free(d);
}
return r; return r;
} }
@@ -582,11 +590,8 @@ static void event_unmask_signal_data(sd_event *e, struct signal_data *d, int sig
assert_se(sigdelset(&d->sigset, sig) >= 0); assert_se(sigdelset(&d->sigset, sig) >= 0);
if (sigisemptyset(&d->sigset)) { if (sigisemptyset(&d->sigset)) {
/* If all the mask is all-zero we can get rid of the structure */ /* If all the mask is all-zero we can get rid of the structure */
hashmap_remove(e->signal_data, &d->priority); event_free_signal_data(e, d);
safe_close(d->fd);
free(d);
return; return;
} }