15263807472

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

#include <stdio.h>
#include <threads.h>

#include "alloc-util.h"
#include "errno-util.h"
#include "extract-word.h"
#include "fd-util.h"
#include "fileio.h"
#include "parse-util.h"
#include "psi-util.h"
#include "string-util.h"
#include "strv.h"

int read_resource_pressure(const char *path, PressureType type, ResourcePressure *ret) {
        _cleanup_free_ char *line = NULL;
        _cleanup_fclose_ FILE *f = NULL;
        unsigned field_filled = 0;
        ResourcePressure rp = {};
        const char *t, *cline;
        char *word;
        int r;

        assert(path);
        assert(IN_SET(type, PRESSURE_TYPE_SOME, PRESSURE_TYPE_FULL));
        assert(ret);

        if (type == PRESSURE_TYPE_SOME)
                t = "some";
        else if (type == PRESSURE_TYPE_FULL)
                t = "full";
        else
                return -EINVAL;

        r = fopen_unlocked(path, "re", &f);
        if (r < 0)
                return r;

        for (;;) {
                _cleanup_free_ char *l = NULL;
                char *w;

                r = read_line(f, LONG_LINE_MAX, &l);
                if (r < 0)
                        return r;
                if (r == 0)
                        break;

                w = first_word(l, t);
                if (w) {
                        line = TAKE_PTR(l);
                        cline = w;
                        break;
                }
        }

        if (!line)
                return -ENODATA;

        /* extracts either avgX=Y.Z or total=X */
        while ((r = extract_first_word(&cline, &word, NULL, 0)) > 0) {
                _cleanup_free_ char *w = word;
                const char *v;

                if ((v = startswith(w, "avg10="))) {
                        if (field_filled & (1U << 0))
                                return -EINVAL;

                        field_filled |= 1U << 0;
                        r = parse_loadavg_fixed_point(v, &rp.avg10);
                } else if ((v = startswith(w, "avg60="))) {
                        if (field_filled & (1U << 1))
                                return -EINVAL;

                        field_filled |= 1U << 1;
                        r = parse_loadavg_fixed_point(v, &rp.avg60);
                } else if ((v = startswith(w, "avg300="))) {
                        if (field_filled & (1U << 2))
                                return -EINVAL;

                        field_filled |= 1U << 2;
                        r = parse_loadavg_fixed_point(v, &rp.avg300);
                } else if ((v = startswith(w, "total="))) {
                        if (field_filled & (1U << 3))
                                return -EINVAL;

                        field_filled |= 1U << 3;
                        r = safe_atou64(v, &rp.total);
                } else
                        continue;

                if (r < 0)
                        return r;
        }

        if (r < 0)
                return r;

        if (field_filled != 15U)
                return -EINVAL;

        *ret = rp;
        return 0;
}

int is_pressure_supported(void) {
        static thread_local int cached = -1;
        int r;

        /* The pressure files, both under /proc/ and in cgroups, will exist even if the kernel has PSI
         * support disabled; we have to read the file to make sure it doesn't return -EOPNOTSUPP */

        if (cached >= 0)
                return cached;

        FOREACH_STRING(p, "/proc/pressure/cpu", "/proc/pressure/io", "/proc/pressure/memory") {
                r = read_virtual_file(p, 0, NULL, NULL);
                if (r == -ENOENT || ERRNO_IS_NEG_NOT_SUPPORTED(r))
                        return (cached = false);
                if (r < 0)
                        return r;
        }

        return (cached = true);
}

1	/* SPDX-License-Identifier: LGPL-2.1-or-later */
2
3	#include <stdio.h>
4	#include <threads.h>
5
6	#include "alloc-util.h"
7	#include "errno-util.h"
8	#include "extract-word.h"
9	#include "fd-util.h"
10	#include "fileio.h"
11	#include "parse-util.h"
12	#include "psi-util.h"
13	#include "string-util.h"
14	#include "strv.h"
15
16	int read_resource_pressure(const char path, PressureType type, ResourcePressure ret) {	185✔
17	_cleanup_free_ char *line = NULL;	185✔
18	_cleanup_fclose_ FILE *f = NULL;	185✔
19	unsigned field_filled = 0;	185✔
20	ResourcePressure rp = {};	185✔
21	const char t, cline;	185✔
22	char *word;	185✔
23	int r;	185✔
24
25	assert(path);	185✔
26	assert(IN_SET(type, PRESSURE_TYPE_SOME, PRESSURE_TYPE_FULL));	185✔
27	assert(ret);	185✔
28
29	if (type == PRESSURE_TYPE_SOME)	185✔
30	t = "some";
31	else if (type == PRESSURE_TYPE_FULL)	172✔
32	t = "full";
33	else
34	return -EINVAL;
35
36	r = fopen_unlocked(path, "re", &f);	185✔
37	if (r < 0)	185✔
38	return r;
39
40	for (;;) {	527✔
41	_cleanup_free_ char *l = NULL;	172✔
42	char *w;	355✔
43
44	r = read_line(f, LONG_LINE_MAX, &l);	355✔
45	if (r < 0)	355✔
UNCOV 46	return r;	×
47	if (r == 0)	355✔
48	break;
49
50	w = first_word(l, t);	353✔
51	if (w) {	353✔
52	line = TAKE_PTR(l);	181✔
53	cline = w;	181✔
54	break;	181✔
55	}
56	}
57
58	if (!line)	183✔
59	return -ENODATA;
60
61	/* extracts either avgX=Y.Z or total=X */
62	while ((r = extract_first_word(&cline, &word, NULL, 0)) > 0) {	901✔
63	_cleanup_free_ char *w = word;	722✔
64	const char *v;	722✔
65
66	if ((v = startswith(w, "avg10="))) {	722✔
67	if (field_filled & (1U << 0))	181✔
68	return -EINVAL;
69
70	field_filled \|= 1U << 0;	181✔
71	r = parse_loadavg_fixed_point(v, &rp.avg10);	181✔
72	} else if ((v = startswith(w, "avg60="))) {	541✔
73	if (field_filled & (1U << 1))	181✔
74	return -EINVAL;
75
76	field_filled \|= 1U << 1;	180✔
77	r = parse_loadavg_fixed_point(v, &rp.avg60);	180✔
78	} else if ((v = startswith(w, "avg300="))) {	360✔
79	if (field_filled & (1U << 2))	179✔
80	return -EINVAL;
81
82	field_filled \|= 1U << 2;	179✔
83	r = parse_loadavg_fixed_point(v, &rp.avg300);	179✔
84	} else if ((v = startswith(w, "total="))) {	181✔
85	if (field_filled & (1U << 3))	179✔
86	return -EINVAL;
87
88	field_filled \|= 1U << 3;	179✔
89	r = safe_atou64(v, &rp.total);	179✔
90	} else
91	continue;	2✔
92
93	if (r < 0)	719✔
94	return r;
95	}
96
97	if (r < 0)	179✔
98	return r;
99
100	if (field_filled != 15U)	179✔
101	return -EINVAL;
102
103	*ret = rp;	179✔
104	return 0;	179✔
105	}
106
107	int is_pressure_supported(void) {	12,181✔
108	static thread_local int cached = -1;	12,181✔
109	int r;	12,181✔
110
111	/* The pressure files, both under /proc/ and in cgroups, will exist even if the kernel has PSI
112	* support disabled; we have to read the file to make sure it doesn't return -EOPNOTSUPP */
113
114	if (cached >= 0)	12,181✔
115	return cached;
116
117	FOREACH_STRING(p, "/proc/pressure/cpu", "/proc/pressure/io", "/proc/pressure/memory") {	47,564✔
118	r = read_virtual_file(p, 0, NULL, NULL);	35,673✔
119	if (r == -ENOENT \|\| ERRNO_IS_NEG_NOT_SUPPORTED(r))	35,673✔
UNCOV 120	return (cached = false);	×
121	if (r < 0)	35,673✔
122	return r;
123	}
124
125	return (cached = true);	11,891✔
126	}

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