Function test_reuse

test/submit-reuse.c:105–191

}

static int test_reuse(int argc, char *argv[], int split, int async)
{
	struct thread_data data;
	struct io_uring_params p = { };
	int fd1, fd2, ret, i;
	struct timeval tv;
	pthread_t thread;
	char *fname1 = ".reuse.1";
	int do_unlink = 1;
	void *tret;

	ret = io_uring_queue_init_params(32, &ring, &p);
	if (ret) {
		fprintf(stderr, "io_uring_queue_init: %d\n", ret);
		return 1;
	}

	if (!(p.features & IORING_FEAT_SUBMIT_STABLE)) {
		fprintf(stdout, "FEAT_SUBMIT_STABLE not there, skipping\n");
		io_uring_queue_exit(&ring);
		no_stable = 1;
		return 0;
	}

	if (argc > 1) {
		fname1 = argv[1];
		do_unlink = 0;
	} else {
		t_create_file(fname1, FILE_SIZE);
	}

	fd1 = open(fname1, O_RDONLY);
	if (do_unlink)
		unlink(fname1);
	if (fd1 < 0) {
		if (errno == EPERM || errno == EACCES)
			return T_EXIT_SKIP;
		perror("open fname1");
		goto err;
	}

	t_create_file(".reuse.2", FILE_SIZE);
	fd2 = open(".reuse.2", O_RDONLY);
	unlink(".reuse.2");
	if (fd2 < 0) {
		perror("open .reuse.2");
		goto err;
	}

	data.fd1 = fd1;
	data.fd2 = fd2;
	data.do_exit = 0;
	pthread_create(&thread, NULL, flusher, &data);
	usleep(10000);

	gettimeofday(&tv, NULL);
	for (i = 0; i < 1000; i++) {
		ret = prep(fd1, str1, split, async);