Bug Summary

File:build-scan/../src/journal/catalog.c
Warning:line 661, column 1
Potential leak of memory pointed to by 'subject'

Annotated Source Code

Press '?' to see keyboard shortcuts

clang -cc1 -cc1 -triple x86_64-unknown-linux-gnu -analyze -disable-free -disable-llvm-verifier -discard-value-names -main-file-name catalog.c -analyzer-store=region -analyzer-opt-analyze-nested-blocks -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -setup-static-analyzer -mrelocation-model pic -pic-level 2 -fhalf-no-semantic-interposition -mframe-pointer=all -relaxed-aliasing -menable-no-infs -menable-no-nans -menable-unsafe-fp-math -fno-signed-zeros -mreassociate -freciprocal-math -fdenormal-fp-math=preserve-sign,preserve-sign -ffp-contract=fast -fno-rounding-math -ffast-math -ffinite-math-only -mconstructor-aliases -munwind-tables -target-cpu x86-64 -tune-cpu generic -fno-split-dwarf-inlining -debugger-tuning=gdb -resource-dir /usr/lib64/clang/12.0.0 -include config.h -I src/journal/libjournal-client.a.p -I src/journal -I ../src/journal -I src/basic -I ../src/basic -I src/shared -I ../src/shared -I src/systemd -I ../src/systemd -I src/journal-remote -I ../src/journal-remote -I src/nspawn -I ../src/nspawn -I src/resolve -I ../src/resolve -I src/timesync -I ../src/timesync -I ../src/time-wait-sync -I src/login -I ../src/login -I src/udev -I ../src/udev -I src/libudev -I ../src/libudev -I src/core -I ../src/core -I ../src/libsystemd/sd-bus -I ../src/libsystemd/sd-device -I ../src/libsystemd/sd-hwdb -I ../src/libsystemd/sd-id128 -I ../src/libsystemd/sd-netlink -I ../src/libsystemd/sd-network -I src/libsystemd-network -I ../src/libsystemd-network -I . -I .. -D _FILE_OFFSET_BITS=64 -internal-isystem /usr/local/include -internal-isystem /usr/lib64/clang/12.0.0/include -internal-externc-isystem /include -internal-externc-isystem /usr/include -Wwrite-strings -Wno-unused-parameter -Wno-missing-field-initializers -Wno-unused-result -Wno-format-signedness -Wno-error=nonnull -std=gnu99 -fconst-strings -fdebug-compilation-dir /home/mrc0mmand/repos/@redhat-plumbers/systemd-rhel8/build-scan -ferror-limit 19 -fvisibility default -stack-protector 2 -fgnuc-version=4.2.1 -fcolor-diagnostics -analyzer-output=html -faddrsig -o /tmp/scan-build-2021-07-16-221226-1465241-1 -x c ../src/journal/catalog.c
1/* SPDX-License-Identifier: LGPL-2.1+ */
2
3#include <errno(*__errno_location ()).h>
4#include <fcntl.h>
5#include <locale.h>
6#include <stdio.h>
7#include <string.h>
8#include <sys/mman.h>
9#include <unistd.h>
10
11#include "sd-id128.h"
12
13#include "alloc-util.h"
14#include "catalog.h"
15#include "conf-files.h"
16#include "fd-util.h"
17#include "fileio.h"
18#include "hashmap.h"
19#include "log.h"
20#include "mkdir.h"
21#include "path-util.h"
22#include "siphash24.h"
23#include "sparse-endian.h"
24#include "strbuf.h"
25#include "string-util.h"
26#include "strv.h"
27#include "util.h"
28
29const char * const catalog_file_dirs[] = {
30 "/usr/local/lib/systemd/catalog/",
31 "/usr/lib/systemd/catalog/",
32 NULL((void*)0)
33};
34
35#define CATALOG_SIGNATURE(uint8_t[]) { 'R', 'H', 'H', 'H', 'K', 'S', 'L', 'P' } (uint8_t[]) { 'R', 'H', 'H', 'H', 'K', 'S', 'L', 'P' }
36
37typedef struct CatalogHeader {
38 uint8_t signature[8]; /* "RHHHKSLP" */
39 le32_t compatible_flags;
40 le32_t incompatible_flags;
41 le64_t header_size;
42 le64_t n_items;
43 le64_t catalog_item_size;
44} CatalogHeader;
45
46typedef struct CatalogItem {
47 sd_id128_t id;
48 char language[32];
49 le64_t offset;
50} CatalogItem;
51
52static void catalog_hash_func(const void *p, struct siphash *state) {
53 const CatalogItem *i = p;
54
55 siphash24_compress(&i->id, sizeof(i->id), state);
56 siphash24_compress(i->language, strlen(i->language), state);
57}
58
59static int catalog_compare_func(const void *a, const void *b) {
60 const CatalogItem *i = a, *j = b;
61 unsigned k;
62
63 for (k = 0; k < ELEMENTSOF(j->id.bytes)__extension__ (__builtin_choose_expr( !__builtin_types_compatible_p
(typeof(j->id.bytes), typeof(&*(j->id.bytes))), sizeof
(j->id.bytes)/sizeof((j->id.bytes)[0]), ((void)0))); k++) {
64 if (i->id.bytes[k] < j->id.bytes[k])
65 return -1;
66 if (i->id.bytes[k] > j->id.bytes[k])
67 return 1;
68 }
69
70 return strcmp(i->language, j->language);
71}
72
73const struct hash_ops catalog_hash_ops = {
74 .hash = catalog_hash_func,
75 .compare = catalog_compare_func
76};
77
78static bool_Bool next_header(const char **s) {
79 const char *e;
80
81 e = strchr(*s, '\n');
82
83 /* Unexpected end */
84 if (!e)
85 return false0;
86
87 /* End of headers */
88 if (e == *s)
89 return false0;
90
91 *s = e + 1;
92 return true1;
93}
94
95static const char *skip_header(const char *s) {
96 while (next_header(&s))
97 ;
98 return s;
99}
100
101static char *combine_entries(const char *one, const char *two) {
102 const char *b1, *b2;
103 size_t l1, l2, n;
104 char *dest, *p;
105
106 /* Find split point of headers to body */
107 b1 = skip_header(one);
108 b2 = skip_header(two);
109
110 l1 = strlen(one);
111 l2 = strlen(two);
112 dest = new(char, l1 + l2 + 1)((char*) malloc_multiply(sizeof(char), (l1 + l2 + 1)));
113 if (!dest) {
114 log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 114, __func__);
115 return NULL((void*)0);
116 }
117
118 p = dest;
119
120 /* Headers from @one */
121 n = b1 - one;
122 p = mempcpy(p, one, n);
123
124 /* Headers from @two, these will only be found if not present above */
125 n = b2 - two;
126 p = mempcpy(p, two, n);
127
128 /* Body from @one */
129 n = l1 - (b1 - one);
130 if (n > 0) {
131 memcpy(p, b1, n);
132 p += n;
133
134 /* Body from @two */
135 } else {
136 n = l2 - (b2 - two);
137 memcpy(p, b2, n);
138 p += n;
139 }
140
141 assert(p - dest <= (ptrdiff_t)(l1 + l2))do { if ((__builtin_expect(!!(!(p - dest <= (ptrdiff_t)(l1
+ l2))),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("p - dest <= (ptrdiff_t)(l1 + l2)"
), "../src/journal/catalog.c", 141, __PRETTY_FUNCTION__); } while
(0);
142 p[0] = '\0';
143 return dest;
144}
145
146static int finish_item(
147 Hashmap *h,
148 sd_id128_t id,
149 const char *language,
150 char *payload, size_t payload_size) {
151
152 _cleanup_free___attribute__((cleanup(freep))) CatalogItem *i = NULL((void*)0);
153 _cleanup_free___attribute__((cleanup(freep))) char *prev = NULL((void*)0), *combined = NULL((void*)0);
154
155 assert(h)do { if ((__builtin_expect(!!(!(h)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("h"), "../src/journal/catalog.c", 155, __PRETTY_FUNCTION__
); } while (0);
156 assert(payload)do { if ((__builtin_expect(!!(!(payload)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("payload"), "../src/journal/catalog.c", 156
, __PRETTY_FUNCTION__); } while (0);
157 assert(payload_size > 0)do { if ((__builtin_expect(!!(!(payload_size > 0)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("payload_size > 0"), "../src/journal/catalog.c"
, 157, __PRETTY_FUNCTION__); } while (0);
158
159 i = new0(CatalogItem, 1)((CatalogItem*) calloc((1), sizeof(CatalogItem)));
160 if (!i)
161 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 161, __func__);
162
163 i->id = id;
164 if (language) {
165 assert(strlen(language) > 1 && strlen(language) < 32)do { if ((__builtin_expect(!!(!(strlen(language) > 1 &&
strlen(language) < 32)),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD
, ("strlen(language) > 1 && strlen(language) < 32"
), "../src/journal/catalog.c", 165, __PRETTY_FUNCTION__); } while
(0);
166 strcpy(i->language, language);
167 }
168
169 prev = hashmap_get(h, i);
170 if (prev) {
171 /* Already have such an item, combine them */
172 combined = combine_entries(payload, prev);
173 if (!combined)
174 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 174, __func__);
175
176 if (hashmap_update(h, i, combined) < 0)
177 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 177, __func__);
178 combined = NULL((void*)0);
179 } else {
180 /* A new item */
181 combined = memdup(payload, payload_size + 1);
182 if (!combined)
183 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 183, __func__);
184
185 if (hashmap_put(h, i, combined) < 0)
186 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 186, __func__);
187 i = NULL((void*)0);
188 combined = NULL((void*)0);
189 }
190
191 return 0;
192}
193
194int catalog_file_lang(const char* filename, char **lang) {
195 char *beg, *end, *_lang;
196
197 end = endswith(filename, ".catalog");
198 if (!end)
199 return 0;
200
201 beg = end - 1;
202 while (beg > filename && !IN_SET(*beg, '.', '/')({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){'.', '/'})/sizeof(int)]; switch(*beg) { case
'.': case '/': _found = 1; break; default: break; } _found; }
) && end - beg < 32)
203 beg--;
204
205 if (*beg != '.' || end <= beg + 1)
206 return 0;
207
208 _lang = strndup(beg + 1, end - beg - 1);
209 if (!_lang)
210 return -ENOMEM12;
211
212 *lang = _lang;
213 return 1;
214}
215
216static int catalog_entry_lang(const char* filename, int line,
217 const char* t, const char* deflang, char **lang) {
218 size_t c;
219
220 c = strlen(t);
221 if (c == 0) {
222 log_error("[%s:%u] Language too short.", filename, line)({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 222, __func__, "[%s:%u] Language too short."
, filename, line) : -abs(_e); });
223 return -EINVAL22;
224 }
225 if (c > 31) {
226 log_error("[%s:%u] language too long.", filename, line)({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 226, __func__, "[%s:%u] language too long."
, filename, line) : -abs(_e); });
227 return -EINVAL22;
228 }
229
230 if (deflang) {
231 if (streq(t, deflang)(strcmp((t),(deflang)) == 0)) {
232 log_warning("[%s:%u] language specified unnecessarily",({ int _level = (((4))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 233, __func__, "[%s:%u] language specified unnecessarily"
, filename, line) : -abs(_e); })
233 filename, line)({ int _level = (((4))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 233, __func__, "[%s:%u] language specified unnecessarily"
, filename, line) : -abs(_e); });
234 return 0;
235 } else
236 log_warning("[%s:%u] language differs from default for file",({ int _level = (((4))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 237, __func__, "[%s:%u] language differs from default for file"
, filename, line) : -abs(_e); })
237 filename, line)({ int _level = (((4))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 237, __func__, "[%s:%u] language differs from default for file"
, filename, line) : -abs(_e); });
238 }
239
240 *lang = strdup(t);
241 if (!*lang)
242 return -ENOMEM12;
243
244 return 0;
245}
246
247int catalog_import_file(Hashmap *h, const char *path) {
248 _cleanup_fclose___attribute__((cleanup(fclosep))) FILE *f = NULL((void*)0);
249 _cleanup_free___attribute__((cleanup(freep))) char *payload = NULL((void*)0);
250 size_t payload_size = 0, payload_allocated = 0;
251 unsigned n = 0;
252 sd_id128_t id;
253 _cleanup_free___attribute__((cleanup(freep))) char *deflang = NULL((void*)0), *lang = NULL((void*)0);
254 bool_Bool got_id = false0, empty_line = true1;
255 int r;
256
257 assert(h)do { if ((__builtin_expect(!!(!(h)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("h"), "../src/journal/catalog.c", 257, __PRETTY_FUNCTION__
); } while (0);
258 assert(path)do { if ((__builtin_expect(!!(!(path)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("path"), "../src/journal/catalog.c", 258
, __PRETTY_FUNCTION__); } while (0);
259
260 f = fopen(path, "re");
261 if (!f)
262 return log_error_errno(errno, "Failed to open file %s: %m", path)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
= (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
((_level) & 0x07)) ? log_internal_realm(((_realm) <<
10 | (_level)), _e, "../src/journal/catalog.c", 262, __func__
, "Failed to open file %s: %m", path) : -abs(_e); });
263
264 r = catalog_file_lang(path, &deflang);
265 if (r < 0)
266 log_error_errno(r, "Failed to determine language for file %s: %m", path)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 266, __func__, "Failed to determine language for file %s: %m"
, path) : -abs(_e); });
267 if (r == 1)
268 log_debug("File %s has language %s.", path, deflang)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 268, __func__, "File %s has language %s."
, path, deflang) : -abs(_e); });
269
270 for (;;) {
271 char line[LINE_MAX2048];
272 size_t line_len;
273
274 if (!fgets(line, sizeof(line), f)) {
275 if (feof(f))
276 break;
277
278 return log_error_errno(errno, "Failed to read file %s: %m", path)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
= (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
((_level) & 0x07)) ? log_internal_realm(((_realm) <<
10 | (_level)), _e, "../src/journal/catalog.c", 278, __func__
, "Failed to read file %s: %m", path) : -abs(_e); });
279 }
280
281 n++;
282
283 truncate_nl(line);
284
285 if (line[0] == 0) {
286 empty_line = true1;
287 continue;
288 }
289
290 if (strchr(COMMENTS"#;" "\n", line[0]))
291 continue;
292
293 if (empty_line &&
294 strlen(line) >= 2+1+32 &&
295 line[0] == '-' &&
296 line[1] == '-' &&
297 line[2] == ' ' &&
298 IN_SET(line[2+1+32], ' ', '\0')({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){' ', '\0'})/sizeof(int)]; switch(line[2+
1+32]) { case ' ': case '\0': _found = 1; break; default: break
; } _found; })) {
299
300 bool_Bool with_language;
301 sd_id128_t jd;
302
303 /* New entry */
304
305 with_language = line[2+1+32] != '\0';
306 line[2+1+32] = '\0';
307
308 if (sd_id128_from_string(line + 2 + 1, &jd) >= 0) {
309
310 if (got_id) {
311 if (payload_size == 0) {
312 log_error("[%s:%u] No payload text.", path, n)({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 312, __func__, "[%s:%u] No payload text."
, path, n) : -abs(_e); });
313 return -EINVAL22;
314 }
315
316 r = finish_item(h, id, lang ?: deflang, payload, payload_size);
317 if (r < 0)
318 return r;
319
320 lang = mfree(lang);
321 payload_size = 0;
322 }
323
324 if (with_language) {
325 char *t;
326
327 t = strstrip(line + 2 + 1 + 32 + 1);
328 r = catalog_entry_lang(path, n, t, deflang, &lang);
329 if (r < 0)
330 return r;
331 }
332
333 got_id = true1;
334 empty_line = false0;
335 id = jd;
336
337 continue;
338 }
339 }
340
341 /* Payload */
342 if (!got_id) {
343 log_error("[%s:%u] Got payload before ID.", path, n)({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 343, __func__, "[%s:%u] Got payload before ID."
, path, n) : -abs(_e); });
344 return -EINVAL22;
345 }
346
347 line_len = strlen(line);
348 if (!GREEDY_REALLOC(payload, payload_allocated,greedy_realloc((void**) &(payload), &(payload_allocated
), (payload_size + (empty_line ? 1 : 0) + line_len + 1 + 1), sizeof
((payload)[0]))
349 payload_size + (empty_line ? 1 : 0) + line_len + 1 + 1)greedy_realloc((void**) &(payload), &(payload_allocated
), (payload_size + (empty_line ? 1 : 0) + line_len + 1 + 1), sizeof
((payload)[0])))
350 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 350, __func__);
351
352 if (empty_line)
353 payload[payload_size++] = '\n';
354 memcpy(payload + payload_size, line, line_len);
355 payload_size += line_len;
356 payload[payload_size++] = '\n';
357 payload[payload_size] = '\0';
358
359 empty_line = false0;
360 }
361
362 if (got_id) {
363 if (payload_size == 0) {
364 log_error("[%s:%u] No payload text.", path, n)({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 364, __func__, "[%s:%u] No payload text."
, path, n) : -abs(_e); });
365 return -EINVAL22;
366 }
367
368 r = finish_item(h, id, lang ?: deflang, payload, payload_size);
369 if (r < 0)
370 return r;
371 }
372
373 return 0;
374}
375
376static int64_t write_catalog(const char *database, struct strbuf *sb,
377 CatalogItem *items, size_t n) {
378 CatalogHeader header;
379 _cleanup_fclose___attribute__((cleanup(fclosep))) FILE *w = NULL((void*)0);
380 int r;
381 _cleanup_free___attribute__((cleanup(freep))) char *d, *p = NULL((void*)0);
382 size_t k;
383
384 d = dirname_malloc(database);
385 if (!d)
386 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 386, __func__);
387
388 r = mkdir_p(d, 0775);
389 if (r < 0)
390 return log_error_errno(r, "Recursive mkdir %s: %m", d)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 390, __func__, "Recursive mkdir %s: %m"
, d) : -abs(_e); });
391
392 r = fopen_temporary(database, &w, &p);
393 if (r < 0)
394 return log_error_errno(r, "Failed to open database for writing: %s: %m",({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 395, __func__, "Failed to open database for writing: %s: %m"
, database) : -abs(_e); })
395 database)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 395, __func__, "Failed to open database for writing: %s: %m"
, database) : -abs(_e); });
396
397 zero(header)(({ size_t _l_ = (sizeof(header)); void *_x_ = (&(header)
); _l_ == 0 ? _x_ : memset(_x_, 0, _l_); }));
398 memcpy(header.signature, CATALOG_SIGNATURE(uint8_t[]) { 'R', 'H', 'H', 'H', 'K', 'S', 'L', 'P' }, sizeof(header.signature));
399 header.header_size = htole64(ALIGN_TO(sizeof(CatalogHeader), 8));
400 header.catalog_item_size = htole64(sizeof(CatalogItem));
401 header.n_items = htole64(n);
402
403 r = -EIO5;
404
405 k = fwrite(&header, 1, sizeof(header), w);
406 if (k != sizeof(header)) {
407 log_error("%s: failed to write header.", p)({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 407, __func__, "%s: failed to write header."
, p) : -abs(_e); });
408 goto error;
409 }
410
411 k = fwrite(items, 1, n * sizeof(CatalogItem), w);
412 if (k != n * sizeof(CatalogItem)) {
413 log_error("%s: failed to write database.", p)({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 413, __func__, "%s: failed to write database."
, p) : -abs(_e); });
414 goto error;
415 }
416
417 k = fwrite(sb->buf, 1, sb->len, w);
418 if (k != sb->len) {
419 log_error("%s: failed to write strings.", p)({ int _level = (((3))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 419, __func__, "%s: failed to write strings."
, p) : -abs(_e); });
420 goto error;
421 }
422
423 r = fflush_and_check(w);
424 if (r < 0) {
425 log_error_errno(r, "%s: failed to write database: %m", p)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 425, __func__, "%s: failed to write database: %m"
, p) : -abs(_e); });
426 goto error;
427 }
428
429 fchmod(fileno(w), 0644);
430
431 if (rename(p, database) < 0) {
432 r = log_error_errno(errno, "rename (%s -> %s) failed: %m", p, database)({ int _level = ((3)), _e = (((*__errno_location ()))), _realm
= (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
((_level) & 0x07)) ? log_internal_realm(((_realm) <<
10 | (_level)), _e, "../src/journal/catalog.c", 432, __func__
, "rename (%s -> %s) failed: %m", p, database) : -abs(_e);
});
433 goto error;
434 }
435
436 return ftello(w);
437
438error:
439 (void) unlink(p);
440 return r;
441}
442
443int catalog_update(const char* database, const char* root, const char* const* dirs) {
444 _cleanup_strv_free___attribute__((cleanup(strv_freep))) char **files = NULL((void*)0);
445 char **f;
446 _cleanup_(strbuf_cleanupp)__attribute__((cleanup(strbuf_cleanupp))) struct strbuf *sb = NULL((void*)0);
447 _cleanup_hashmap_free_free_free___attribute__((cleanup(hashmap_free_free_freep))) Hashmap *h = NULL((void*)0);
448 _cleanup_free___attribute__((cleanup(freep))) CatalogItem *items = NULL((void*)0);
449 ssize_t offset;
450 char *payload;
451 CatalogItem *i;
452 Iterator j;
453 unsigned n;
454 int r;
455 int64_t sz;
456
457 h = hashmap_new(&catalog_hash_ops)internal_hashmap_new(&catalog_hash_ops );
458 sb = strbuf_new();
459 if (!h || !sb)
460 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 460, __func__);
461
462 r = conf_files_list_strv(&files, ".catalog", root, 0, dirs);
463 if (r < 0)
464 return log_error_errno(r, "Failed to get catalog files: %m")({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 464, __func__, "Failed to get catalog files: %m"
) : -abs(_e); });
465
466 STRV_FOREACH(f, files)for ((f) = (files); (f) && *(f); (f)++) {
467 log_debug("Reading file '%s'", *f)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 467, __func__, "Reading file '%s'"
, *f) : -abs(_e); });
468 r = catalog_import_file(h, *f);
469 if (r < 0)
470 return log_error_errno(r, "Failed to import file '%s': %m", *f)({ int _level = ((3)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 470, __func__, "Failed to import file '%s': %m"
, *f) : -abs(_e); });
471 }
472
473 if (hashmap_size(h) <= 0) {
474 log_info("No items in catalog.")({ int _level = (((6))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 474, __func__, "No items in catalog."
) : -abs(_e); });
475 return 0;
476 } else
477 log_debug("Found %u items in catalog.", hashmap_size(h))({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 477, __func__, "Found %u items in catalog."
, hashmap_size(h)) : -abs(_e); });
478
479 items = new(CatalogItem, hashmap_size(h))((CatalogItem*) malloc_multiply(sizeof(CatalogItem), (hashmap_size
(h))));
480 if (!items)
481 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 481, __func__);
482
483 n = 0;
484 HASHMAP_FOREACH_KEY(payload, i, h, j)for ((j) = ((Iterator) { .idx = ((2147483647 *2U +1U) - 1), .
next_key = ((void*)0) }); hashmap_iterate((h), &(j), (void
**)&(payload), (const void**) &(i)); ) {
485 log_debug("Found " SD_ID128_FORMAT_STR ", language %s",({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 487, __func__, "Found " "%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x"
", language %s", (i->id).bytes[0], (i->id).bytes[1], (
i->id).bytes[2], (i->id).bytes[3], (i->id).bytes[4],
(i->id).bytes[5], (i->id).bytes[6], (i->id).bytes[7
], (i->id).bytes[8], (i->id).bytes[9], (i->id).bytes
[10], (i->id).bytes[11], (i->id).bytes[12], (i->id).
bytes[13], (i->id).bytes[14], (i->id).bytes[15], isempty
(i->language) ? "C" : i->language) : -abs(_e); })
486 SD_ID128_FORMAT_VAL(i->id),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 487, __func__, "Found " "%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x"
", language %s", (i->id).bytes[0], (i->id).bytes[1], (
i->id).bytes[2], (i->id).bytes[3], (i->id).bytes[4],
(i->id).bytes[5], (i->id).bytes[6], (i->id).bytes[7
], (i->id).bytes[8], (i->id).bytes[9], (i->id).bytes
[10], (i->id).bytes[11], (i->id).bytes[12], (i->id).
bytes[13], (i->id).bytes[14], (i->id).bytes[15], isempty
(i->language) ? "C" : i->language) : -abs(_e); })
487 isempty(i->language) ? "C" : i->language)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 487, __func__, "Found " "%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x"
", language %s", (i->id).bytes[0], (i->id).bytes[1], (
i->id).bytes[2], (i->id).bytes[3], (i->id).bytes[4],
(i->id).bytes[5], (i->id).bytes[6], (i->id).bytes[7
], (i->id).bytes[8], (i->id).bytes[9], (i->id).bytes
[10], (i->id).bytes[11], (i->id).bytes[12], (i->id).
bytes[13], (i->id).bytes[14], (i->id).bytes[15], isempty
(i->language) ? "C" : i->language) : -abs(_e); });
488
489 offset = strbuf_add_string(sb, payload, strlen(payload));
490 if (offset < 0)
491 return log_oom()log_oom_internal(LOG_REALM_SYSTEMD, "../src/journal/catalog.c"
, 491, __func__);
492
493 i->offset = htole64((uint64_t) offset);
494 items[n++] = *i;
495 }
496
497 assert(n == hashmap_size(h))do { if ((__builtin_expect(!!(!(n == hashmap_size(h))),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("n == hashmap_size(h)"), "../src/journal/catalog.c"
, 497, __PRETTY_FUNCTION__); } while (0);
498 qsort_safe(items, n, sizeof(CatalogItem), catalog_compare_func);
499
500 strbuf_complete(sb);
501
502 sz = write_catalog(database, sb, items, n);
503 if (sz < 0)
504 return log_error_errno(sz, "Failed to write %s: %m", database)({ int _level = ((3)), _e = ((sz)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 504, __func__, "Failed to write %s: %m"
, database) : -abs(_e); });
505
506 log_debug("%s: wrote %u items, with %zu bytes of strings, %"PRIi64" total size.",({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 507, __func__, "%s: wrote %u items, with %zu bytes of strings, %"
"l" "i"" total size.", database, n, sb->len, sz) : -abs(_e
); })
507 database, n, sb->len, sz)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 507, __func__, "%s: wrote %u items, with %zu bytes of strings, %"
"l" "i"" total size.", database, n, sb->len, sz) : -abs(_e
); });
508 return 0;
509}
510
511static int open_mmap(const char *database, int *_fd, struct stat *_st, void **_p) {
512 const CatalogHeader *h;
513 int fd;
514 void *p;
515 struct stat st;
516
517 assert(_fd)do { if ((__builtin_expect(!!(!(_fd)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("_fd"), "../src/journal/catalog.c", 517,
__PRETTY_FUNCTION__); } while (0);
518 assert(_st)do { if ((__builtin_expect(!!(!(_st)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("_st"), "../src/journal/catalog.c", 518,
__PRETTY_FUNCTION__); } while (0);
519 assert(_p)do { if ((__builtin_expect(!!(!(_p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("_p"), "../src/journal/catalog.c", 519, __PRETTY_FUNCTION__
); } while (0);
520
521 fd = open(database, O_RDONLY00|O_CLOEXEC02000000);
522 if (fd < 0)
523 return -errno(*__errno_location ());
524
525 if (fstat(fd, &st) < 0) {
526 safe_close(fd);
527 return -errno(*__errno_location ());
528 }
529
530 if (st.st_size < (off_t) sizeof(CatalogHeader)) {
531 safe_close(fd);
532 return -EINVAL22;
533 }
534
535 p = mmap(NULL((void*)0), PAGE_ALIGN(st.st_size)ALIGN_TO((st.st_size), page_size()), PROT_READ0x1, MAP_SHARED0x01, fd, 0);
536 if (p == MAP_FAILED((void *) -1)) {
537 safe_close(fd);
538 return -errno(*__errno_location ());
539 }
540
541 h = p;
542 if (memcmp(h->signature, CATALOG_SIGNATURE(uint8_t[]) { 'R', 'H', 'H', 'H', 'K', 'S', 'L', 'P' }, sizeof(h->signature)) != 0 ||
543 le64toh(h->header_size) < sizeof(CatalogHeader) ||
544 le64toh(h->catalog_item_size) < sizeof(CatalogItem) ||
545 h->incompatible_flags != 0 ||
546 le64toh(h->n_items) <= 0 ||
547 st.st_size < (off_t) (le64toh(h->header_size) + le64toh(h->catalog_item_size) * le64toh(h->n_items))) {
548 safe_close(fd);
549 munmap(p, st.st_size);
550 return -EBADMSG74;
551 }
552
553 *_fd = fd;
554 *_st = st;
555 *_p = p;
556
557 return 0;
558}
559
560static const char *find_id(void *p, sd_id128_t id) {
561 CatalogItem *f = NULL((void*)0), key = { .id = id };
562 const CatalogHeader *h = p;
563 const char *loc;
564
565 loc = setlocale(LC_MESSAGES5, NULL((void*)0));
566 if (loc && loc[0] && !streq(loc, "C")(strcmp((loc),("C")) == 0) && !streq(loc, "POSIX")(strcmp((loc),("POSIX")) == 0)) {
567 strncpy(key.language, loc, sizeof(key.language));
568 key.language[strcspn(key.language, ".@")] = 0;
569
570 f = bsearch(&key, (const uint8_t*) p + le64toh(h->header_size), le64toh(h->n_items), le64toh(h->catalog_item_size), catalog_compare_func);
571 if (!f) {
572 char *e;
573
574 e = strchr(key.language, '_');
575 if (e) {
576 *e = 0;
577 f = bsearch(&key, (const uint8_t*) p + le64toh(h->header_size), le64toh(h->n_items), le64toh(h->catalog_item_size), catalog_compare_func);
578 }
579 }
580 }
581
582 if (!f) {
583 zero(key.language)(({ size_t _l_ = (sizeof(key.language)); void *_x_ = (&(key
.language)); _l_ == 0 ? _x_ : memset(_x_, 0, _l_); }));
584 f = bsearch(&key, (const uint8_t*) p + le64toh(h->header_size), le64toh(h->n_items), le64toh(h->catalog_item_size), catalog_compare_func);
585 }
586
587 if (!f)
588 return NULL((void*)0);
589
590 return (const char*) p +
591 le64toh(h->header_size) +
592 le64toh(h->n_items) * le64toh(h->catalog_item_size) +
593 le64toh(f->offset);
594}
595
596int catalog_get(const char* database, sd_id128_t id, char **_text) {
597 _cleanup_close___attribute__((cleanup(closep))) int fd = -1;
598 void *p = NULL((void*)0);
599 struct stat st = {};
600 char *text = NULL((void*)0);
601 int r;
602 const char *s;
603
604 assert(_text)do { if ((__builtin_expect(!!(!(_text)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("_text"), "../src/journal/catalog.c", 604
, __PRETTY_FUNCTION__); } while (0);
605
606 r = open_mmap(database, &fd, &st, &p);
607 if (r < 0)
608 return r;
609
610 s = find_id(p, id);
611 if (!s) {
612 r = -ENOENT2;
613 goto finish;
614 }
615
616 text = strdup(s);
617 if (!text) {
618 r = -ENOMEM12;
619 goto finish;
620 }
621
622 *_text = text;
623 r = 0;
624
625finish:
626 if (p)
627 munmap(p, st.st_size);
628
629 return r;
630}
631
632static char *find_header(const char *s, const char *header) {
633
634 for (;;) {
10
←
Loop condition is true. Entering loop body
→
635 const char *v;
636
637 v = startswith(s, header);
638 if (v
10.1
'v' is non-null
) {
11
←
Taking true branch
→
639 v += strspn(v, WHITESPACE" \t\n\r");
640 return strndup(v, strcspn(v, NEWLINE"\n\r"));
12
←
Memory is allocated
→
641 }
642
643 if (!next_header(&s))
644 return NULL((void*)0);
645 }
646}
647
648static void dump_catalog_entry(FILE *f, sd_id128_t id, const char *s, bool_Bool oneline) {
649 if (oneline) {
7
←
Assuming 'oneline' is true
→
8
←
Taking true branch
→
650 _cleanup_free___attribute__((cleanup(freep))) char *subject = NULL((void*)0), *defined_by = NULL((void*)0);
651
652 subject = find_header(s, "Subject:");
9
←
Calling 'find_header'
→
13
←
Returned allocated memory
→
653 defined_by = find_header(s, "Defined-By:");
654
655 fprintf(f, SD_ID128_FORMAT_STR"%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x" " %s: %s\n",
656 SD_ID128_FORMAT_VAL(id)(id).bytes[0], (id).bytes[1], (id).bytes[2], (id).bytes[3], (
id).bytes[4], (id).bytes[5], (id).bytes[6], (id).bytes[7], (id
).bytes[8], (id).bytes[9], (id).bytes[10], (id).bytes[11], (id
).bytes[12], (id).bytes[13], (id).bytes[14], (id).bytes[15],
657 strna(defined_by), strna(subject));
658 } else
659 fprintf(f, "-- " SD_ID128_FORMAT_STR"%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x%02x" "\n%s\n",
660 SD_ID128_FORMAT_VAL(id)(id).bytes[0], (id).bytes[1], (id).bytes[2], (id).bytes[3], (
id).bytes[4], (id).bytes[5], (id).bytes[6], (id).bytes[7], (id
).bytes[8], (id).bytes[9], (id).bytes[10], (id).bytes[11], (id
).bytes[12], (id).bytes[13], (id).bytes[14], (id).bytes[15], s);
661}
14
←
Potential leak of memory pointed to by 'subject'
662
663int catalog_list(FILE *f, const char *database, bool_Bool oneline) {
664 _cleanup_close___attribute__((cleanup(closep))) int fd = -1;
665 void *p = NULL((void*)0);
666 struct stat st;
667 const CatalogHeader *h;
668 const CatalogItem *items;
669 int r;
670 unsigned n;
671 sd_id128_t last_id;
672 bool_Bool last_id_set = false0;
673
674 r = open_mmap(database, &fd, &st, &p);
675 if (r < 0)
676 return r;
677
678 h = p;
679 items = (const CatalogItem*) ((const uint8_t*) p + le64toh(h->header_size));
680
681 for (n = 0; n < le64toh(h->n_items); n++) {
682 const char *s;
683
684 if (last_id_set && sd_id128_equal(last_id, items[n].id))
685 continue;
686
687 assert_se(s = find_id(p, items[n].id))do { if ((__builtin_expect(!!(!(s = find_id(p, items[n].id)))
,0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("s = find_id(p, items[n].id)"
), "../src/journal/catalog.c", 687, __PRETTY_FUNCTION__); } while
(0);
688
689 dump_catalog_entry(f, items[n].id, s, oneline);
690
691 last_id_set = true1;
692 last_id = items[n].id;
693 }
694
695 munmap(p, st.st_size);
696
697 return 0;
698}
699
700int catalog_list_items(FILE *f, const char *database, bool_Bool oneline, char **items) {
701 char **item;
702 int r = 0;
703
704 STRV_FOREACH(item, items)for ((item) = (items); (item) && *(item); (item)++) {
1
Assuming 'item' is non-null
→
2
←
Loop condition is true. Entering loop body
→
705 sd_id128_t id;
706 int k;
707 _cleanup_free___attribute__((cleanup(freep))) char *msg = NULL((void*)0);
708
709 k = sd_id128_from_string(*item, &id);
710 if (k < 0) {
3
←
Assuming 'k' is >= 0
→
4
←
Taking false branch
→
711 log_error_errno(k, "Failed to parse id128 '%s': %m", *item)({ int _level = ((3)), _e = ((k)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 711, __func__, "Failed to parse id128 '%s': %m"
, *item) : -abs(_e); });
712 if (r == 0)
713 r = k;
714 continue;
715 }
716
717 k = catalog_get(database, id, &msg);
718 if (k
4.1
'k' is >= 0
 < 0) {
5
←
Taking false branch
→
719 log_full_errno(k == -ENOENT ? LOG_NOTICE : LOG_ERR, k,({ int _level = ((k == -2 ? 5 : 3)), _e = ((k)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 720, __func__, "Failed to retrieve catalog entry for '%s': %m"
, *item) : -abs(_e); })
720 "Failed to retrieve catalog entry for '%s': %m", *item)({ int _level = ((k == -2 ? 5 : 3)), _e = ((k)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/journal/catalog.c", 720, __func__, "Failed to retrieve catalog entry for '%s': %m"
, *item) : -abs(_e); });
721 if (r == 0)
722 r = k;
723 continue;
724 }
725
726 dump_catalog_entry(f, id, msg, oneline);
6
←
Calling 'dump_catalog_entry'
→
727 }
728
729 return r;
730}