tools/testing/selftests/bpf/map_tests/sk_storage_map.c

166

int i, map_fd, err, *sk_fds;

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

168

sk_fds = malloc(sizeof(*sk_fds) * nr_sk_per_thread);

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

169

if (!sk_fds) {

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

175

sk_fds[i] = -1;

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

183

sk_fds[i] = socket(AF_INET6, SOCK_STREAM, 0);

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

184

if (sk_fds[i] == -1) {

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

189

err = bpf_map_update_elem(map_fd, &sk_fds[i], &value,

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

205

close(sk_fds[i]);

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

206

sk_fds[i] = -1;

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

212

free(sk_fds);

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

216

for (i = 0; i < nr_sk_per_thread && sk_fds[i] != -1; i++)

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

217

close(sk_fds[i]);

tools/testing/selftests/bpf/map_tests/sk_storage_map.c

218

free(sk_fds);

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

36

static int sk_fds[REUSEPORT_ARRAY_SIZE];

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

419

srv_fd = sk_fds[ev.data.u32];

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

541

err = setsockopt(sk_fds[0], SOL_SOCKET, SO_DETACH_REUSEPORT_BPF,

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

546

err = setsockopt(sk_fds[1], SOL_SOCKET, SO_DETACH_REUSEPORT_BPF,

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

603

sk_fds[i] = socket(family, type, 0);

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

604

RET_IF(sk_fds[i] == -1, "socket()", "sk_fds[%d]:%d errno:%d\n",

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

605

i, sk_fds[i], errno);

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

606

err = setsockopt(sk_fds[i], SOL_SOCKET, SO_REUSEPORT,

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

613

err = setsockopt(sk_fds[i], SOL_SOCKET,

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

621

err = bind(sk_fds[i], (struct sockaddr *)&srv_sa, addrlen);

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

626

err = listen(sk_fds[i], 10);

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

632

err = bpf_map_update_elem(reuseport_array, &i, &sk_fds[i],

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

640

err = getsockname(sk_fds[i], (struct sockaddr *)&srv_sa,

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

654

err = epoll_ctl(epfd, EPOLL_CTL_ADD, sk_fds[i], &ev);

tools/testing/selftests/bpf/prog_tests/select_reuseport.c

697

close(sk_fds[i]);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

102

sk_fds->active_fd = fastopen_connect(sk_fds->srv_fd, fast,

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

105

sk_fds->active_fd = connect_to_fd(sk_fds->srv_fd, 0);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

107

if (!ASSERT_NEQ(sk_fds->active_fd, -1, "")) {

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

108

close(sk_fds->srv_fd);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

113

if (!ASSERT_OK(getsockname(sk_fds->srv_fd, (struct sockaddr *)&addr6,

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

116

sk_fds->passive_lport = ntohs(addr6.sin6_port);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

119

if (!ASSERT_OK(getsockname(sk_fds->active_fd, (struct sockaddr *)&addr6,

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

122

sk_fds->active_lport = ntohs(addr6.sin6_port);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

124

sk_fds->passive_fd = accept(sk_fds->srv_fd, NULL, 0);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

125

if (!ASSERT_NEQ(sk_fds->passive_fd, -1, "accept(srv_fd)"))

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

132

ret = read(sk_fds->passive_fd, bytes_in, sizeof(bytes_in));

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

134

close(sk_fds->passive_fd);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

142

close(sk_fds->active_fd);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

143

close(sk_fds->srv_fd);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

146

memset(sk_fds, -1, sizeof(*sk_fds));

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

181

static int check_error_linum(const struct sk_fds *sk_fds)

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

187

lport = sk_fds->passive_lport;

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

195

lport = sk_fds->active_lport;

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

206

static void check_hdr_and_close_fds(struct sk_fds *sk_fds)

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

213

if (sk_fds_shutdown(sk_fds))

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

220

if (check_hdr_stg(&exp_passive_hdr_stg, sk_fds->passive_fd,

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

224

if (check_hdr_stg(&exp_active_hdr_stg, sk_fds->active_fd,

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

244

ASSERT_FALSE(check_error_linum(sk_fds), "check_error_linum");

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

245

sk_fds_close(sk_fds);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

298

struct sk_fds sk_fds;

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

323

if (sk_fds_connect(&sk_fds, true)) {

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

328

check_hdr_and_close_fds(&sk_fds);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

335

struct sk_fds sk_fds;

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

367

if (sk_fds_connect(&sk_fds, false)) {

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

372

check_hdr_and_close_fds(&sk_fds);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

379

struct sk_fds sk_fds;

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

399

if (sk_fds_connect(&sk_fds, false)) {

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

404

check_hdr_and_close_fds(&sk_fds);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

411

struct sk_fds sk_fds;

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

438

if (sk_fds_connect(&sk_fds, false)) {

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

443

check_hdr_and_close_fds(&sk_fds);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

463

struct sk_fds sk_fds;

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

475

if (sk_fds_connect(&sk_fds, false)) {

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

482

ret = send(sk_fds.active_fd, send_msg, sizeof(send_msg),

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

487

ret = read(sk_fds.passive_fd, recv_msg, sizeof(recv_msg));

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

492

if (sk_fds_shutdown(&sk_fds))

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

511

ASSERT_FALSE(check_error_linum(&sk_fds), "check_error_linum");

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

512

sk_fds_close(&sk_fds);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

67

static void sk_fds_close(struct sk_fds *sk_fds)

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

69

close(sk_fds->srv_fd);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

70

close(sk_fds->passive_fd);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

71

close(sk_fds->active_fd);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

74

static int sk_fds_shutdown(struct sk_fds *sk_fds)

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

78

shutdown(sk_fds->active_fd, SHUT_WR);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

79

ret = read(sk_fds->passive_fd, &abyte, sizeof(abyte));

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

83

shutdown(sk_fds->passive_fd, SHUT_WR);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

84

ret = read(sk_fds->active_fd, &abyte, sizeof(abyte));

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

91

static int sk_fds_connect(struct sk_fds *sk_fds, bool fast_open)

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

97

sk_fds->srv_fd = start_server(AF_INET6, SOCK_STREAM, LO_ADDR6, 0, 0);

tools/testing/selftests/bpf/prog_tests/tcp_hdr_options.c

98

if (!ASSERT_NEQ(sk_fds->srv_fd, -1, "start_server"))