Lines Matching refs:sk
40 int sk = socket(test_family, SOCK_STREAM, IPPROTO_TCP); in prepare_sk() local
42 if (sk < 0) in prepare_sk()
45 if (test_add_key(sk, DEFAULT_TEST_PASSWORD, this_ip_dest, in prepare_sk()
49 if (addr && test_add_key(sk, SECOND_PASSWORD, *addr, in prepare_sk()
53 return sk; in prepare_sk()
58 int sk = prepare_sk(addr, sndid, rcvid); in prepare_lsk() local
60 if (listen(sk, 10)) in prepare_lsk()
63 return sk; in prepare_lsk()
66 static int test_del_key(int sk, uint8_t sndid, uint8_t rcvid, bool async, in test_del_key() argument
89 err = setsockopt(sk, IPPROTO_TCP, TCP_AO_DEL_KEY, &del, sizeof(del)); in test_del_key()
97 err = test_get_one_ao(sk, &key, &sockaddr, sizeof(sockaddr), in test_del_key()
105 if (test_get_ao_info(sk, &ao_info)) in test_del_key()
114 static void try_delete_key(char *tst_name, int sk, uint8_t sndid, uint8_t rcvid, in try_delete_key() argument
120 err = test_del_key(sk, sndid, rcvid, async, current_key, rnext_key); in try_delete_key()
142 static int test_set_key(int sk, int current_keyid, int rnext_keyid) in test_set_key() argument
156 err = test_set_ao_info(sk, &ao_info); in test_set_key()
159 if (test_get_ao_info(sk, &ao_info)) in test_set_key()
168 static int test_add_current_rnext_key(int sk, const char *key, uint8_t keyflags, in test_add_current_rnext_key() argument
184 err = setsockopt(sk, IPPROTO_TCP, TCP_AO_ADD_KEY, &tmp, sizeof(tmp)); in test_add_current_rnext_key()
188 return test_verify_socket_key(sk, &tmp); in test_add_current_rnext_key()
191 static int __try_add_current_rnext_key(int sk, const char *key, uint8_t keyflags, in __try_add_current_rnext_key() argument
199 err = test_add_current_rnext_key(sk, key, keyflags, in_addr, prefix, in __try_add_current_rnext_key()
204 if (test_get_ao_info(sk, &ao_info)) in __try_add_current_rnext_key()
213 static void try_add_current_rnext_key(char *tst_name, int sk, const char *key, in try_add_current_rnext_key() argument
221 err = __try_add_current_rnext_key(sk, key, keyflags, in_addr, prefix, in try_add_current_rnext_key()
236 int sk; in check_closed_socket() local
238 sk = prepare_sk(&this_ip_dest, 200, 200); in check_closed_socket()
239 try_delete_key("closed socket, delete a key", sk, 200, 200, 0, -1, -1, 0); in check_closed_socket()
240 try_delete_key("closed socket, delete all keys", sk, 100, 100, 0, -1, -1, 0); in check_closed_socket()
241 close(sk); in check_closed_socket()
243 sk = prepare_sk(&this_ip_dest, 200, 200); in check_closed_socket()
244 if (test_set_key(sk, 100, 200)) in check_closed_socket()
246 try_delete_key("closed socket, delete current key", sk, 100, 100, 0, -1, -1, FAULT_BUSY); in check_closed_socket()
247 try_delete_key("closed socket, delete rnext key", sk, 200, 200, 0, -1, -1, FAULT_BUSY); in check_closed_socket()
248 close(sk); in check_closed_socket()
250 sk = prepare_sk(&this_ip_dest, 200, 200); in check_closed_socket()
251 if (test_add_key(sk, "Glory to heros!", this_ip_dest, in check_closed_socket()
254 if (test_add_key(sk, "Glory to Ukraine!", this_ip_dest, in check_closed_socket()
257 try_delete_key("closed socket, delete a key + set current/rnext", sk, 100, 100, 0, 10, 13, 0); in check_closed_socket()
258 try_delete_key("closed socket, force-delete current key", sk, 10, 11, 0, 200, -1, 0); in check_closed_socket()
259 try_delete_key("closed socket, force-delete rnext key", sk, 12, 13, 0, -1, 200, 0); in check_closed_socket()
260 try_delete_key("closed socket, delete current+rnext key", sk, 200, 200, 0, -1, -1, FAULT_BUSY); in check_closed_socket()
261 close(sk); in check_closed_socket()
263 sk = prepare_sk(&this_ip_dest, 200, 200); in check_closed_socket()
264 if (test_set_key(sk, 100, 200)) in check_closed_socket()
267 sk, "Laaaa! Lalala-la-la-lalala...", 0, in check_closed_socket()
271 sk, "Laaaa! Lalala-la-la-lalala...", 0, in check_closed_socket()
274 close(sk); in check_closed_socket()
277 static void assert_no_current_rnext(const char *tst_msg, int sk) in assert_no_current_rnext() argument
281 if (test_get_ao_info(sk, &ao_info)) in assert_no_current_rnext()
299 int sk, err; in assert_no_tcp_repair() local
301 sk = prepare_sk(&this_ip_dest, 200, 200); in assert_no_tcp_repair()
302 test_enable_repair(sk); in assert_no_tcp_repair()
303 if (listen(sk, 10)) in assert_no_tcp_repair()
306 err = getsockopt(sk, SOL_TCP, TCP_AO_REPAIR, &ao_img, &len); in assert_no_tcp_repair()
312 err = setsockopt(sk, SOL_TCP, TCP_AO_REPAIR, &ao_img, sizeof(ao_img)); in assert_no_tcp_repair()
317 close(sk); in assert_no_tcp_repair()
322 int sk, err; in check_listen_socket() local
324 sk = prepare_lsk(&this_ip_dest, 200, 200); in check_listen_socket()
325 try_delete_key("listen socket, delete a key", sk, 200, 200, 0, -1, -1, 0); in check_listen_socket()
326 try_delete_key("listen socket, delete all keys", sk, 100, 100, 0, -1, -1, 0); in check_listen_socket()
327 close(sk); in check_listen_socket()
329 sk = prepare_lsk(&this_ip_dest, 200, 200); in check_listen_socket()
330 err = test_set_key(sk, 100, -1); in check_listen_socket()
335 err = test_set_key(sk, -1, 200); in check_listen_socket()
340 close(sk); in check_listen_socket()
342 sk = prepare_sk(&this_ip_dest, 200, 200); in check_listen_socket()
343 if (test_set_key(sk, 100, 200)) in check_listen_socket()
345 if (listen(sk, 10)) in check_listen_socket()
347 assert_no_current_rnext("listen() after current/rnext keys set", sk); in check_listen_socket()
348 …try_delete_key("listen socket, delete current key from before listen()", sk, 100, 100, 0, -1, -1, … in check_listen_socket()
349 …try_delete_key("listen socket, delete rnext key from before listen()", sk, 200, 200, 0, -1, -1, FA… in check_listen_socket()
350 close(sk); in check_listen_socket()
354 sk = prepare_lsk(&this_ip_dest, 200, 200); in check_listen_socket()
355 if (test_add_key(sk, "Glory to heros!", this_ip_dest, in check_listen_socket()
358 if (test_add_key(sk, "Glory to Ukraine!", this_ip_dest, in check_listen_socket()
361 try_delete_key("listen socket, delete a key + set current/rnext", sk, in check_listen_socket()
363 try_delete_key("listen socket, force-delete current key", sk, in check_listen_socket()
365 try_delete_key("listen socket, force-delete rnext key", sk, in check_listen_socket()
367 try_delete_key("listen socket, delete a key", sk, in check_listen_socket()
369 close(sk); in check_listen_socket()
371 sk = prepare_lsk(&this_ip_dest, 200, 200); in check_listen_socket()
373 sk, "Laaaa! Lalala-la-la-lalala...", 0, in check_listen_socket()
377 sk, "Laaaa! Lalala-la-la-lalala...", 0, in check_listen_socket()
380 close(sk); in check_listen_socket()
521 static int test_add_key_cr(int sk, const char *pwd, unsigned int pwd_len, in test_add_key_cr() argument
542 err = setsockopt(sk, IPPROTO_TCP, TCP_AO_ADD_KEY, &tmp, sizeof(tmp)); in test_add_key_cr()
546 return test_verify_socket_key(sk, &tmp); in test_add_key_cr()
549 static void verify_current_rnext(const char *tst, int sk, in verify_current_rnext() argument
554 if (test_get_ao_info(sk, &ao_info)) in verify_current_rnext()
583 int sk; in key_collection_socket() local
586 sk = test_listen_socket(this_ip_addr, port, 1); in key_collection_socket()
588 sk = socket(test_family, SOCK_STREAM, IPPROTO_TCP); in key_collection_socket()
589 if (sk < 0) in key_collection_socket()
616 if (test_add_key_cr(sk, key->password, key->len, in key_collection_socket()
628 return sk; in key_collection_socket()
679 static void verify_keys(const char *tst_name, int sk, in verify_keys() argument
694 if (getsockopt(sk, IPPROTO_TCP, TCP_AO_GET_KEYS, keys, &len)) { in verify_keys()
799 int sk, lsk; in start_server() local
809 sk = accept(lsk, NULL, NULL); in start_server()
810 if (sk < 0) in start_server()
812 if (test_get_tcp_counters(sk, begin)) in start_server()
821 bytes = test_server_run(sk, quota, TEST_TIMEOUT_SEC); in start_server()
829 return sk; in start_server()
832 static void end_server(const char *tst_name, int sk, in end_server() argument
837 if (test_get_tcp_counters(sk, &end)) in end_server()
839 verify_keys(tst_name, sk, false, true); in end_server()
842 close(sk); in end_server()
852 int sk; in try_server_run() local
854 sk = start_server(tst_name, port, quota, &tmp, in try_server_run()
856 end_server(tst_name, sk, &tmp); in try_server_run()
865 int sk; in server_rotations() local
867 sk = start_server(tst_name, port, quota, &tmp, in server_rotations()
875 bytes = test_server_run(sk, quota, TEST_TIMEOUT_SEC); in server_rotations()
880 verify_current_rnext(tst_name, sk, in server_rotations()
884 end_server(tst_name, sk, &tmp); in server_rotations()
892 int sk; in run_client() local
895 sk = key_collection_socket(false, port); in run_client()
904 if (test_set_key(sk, sndid, rcvid)) in run_client()
907 if (before && test_get_tcp_counters(sk, before)) in run_client()
911 if (test_connect_socket(sk, this_ip_dest, port++) <= 0) in run_client()
921 if (test_client_verify(sk, msg_sz, msg_nr)) { in run_client()
923 close(sk); in run_client()
929 return sk; in run_client()
944 static void end_client(const char *tst_name, int sk, unsigned int nr_keys, in end_client() argument
955 verify_current_rnext(tst_name, sk, in end_client()
958 if (start && test_get_tcp_counters(sk, &end)) in end_client()
960 verify_keys(tst_name, sk, false, false); in end_client()
962 close(sk); in end_client()
968 static void try_unmatched_keys(int sk, int *rnext_index, unsigned int port) in try_unmatched_keys() argument
982 err = test_add_key_cr(sk, key->password, key->len, wrong_addr, in try_unmatched_keys()
994 err = test_add_key_cr(sk, key->password, key->len, this_ip_dest, in try_unmatched_keys()
1014 if (test_set_key(sk, -1, key->server_keyid)) in try_unmatched_keys()
1019 if (test_client_verify(sk, msg_len, nr_packets)) in try_unmatched_keys()
1052 int sk; in check_current_back() local
1054 sk = start_client(tst_name, port, nr_keys, current_index, rnext_index, in check_current_back()
1056 if (sk < 0) in check_current_back()
1058 if (test_set_key(sk, collection.keys[rotate_to_index].client_keyid, -1)) in check_current_back()
1064 if (test_client_verify(sk, msg_len, nr_packets)) in check_current_back()
1077 end_client(tst_name, sk, nr_keys, current_index, rnext_index, &tmp); in check_current_back()
1086 int sk; in roll_over_keys() local
1088 sk = start_client(tst_name, port, nr_keys, current_index, rnext_index, in roll_over_keys()
1090 if (sk < 0) in roll_over_keys()
1100 if (test_set_key(sk, -1, collection.keys[i].server_keyid)) in roll_over_keys()
1102 if (test_client_verify(sk, msg_len, nr_packets)) { in roll_over_keys()
1104 close(sk); in roll_over_keys()
1108 verify_current_rnext(tst_name, sk, -1, in roll_over_keys()
1113 end_client(tst_name, sk, nr_keys, current_index, rnext_index, &tmp); in roll_over_keys()
1120 int sk; in try_client_run() local
1122 sk = start_client(tst_name, port, nr_keys, current_index, rnext_index, in try_client_run()
1124 if (sk < 0) in try_client_run()
1126 end_client(tst_name, sk, nr_keys, current_index, rnext_index, &tmp); in try_client_run()
1133 int sk; in try_client_match() local
1135 sk = client_non_matching(tst_name, port, nr_keys, current_index, in try_client_match()
1137 if (sk < 0) in try_client_match()
1139 try_unmatched_keys(sk, &rnext_index, port); in try_client_match()
1140 end_client(tst_name, sk, nr_keys, current_index, rnext_index, NULL); in try_client_match()