bpf/prog_tests/migrate_reuseport.c

150 	int err = 0, fd, len;
159 			err = -1;
163 			err = -1;
167 		err = lseek(fd, 0, SEEK_SET);
168 		if (!ASSERT_OK(err, "lseek"))
176 			err = -1;
182 	return err;
205 	int err;
207 	err = bpf_link__destroy(test_case->link);
208 	if (!ASSERT_OK(err, "bpf_link__destroy"))
219 	int i, err, prog_fd, reuseport = 1, qlen = QLEN;
233 		err = setsockopt(test_case->servers[i], SOL_SOCKET,
235 		if (!ASSERT_OK(err, "setsockopt - SO_REUSEPORT"))
238 		err = bind(test_case->servers[i],
241 		if (!ASSERT_OK(err, "bind"))
245 			err = setsockopt(test_case->servers[i], SOL_SOCKET,
248 			if (!ASSERT_OK(err,
252 			err = getsockname(test_case->servers[i],
255 			if (!ASSERT_OK(err, "getsockname"))
260 			err = setsockopt(test_case->servers[i],
263 			if (!ASSERT_OK(err, "setsockopt - TCP_FASTOPEN"))
269 			err = listen(test_case->servers[i], qlen);
270 			if (!ASSERT_OK(err, "listen"))
281 	int i, err;
292 		err = settimeo(test_case->clients[i], 100);
293 		if (!ASSERT_OK(err, "settimeo"))
299 			err = setsockopt(test_case->clients[i], IPPROTO_TCP,
302 			if (!ASSERT_OK(err,
307 		err = connect(test_case->clients[i],
310 		if (!ASSERT_OK(err, "connect"))
313 		err = write(test_case->clients[i], buf, MSGLEN);
314 		if (!ASSERT_EQ(err, MSGLEN, "write"))
324 	int i, err, migrated_to = MIGRATED_TO;
333 		err = bpf_map_update_elem(reuseport_map_fd, &i, &value,
335 		if (!ASSERT_OK(err, "bpf_map_update_elem - reuseport_map"))
338 		err = bpf_map_lookup_elem(reuseport_map_fd, &i, &value);
339 		if (!ASSERT_OK(err, "bpf_map_lookup_elem - reuseport_map"))
342 		err = bpf_map_update_elem(migrate_map_fd, &value, &migrated_to,
344 		if (!ASSERT_OK(err, "bpf_map_update_elem - migrate_map"))
353 	int i, err;
359 		err = shutdown(test_case->servers[i], SHUT_RDWR);
360 		if (!ASSERT_OK(err, "shutdown"))
381 	err = listen(test_case->servers[1], QLEN);
382 	if (!ASSERT_OK(err, "listen"))
390 	err = shutdown(test_case->servers[MIGRATED_TO], SHUT_RDWR);
391 	if (!ASSERT_OK(err, "shutdown"))
395 	err = listen(test_case->servers[MIGRATED_TO], QLEN);
396 	if (!ASSERT_OK(err, "listen"))
400 	err = shutdown(test_case->servers[1], SHUT_RDWR);
401 	if (!ASSERT_OK(err, "shutdown"))
412 	int err, cnt = 0, client;
415 	err = settimeo(test_case->servers[MIGRATED_TO], 4000);
416 	if (!ASSERT_OK(err, "settimeo"))
459 	int err, saved_len;
473 		err = setup_fastopen(buf, sizeof(buf), &saved_len, false);
474 		if (!ASSERT_OK(err, "setup_fastopen - setup"))
478 	err = start_servers(test_case, skel);
479 	if (!ASSERT_OK(err, "start_servers"))
486 		err = drop_ack(test_case, skel);
487 		if (!ASSERT_OK(err, "drop_ack"))
492 	err = start_clients(test_case);
493 	if (!ASSERT_OK(err, "start_clients"))
496 	err = listen(test_case->servers[MIGRATED_TO], QLEN);
497 	if (!ASSERT_OK(err, "listen"))
500 	err = update_maps(test_case, skel);
501 	if (!ASSERT_OK(err, "fill_maps"))
507 	err = migrate_dance(test_case);
508 	if (!ASSERT_OK(err, "migrate_dance"))
520 		err = pass_ack(test_case);
521 		if (!ASSERT_OK(err, "pass_ack"))
531 		err = pass_ack(test_case);
532 		ASSERT_OK(err, "pass_ack - clean up");
539 		err = setup_fastopen(buf, sizeof(buf), &saved_len, true);
540 		ASSERT_OK(err, "setup_fastopen - restore");