|
19 | 19 | #include <bpf/libbpf.h> |
20 | 20 |
|
21 | 21 | #include "cgroup_helpers.h" |
| 22 | +#include "network_helpers.h" |
22 | 23 | #include "testing_helpers.h" |
23 | 24 | #include "bpf_util.h" |
24 | 25 |
|
@@ -939,37 +940,6 @@ static int cmp_peer_addr(int sock1, const struct sockaddr_storage *addr2) |
939 | 940 | return cmp_sock_addr(getpeername, sock1, addr2, /*cmp_port*/ 1); |
940 | 941 | } |
941 | 942 |
|
942 | | -static int start_server(int type, const struct sockaddr_storage *addr, |
943 | | - socklen_t addr_len) |
944 | | -{ |
945 | | - int fd; |
946 | | - |
947 | | - fd = socket(addr->ss_family, type, 0); |
948 | | - if (fd == -1) { |
949 | | - log_err("Failed to create server socket"); |
950 | | - goto out; |
951 | | - } |
952 | | - |
953 | | - if (bind(fd, (const struct sockaddr *)addr, addr_len) == -1) { |
954 | | - log_err("Failed to bind server socket"); |
955 | | - goto close_out; |
956 | | - } |
957 | | - |
958 | | - if (type == SOCK_STREAM) { |
959 | | - if (listen(fd, 128) == -1) { |
960 | | - log_err("Failed to listen on server socket"); |
961 | | - goto close_out; |
962 | | - } |
963 | | - } |
964 | | - |
965 | | - goto out; |
966 | | -close_out: |
967 | | - close(fd); |
968 | | - fd = -1; |
969 | | -out: |
970 | | - return fd; |
971 | | -} |
972 | | - |
973 | 943 | static int connect_to_server(int type, const struct sockaddr_storage *addr, |
974 | 944 | socklen_t addr_len) |
975 | 945 | { |
@@ -1178,7 +1148,7 @@ static int run_bind_test_case(const struct sock_addr_test *test) |
1178 | 1148 | if (init_addrs(test, &requested_addr, &expected_addr, NULL)) |
1179 | 1149 | goto err; |
1180 | 1150 |
|
1181 | | - servfd = start_server(test->type, &requested_addr, addr_len); |
| 1151 | + servfd = start_server_addr(test->type, &requested_addr, addr_len, NULL); |
1182 | 1152 | if (servfd == -1) |
1183 | 1153 | goto err; |
1184 | 1154 |
|
@@ -1214,7 +1184,7 @@ static int run_connect_test_case(const struct sock_addr_test *test) |
1214 | 1184 | goto err; |
1215 | 1185 |
|
1216 | 1186 | /* Prepare server to connect to */ |
1217 | | - servfd = start_server(test->type, &expected_addr, addr_len); |
| 1187 | + servfd = start_server_addr(test->type, &expected_addr, addr_len, NULL); |
1218 | 1188 | if (servfd == -1) |
1219 | 1189 | goto err; |
1220 | 1190 |
|
@@ -1271,7 +1241,7 @@ static int run_xmsg_test_case(const struct sock_addr_test *test, int max_cmsg) |
1271 | 1241 | goto err; |
1272 | 1242 |
|
1273 | 1243 | /* Prepare server to sendmsg to */ |
1274 | | - servfd = start_server(test->type, &server_addr, addr_len); |
| 1244 | + servfd = start_server_addr(test->type, &server_addr, addr_len, NULL); |
1275 | 1245 | if (servfd == -1) |
1276 | 1246 | goto err; |
1277 | 1247 |
|
|
0 commit comments