|
Packit |
d3489f |
/* SPDX-License-Identifier: MIT */
|
|
Packit |
d3489f |
/*
|
|
Packit |
d3489f |
* Check that IORING_OP_CONNECT works, with and without other side
|
|
Packit |
d3489f |
* being open.
|
|
Packit |
d3489f |
*/
|
|
Packit |
d3489f |
#include <stdio.h>
|
|
Packit |
d3489f |
#include <stdlib.h>
|
|
Packit |
d3489f |
#include <string.h>
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
#include <errno.h>
|
|
Packit |
d3489f |
#include <fcntl.h>
|
|
Packit |
d3489f |
#include <unistd.h>
|
|
Packit |
d3489f |
#include <poll.h>
|
|
Packit |
d3489f |
#include <sys/socket.h>
|
|
Packit |
d3489f |
#include <netinet/in.h>
|
|
Packit |
d3489f |
#include <netinet/tcp.h>
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
#include "liburing.h"
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int create_socket(void)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
int fd;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
|
|
Packit |
d3489f |
if (fd == -1) {
|
|
Packit |
d3489f |
perror("socket()");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
return fd;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int submit_and_wait(struct io_uring *ring, int *res)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
struct io_uring_cqe *cqe;
|
|
Packit |
d3489f |
int ret;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = io_uring_submit_and_wait(ring, 1);
|
|
Packit |
d3489f |
if (ret != 1) {
|
|
Packit |
d3489f |
fprintf(stderr, "io_using_submit: got %d\n", ret);
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = io_uring_peek_cqe(ring, &cqe);
|
|
Packit |
d3489f |
if (ret) {
|
|
Packit |
d3489f |
fprintf(stderr, "io_uring_peek_cqe(): no cqe returned");
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
*res = cqe->res;
|
|
Packit |
d3489f |
io_uring_cqe_seen(ring, cqe);
|
|
Packit |
d3489f |
return 0;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int wait_for(struct io_uring *ring, int fd, int mask)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
struct io_uring_sqe *sqe;
|
|
Packit |
d3489f |
int ret, res;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
sqe = io_uring_get_sqe(ring);
|
|
Packit |
d3489f |
if (!sqe) {
|
|
Packit |
d3489f |
fprintf(stderr, "unable to get sqe\n");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
io_uring_prep_poll_add(sqe, fd, mask);
|
|
Packit |
d3489f |
sqe->user_data = 2;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = submit_and_wait(ring, &res;;
|
|
Packit |
d3489f |
if (ret)
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
if (res < 0) {
|
|
Packit |
d3489f |
fprintf(stderr, "poll(): failed with %d\n", res);
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
return res;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int listen_on_socket(int fd)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
struct sockaddr_in addr;
|
|
Packit |
d3489f |
int ret;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
memset(&addr, 0, sizeof(addr));
|
|
Packit |
d3489f |
addr.sin_family = AF_INET;
|
|
Packit |
d3489f |
addr.sin_port = 0x1234;
|
|
Packit |
d3489f |
addr.sin_addr.s_addr = 0x0100007fU;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = bind(fd, (struct sockaddr*)&addr, sizeof(addr));
|
|
Packit |
d3489f |
if (ret == -1) {
|
|
Packit |
d3489f |
perror("bind()");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = listen(fd, 128);
|
|
Packit |
d3489f |
if (ret == -1) {
|
|
Packit |
d3489f |
perror("listen()");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
return 0;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int connect_socket(struct io_uring *ring, int fd, int *code)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
struct io_uring_sqe *sqe;
|
|
Packit |
d3489f |
struct sockaddr_in addr;
|
|
Packit |
d3489f |
int ret, res, val = 1;
|
|
Packit |
d3489f |
socklen_t code_len = sizeof(*code);
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = setsockopt(fd, SOL_SOCKET, SO_REUSEPORT, &val, sizeof(val));
|
|
Packit |
d3489f |
if (ret == -1) {
|
|
Packit |
d3489f |
perror("setsockopt()");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = setsockopt(fd, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(val));
|
|
Packit |
d3489f |
if (ret == -1) {
|
|
Packit |
d3489f |
perror("setsockopt()");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
memset(&addr, 0, sizeof(addr));
|
|
Packit |
d3489f |
addr.sin_family = AF_INET;
|
|
Packit |
d3489f |
addr.sin_port = 0x1234;
|
|
Packit |
d3489f |
addr.sin_addr.s_addr = 0x0100007fU;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
sqe = io_uring_get_sqe(ring);
|
|
Packit |
d3489f |
if (!sqe) {
|
|
Packit |
d3489f |
fprintf(stderr, "unable to get sqe\n");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
io_uring_prep_connect(sqe, fd, (struct sockaddr*)&addr, sizeof(addr));
|
|
Packit |
d3489f |
sqe->user_data = 1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = submit_and_wait(ring, &res;;
|
|
Packit |
d3489f |
if (ret)
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
if (res == -EINPROGRESS) {
|
|
Packit |
d3489f |
ret = wait_for(ring, fd, POLLOUT | POLLHUP | POLLERR);
|
|
Packit |
d3489f |
if (ret == -1)
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
int ev = (ret & POLLOUT) || (ret & POLLHUP) || (ret & POLLERR);
|
|
Packit |
d3489f |
if (!ev) {
|
|
Packit |
d3489f |
fprintf(stderr, "poll(): returned invalid value %#x\n", ret);
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = getsockopt(fd, SOL_SOCKET, SO_ERROR, code, &code_len);
|
|
Packit |
d3489f |
if (ret == -1) {
|
|
Packit |
d3489f |
perror("getsockopt()");
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
} else
|
|
Packit |
d3489f |
*code = res;
|
|
Packit |
d3489f |
return 0;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int test_connect_with_no_peer(struct io_uring *ring)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
int connect_fd;
|
|
Packit |
d3489f |
int ret, code;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
connect_fd = create_socket();
|
|
Packit |
d3489f |
if (connect_fd == -1)
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = connect_socket(ring, connect_fd, &code);
|
|
Packit |
d3489f |
if (ret == -1)
|
|
Packit |
d3489f |
goto err;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
if (code != -ECONNREFUSED) {
|
|
Packit |
d3489f |
fprintf(stderr, "connect failed with %d\n", code);
|
|
Packit |
d3489f |
goto err;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
close(connect_fd);
|
|
Packit |
d3489f |
return 0;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
err:
|
|
Packit |
d3489f |
close(connect_fd);
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
static int test_connect(struct io_uring *ring)
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
int accept_fd;
|
|
Packit |
d3489f |
int connect_fd;
|
|
Packit |
d3489f |
int ret, code;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
accept_fd = create_socket();
|
|
Packit |
d3489f |
if (accept_fd == -1)
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = listen_on_socket(accept_fd);
|
|
Packit |
d3489f |
if (ret == -1)
|
|
Packit |
d3489f |
goto err1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
connect_fd = create_socket();
|
|
Packit |
d3489f |
if (connect_fd == -1)
|
|
Packit |
d3489f |
goto err1;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = connect_socket(ring, connect_fd, &code);
|
|
Packit |
d3489f |
if (ret == -1)
|
|
Packit |
d3489f |
goto err2;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
if (code != 0) {
|
|
Packit |
d3489f |
fprintf(stderr, "connect failed with %d\n", code);
|
|
Packit |
d3489f |
goto err2;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
close(connect_fd);
|
|
Packit |
d3489f |
close(accept_fd);
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
return 0;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
err2:
|
|
Packit |
d3489f |
close(connect_fd);
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
err1:
|
|
Packit |
d3489f |
close(accept_fd);
|
|
Packit |
d3489f |
return -1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
int main(int argc, char *argv[])
|
|
Packit |
d3489f |
{
|
|
Packit |
d3489f |
struct io_uring ring;
|
|
Packit |
d3489f |
int ret;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
if (argc > 1)
|
|
Packit |
d3489f |
return 0;
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = io_uring_queue_init(8, &ring, 0);
|
|
Packit |
d3489f |
if (ret) {
|
|
Packit |
d3489f |
fprintf(stderr, "io_uring_queue_setup() = %d\n", ret);
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = test_connect_with_no_peer(&ring);
|
|
Packit |
d3489f |
if (ret == -1) {
|
|
Packit |
d3489f |
fprintf(stderr, "test_connect_with_no_peer(): failed\n");
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
ret = test_connect(&ring);
|
|
Packit |
d3489f |
if (ret == -1) {
|
|
Packit |
d3489f |
fprintf(stderr, "test_connect(): failed\n");
|
|
Packit |
d3489f |
return 1;
|
|
Packit |
d3489f |
}
|
|
Packit |
d3489f |
|
|
Packit |
d3489f |
io_uring_queue_exit(&ring);
|
|
Packit |
d3489f |
return 0;
|
|
Packit |
d3489f |
}
|