Function sender

test/napi-test.c:40–100

}

static int sender(int queue_flags)
{
	unsigned long long written = 0;
	struct sockaddr_in addr;
	struct io_uring ring;
	int i, ret, fd;

	/*
	 * Sender doesn't use the ring, but try and set one up with the same
	 * flags that the receiver will use. If that fails, we know the
	 * receiver will have failed too - just skip the test in that case.
	 */
	ret = io_uring_queue_init(1, &ring, queue_flags);
	if (ret)
		return T_EXIT_SKIP;
	io_uring_queue_exit(&ring);

	memset(&addr, 0, sizeof(addr));
	addr.sin_family = AF_INET;
	addr.sin_port = htons(port);
	ret = inet_pton(AF_INET, receiver_address, &addr.sin_addr);
	assert(ret == 1);

	fd = socket(PF_INET, SOCK_STREAM, 0);
	assert(fd >= 0);

	/* don't race with receiver, give it 1 second to connect */
	i = 0;
	do {
		ret = connect(fd, (void *)&addr, sizeof(addr));
		if (!ret)
			break;
		if (ret == -1 && errno == ECONNREFUSED) {
			if (i >= 10000) {
				fprintf(stderr, "Gave up trying to connect\n");
				return 1;
			}
			usleep(100);
			continue;
		}
		i++;
	} while (1);

	while (written < 8 * 1024 * 1024) {
		for (i = 0; i < BUF_SIZE; i++)
			buffer[i] = current_byte + i;

		ret = write(fd, buffer, BUF_SIZE);
		if (ret <= 0) {
			if (!ret || errno == ECONNRESET)
				break;
			fprintf(stderr, "write failed %i %i\n", ret, errno);
			return 1;
		}
		written += ret;
		current_byte += ret;
	}