1 /* SPDX-License-Identifier: GPL-2.0 */
98 	int ret = -1;  in alloc_anon_50M_check()
103 		return -1;  in alloc_anon_50M_check()
132 	int ret = -1;  in alloc_pagecache_50M_check()
138 		return -1;  in alloc_pagecache_50M_check()
172 	int peak_fd = -1, peak_fd2 = -1, peak_fd3 = -1, peak_fd4 = -1;  in test_memcg_current_peak()
198 	 * We'll open a few FDs for the same memory.peak file to exercise the free-path  in test_memcg_current_peak()
200 	 * the linked-list handling.  in test_memcg_current_peak()
204 	if (peak_fd == -1) {  in test_memcg_current_peak()
225 	if (peak_fd2 == -1)  in test_memcg_current_peak()
230 	if (peak_fd3 == -1)  in test_memcg_current_peak()
233 	/* any non-empty string resets, but make it clear */  in test_memcg_current_peak()
248 	/* Make sure a completely independent read isn't affected by our  FD-local reset above*/  in test_memcg_current_peak()
259 	if (peak_fd4 == -1)  in test_memcg_current_peak()
316 		return -1;  in alloc_pagecache_50M_noexit()
333 		return -1;  in alloc_anon_noexit()
354 	for (limit = 10; limit > 0; limit--) {  in cg_test_proc_killed()
360 	return -1;  in cg_test_proc_killed()
367  * A       memory.min = 0,    memory.max = 200M
440 	if (cg_write(parent[0], "memory.max", "200M"))  in test_memcg_protection()
443 	if (cg_write(parent[0], "memory.swap.max", "0"))  in test_memcg_protection()
547 	for (i = ARRAY_SIZE(children) - 1; i >= 0; i--) {  in test_memcg_protection()
555 	for (i = ARRAY_SIZE(parent) - 1; i >= 0; i--) {  in test_memcg_protection()
579 	int ret = -1;  in alloc_pagecache_max_30M()
580 	long current, high, max;  in alloc_pagecache_max_30M()  local
584 	max = cg_read_long(cgroup, "memory.max");  in alloc_pagecache_max_30M()
585 	if (high != MB(30) && max != MB(30))  in alloc_pagecache_max_30M()
586 		return -1;  in alloc_pagecache_max_30M()
590 		return -1;  in alloc_pagecache_max_30M()
625 	if (cg_read_strcmp(memcg, "memory.high", "max\n"))  in test_memcg_high()
628 	if (cg_write(memcg, "memory.swap.max", "0"))  in test_memcg_high()
664 		return -1;  in alloc_anon_mlock()
677 	int ret = KSFT_FAIL, pid, fd = -1;  in test_memcg_high_sync()
690 	pre_max = cg_read_key_long(memcg, "memory.events", "max ");  in test_memcg_high_sync()
694 	if (cg_write(memcg, "memory.swap.max", "0"))  in test_memcg_high_sync()
700 	if (cg_write(memcg, "memory.max", "140M"))  in test_memcg_high_sync()
714 	post_max = cg_read_key_long(memcg, "memory.events", "max ");  in test_memcg_high_sync()
733  * This test checks that memory.max limits the amount of
741 	long current, max;  in test_memcg_max()  local
750 	if (cg_read_strcmp(memcg, "memory.max", "max\n"))  in test_memcg_max()
753 	if (cg_write(memcg, "memory.swap.max", "0"))  in test_memcg_max()
756 	if (cg_write(memcg, "memory.max", "30M"))  in test_memcg_max()
770 	max = cg_read_key_long(memcg, "memory.events", "max ");  in test_memcg_max()
771 	if (max <= 0)  in test_memcg_max()
801 	int retries, err;  in reclaim_until()  local
805 	for (retries = 5; retries > 0; retries--) {  in reclaim_until()
814 		to_reclaim = current - goal;  in reclaim_until()
819 		else if (err != -EAGAIN)  in reclaim_until()
832 	int fd = -1;  in test_memcg_reclaim()
833 	int retries;  in test_memcg_reclaim()  local
866 	 * retries).  in test_memcg_reclaim()
868 	retries = 5;  in test_memcg_reclaim()
871 		if (retries--) {  in test_memcg_reclaim()
904 	int ret = -1;  in alloc_anon_50M_check_swap()
909 		return -1;  in alloc_anon_50M_check_swap()
931  * This test checks that memory.swap.max limits the amount of
939 	long max, peak;  in test_memcg_swap_max_peak()  local
941 	int swap_peak_fd = -1, mem_peak_fd = -1;  in test_memcg_swap_max_peak()
943 	/* any non-empty string resets */  in test_memcg_swap_max_peak()
964 	if (swap_peak_fd == -1) {  in test_memcg_swap_max_peak()
985 	if (mem_peak_fd == -1)  in test_memcg_swap_max_peak()
994 	/* switch the swap and mem fds into local-peak tracking mode*/  in test_memcg_swap_max_peak()
1016 	if (cg_read_strcmp(memcg, "memory.max", "max\n"))  in test_memcg_swap_max_peak()
1019 	if (cg_read_strcmp(memcg, "memory.swap.max", "max\n"))  in test_memcg_swap_max_peak()
1022 	if (cg_write(memcg, "memory.swap.max", "30M"))  in test_memcg_swap_max_peak()
1025 	if (cg_write(memcg, "memory.max", "30M"))  in test_memcg_swap_max_peak()
1056 	 * multiple extant fds don't corrupt the linked-list  in test_memcg_swap_max_peak()
1096 	max = cg_read_key_long(memcg, "memory.events", "max ");  in test_memcg_swap_max_peak()
1097 	if (max <= 0)  in test_memcg_swap_max_peak()
1119 	if (mem_peak_fd != -1 && close(mem_peak_fd))  in test_memcg_swap_max_peak()
1121 	if (swap_peak_fd != -1 && close(swap_peak_fd))  in test_memcg_swap_max_peak()
1146 	if (cg_write(memcg, "memory.max", "30M"))  in test_memcg_oom_events()
1149 	if (cg_write(memcg, "memory.swap.max", "0"))  in test_memcg_oom_events()
1183 	int sk, client_sk, ctl_fd, yes = 1, ret = -1;  in tcp_server()
1185 	close(srv_args->ctl[0]);  in tcp_server()
1186 	ctl_fd = srv_args->ctl[1];  in tcp_server()
1190 	saddr.sin6_port = htons(srv_args->port);  in tcp_server()
1209 		ret = -1;  in tcp_server()
1217 	ret = -1;  in tcp_server()
1240 	int retries = 0x10; /* nice round number */  in tcp_client()  local
1250 	sk = socket(ai->ai_family, ai->ai_socktype, ai->ai_protocol);  in tcp_client()
1254 	ret = connect(sk, ai->ai_addr, ai->ai_addrlen);  in tcp_client()
1259 	while (retries--) {  in tcp_client()
1273 		if (values_close(current - allocated, sock, 10)) {  in tcp_client()
1307 	while (bind_retries--) {  in test_memcg_sock()
1386 	if (cg_write(child, "memory.max", "50M"))  in test_memcg_oom_group_leaf_events()
1389 	if (cg_write(child, "memory.swap.max", "0"))  in test_memcg_oom_group_leaf_events()
1454 	if (cg_write(parent, "memory.max", "80M"))  in test_memcg_oom_group_parent_events()
1457 	if (cg_write(parent, "memory.swap.max", "0"))  in test_memcg_oom_group_parent_events()
1507 	if (cg_write(memcg, "memory.max", "50M"))  in test_memcg_oom_group_score_events()
1510 	if (cg_write(memcg, "memory.swap.max", "0"))  in test_memcg_oom_group_score_events()