le-EV_CLOSED-issue-with-patch-from-issue-984.c

// endless loop for EV_CLOSED with the patch applied from
// https://github.com/libevent/libevent/issues/984

#include <event2/event.h>
#include <unistd.h>
#include <assert.h>
#include <sys/socket.h>

void readcb(int fd, short events, void *arg)
{
	printf("%s: fd=%i, events=%hi, EV_READ=%hi, EV_CLOSED=%hi\n",
		__func__, fd, events, events&EV_READ, events&EV_CLOSED);
}
void closecb(int fd, short events, void *arg)
{
	printf("%s: fd=%i, events=%hi, EV_READ=%hi, EV_CLOSED=%hi\n",
		__func__, fd, events, events&EV_READ, events&EV_CLOSED);
}

int main()
{
	int fd[2];
	struct event_base *base = event_base_new();
	struct event *ev1;
	struct event *ev2;

	assert(!socketpair(AF_UNIX, SOCK_STREAM, 0, fd));

	ev1 = event_new(base, fd[1], EV_READ, readcb, NULL);
	assert(ev1);
	ev2 = event_new(base, fd[1], EV_CLOSED|EV_ET, closecb, NULL);
	assert(ev2);

	//assert(!event_add(ev1, NULL));
	assert(!event_add(ev2, NULL));

	//event_active(ev2, EV_READ, 0);
	assert(!close(fd[0]));

	return event_base_dispatch(base);
}