1 // SPDX-License-Identifier: GPL-2.0
62 	ASSERT_NE(fd, -1);  in write_sysctl()
78 #define NR_PORT				(60001 - 10000 - 1)
96 	self->servers = malloc(sizeof(int) * nr_server);  in FIXTURE_SETUP()
97 	ASSERT_NE(self->servers, NULL);  in FIXTURE_SETUP()
99 	self->in_addr.sin_family = AF_INET;  in FIXTURE_SETUP()
100 	self->in_addr.sin_addr.s_addr = htonl(INADDR_LOOPBACK);  in FIXTURE_SETUP()
101 	self->in_addr.sin_port = htons(0);  in FIXTURE_SETUP()
102 	self->addrlen = sizeof(struct sockaddr_in);  in FIXTURE_SETUP()
110 		close(self->servers[i]);  in FIXTURE_TEARDOWN()
112 	free(self->servers);  in FIXTURE_TEARDOWN()
124 		  FIXTURE_DATA(so_incoming_cpu) *self,  in create_server()
131 	ASSERT_NE(fd, -1);  in create_server()
133 	if (variant->when_to_set == BEFORE_REUSEPORT)  in create_server()
139 	ret = bind(fd, &self->addr, self->addrlen);  in create_server()
142 	if (variant->when_to_set == BEFORE_LISTEN)  in create_server()
151 	if (variant->when_to_set == AFTER_LISTEN)  in create_server()
158 		    FIXTURE_DATA(so_incoming_cpu) *self,  in create_servers()
164 		self->servers[i] = create_server(_metadata, self, variant, i);  in create_servers()
167 			ret = getsockname(self->servers[i], &self->addr, &self->addrlen);  in create_servers()
172 	if (variant->when_to_set == AFTER_ALL_LISTEN) {  in create_servers()
174 			set_so_incoming_cpu(_metadata, self->servers[i], i);  in create_servers()
179 		    FIXTURE_DATA(so_incoming_cpu) *self)  in create_clients()
191 		/* Make sure SYN will be processed on the i-th CPU  in create_clients()
192 		 * and finally distributed to the i-th listener.  in create_clients()
199 			ASSERT_NE(fd, -1);  in create_clients()
201 			ret = connect(fd, &self->addr, self->addrlen);  in create_clients()
210 			 FIXTURE_DATA(so_incoming_cpu) *self)  in verify_incoming_cpu()
217 			/* If we see -EAGAIN here, SO_INCOMING_CPU is broken */  in verify_incoming_cpu()
218 			fd = accept(self->servers[i], &self->addr, &self->addrlen);  in verify_incoming_cpu()
219 			ASSERT_NE(fd, -1);  in verify_incoming_cpu()
232 	       "working correctly with %d sockets.", total);  in verify_incoming_cpu()
237 	create_servers(_metadata, self, variant);  in TEST_F()
238 	create_clients(_metadata, self);  in TEST_F()
239 	verify_incoming_cpu(_metadata, self);  in TEST_F()
246 	create_servers(_metadata, self, variant);  in TEST_F()
249 	server = create_server(_metadata, self, variant, -1);  in TEST_F()
252 	create_clients(_metadata, self);  in TEST_F()
253 	verify_incoming_cpu(_metadata, self);  in TEST_F()
260 	create_servers(_metadata, self, variant);  in TEST_F()
263 	server = create_server(_metadata, self, variant, -1);  in TEST_F()
265 	create_clients(_metadata, self);  in TEST_F()
268 	client = accept(server, &self->addr, &self->addrlen);  in TEST_F()
269 	ASSERT_EQ(client, -1);  in TEST_F()
271 	verify_incoming_cpu(_metadata, self);  in TEST_F()