Attachment 227040 Details for Bug 256952 – Test cases

Test cases

epoll_hup.c (text/plain), 2.69 KB, created by Vico on 2021-08-09 09:55:27 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Vico

Created: 2021-08-09 09:55:27 UTC

Size: 2.69 KB

patch

obsolete

>
>#include <assert.h>
>#include <stddef.h>
>#include <stdio.h>
>#include <errno.h>
>#include <signal.h>
>#include <stdlib.h>
>#include <stdint.h>
>#include <stdbool.h>
>#include <string.h>
>#include <fcntl.h>
>#include <sys/socket.h>
>#include <sys/un.h>
>#include <sys/epoll.h>
>#include <sys/signalfd.h>
>#include <sys/timerfd.h>
>#include <unistd.h>
>
>#include <pthread.h>
>
>
>static int
>set_cloexec_or_close(int fd)
>{
>	long flags;
>
>	if (fd == -1)
>		return -1;
>
>	flags = fcntl(fd, F_GETFD);
>	if (flags == -1)
>		goto err;
>
>	if (fcntl(fd, F_SETFD, flags | FD_CLOEXEC) == -1)
>		goto err;
>
>	return fd;
>
>err:
>	close(fd);
>	return -1;
>}
>
>static int
>wl_os_epoll_create_cloexec(void)
>{
>	int fd;
>
>	fd = epoll_create1(EPOLL_CLOEXEC);
>	if (fd >= 0)
>		return fd;
>	if (errno != EINVAL)
>		return -1;
>
>	fd = epoll_create(1);
>	return set_cloexec_or_close(fd);
>}
>
>int fds[2];
>int epoll_fd;
>
>static int
>setup_launcher_socket(void)
>{
>	if (socketpair(AF_LOCAL, SOCK_SEQPACKET, 0, fds) < 0) {
>		fprintf(stderr, "weston: socketpair failed: %s\n",
>			strerror(errno));
>		return -1;
>	}
>
>/*
>	if (fcntl(fds[0], F_SETFD, FD_CLOEXEC) < 0) {
>		fprintf(stderr, "weston: fcntl failed: %s\n",
>			strerror(errno));
>		return -1;
>	} */
>
>	return 0;
>}
>
>static void
>add_source()
>{
>	struct epoll_event ep;
>
>	memset(&ep, 0, sizeof ep);
>	//ep.events = EPOLLIN | EPOLLRDHUP;
>	ep.events = EPOLLRDHUP;
>	ep.data.fd = fds[0];
>
>	if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fds[0], &ep) < 0)
>		fprintf(stderr, "Failed add to epoll\n");
>}
>
>#define ARRAY_LENGTH(xx)	(sizeof(xx) / sizeof(xx[0]))
>
>static int
>wl_event_loop_dispatch()
>{
>	struct epoll_event ep[32];
>	int i, count, size = 0;
>	char buffer[1024];
>
>	count = epoll_wait(epoll_fd, ep, ARRAY_LENGTH(ep), -1);
>	//count = epoll_wait(epoll_fd, ep, ARRAY_LENGTH(ep), 3000);
>	fprintf(stderr, "count=%d\n", count);
>
>	if (count < 0)
>		return 0;
>
>	for (i = 0; i < count; i++) {
>
>		fprintf(stderr, "fd  eventmask %x  == fd=%d\n",
>			ep[i].events, ep[i].data.fd);
>
>		size = read(ep[i].data.fd, buffer, sizeof buffer);
>		fprintf(stderr, "read %d: %s\n", size, buffer);
>	}
>
>	return size;
>}
>
>static void *
>worker_thread_function(void *data)
>{
>#define hello "hello world\n"
>	char buffer[1000];
>	int l;
>
>
>	l = read(fds[1], buffer, sizeof(buffer));
>	fprintf(stderr, "%s:  read %d: %s\n", __func__, l, buffer);
>	write(fds[1], hello, sizeof hello);
>	sleep(3);
>	close(fds[1]);
>
>	return 0;
>}
>
>int
>main(int argc, char **argv)
>{
>	int times = 0;
>	char buffer[1024];
>	pthread_t tid;
>
>	epoll_fd = wl_os_epoll_create_cloexec();
>	setup_launcher_socket();
>
>	add_source();
>
>
>	do {
>		snprintf(buffer, sizeof buffer, "hellow orld%d\n", times++);
>		write(fds[0], buffer, strlen(buffer) + 1);
>
>		 pthread_create(&tid, NULL, worker_thread_function, 0);
>		 while (wl_event_loop_dispatch());
>	} while (0);
>}
>
>

Actions: View

Attachments on bug 256952: 226189 | 227028 | 227040 | 227065