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