catalinux / Conn (public) (License: LGPLv2) (since 2016-03-01) (hash sha1)
Net library for easy building ipv4/ipv6 network daemons/clients

/Conn_engine_poll.c (cdb9ad643a95b8777c608ef1ca8de10a3599ed4a) (2699 bytes) (mode 100644) (type blob)

#include <Conn_config.h>

#ifdef POLL_FOUND

#include <Conn_engine_poll.h>

/*
 * Variables
 */
static unsigned long	Conn_poll_allocated_slots = 0;
static struct pollfd	*Conn_poll_pfds = NULL;

/*
 * Functions
 */

/*
 * Init the engine
 */
int Conn_poll_init(void)
{
	return 0;
}

int Conn_poll_shutdown(void)
{
	free(Conn_poll_pfds);

	return 0;
}

/*
 * Grow the number of slots needed for poll
 */
int Conn_poll_grow(unsigned int alloc)
{
	struct pollfd *p, *set;
	unsigned int diff, mem;

	Log(10, "%s: Trying to grow pollfds from %d to %d.\n",
		__FUNCTION__,
		Conn_poll_allocated_slots, alloc);

	if (alloc <= Conn_poll_allocated_slots)
		return 0;

	diff = alloc - Conn_poll_allocated_slots;

	mem = alloc * sizeof(struct pollfd);
	p = (struct pollfd *) realloc(Conn_poll_pfds, mem);
	if (p == NULL) {
		snprintf(Conn_error, sizeof(Conn_error),
			"Cannot alloc %u bytes for pollfds.", mem);
		return -1;
	}

	set = p + Conn_poll_allocated_slots;
	memset(set, 0, diff * sizeof(struct pollfd));
	Conn_poll_pfds = p;

	return 0;
}

/*
 * Add a target to the list
 */
int Conn_poll_add_obj(struct Conn *C)
{
	Conn_poll_pfds[C->slot].fd = C->fd;
	Conn_poll_pfds[C->slot].events = C->events;

	return 0;
}

/*
 * Remove a target from the list
 */
int Conn_poll_del_obj(struct Conn *C)
{
	Conn_poll_pfds[C->slot].fd = -1;
	Conn_poll_pfds[C->slot].events = 0;

	return 0;
}

/*
 * Change event mask
 */
int Conn_poll_chg_obj(struct Conn *C)
{
	Conn_poll_pfds[C->slot].events = C->events;

	return 0;
}


/*
 * Calls a callback for fds with activity
 * Returns: -1 on error, 0 nothing to do, n (>0) if some work was done
 * timeout is in 1/1000 seconds increments.
 */
int Conn_poll_poll(const int timeout2, void (*cb)(const unsigned int slot,
	const int revents))
{
	int slot, events;

	again:
	events = poll(&Conn_poll_pfds[0], Conn_no, timeout2);
	if ((events == -1) && (errno == EINTR))
		goto again;

	if (events < 0) {
		snprintf(Conn_error, sizeof(Conn_error),
			"%s: Conn_no=%d [%s]",
			__FUNCTION__, Conn_no,
			strerror(errno));
		return -1;
	}

	gettimeofday(&Conn_now, NULL);

	if (events == 0)
		return 0;

	/* We do revers scan because of moving Conn objects */
	Log(11, "Processing %d event(s)...\n",
		events);
	slot = Conn_no - 1;
	do {
		if (Conn_poll_pfds[slot].revents & POLLNVAL) {
			Log(0, "BUG NVAL!\n");
			exit(1);
		}

		cb(slot, Conn_poll_pfds[slot].revents);

		slot--;
	} while (slot >= 0);

	return events;

}

/*
 * Move a slot over an other.
 */
int Conn_poll_move_slot(const unsigned int dst, const unsigned int src)
{
	struct pollfd tmp;

	tmp = Conn_poll_pfds[dst];
	Conn_poll_pfds[dst] = Conn_poll_pfds[src];
	Conn_poll_pfds[src] = tmp;

	return 0;
}

#endif


Mode Type Size Ref File
100644 blob 70 9964a59b5d89f394cc4250ed6d6ce67a5f0cd196 .gitignore
100644 blob 1945 fecf0e7a7e8580485101a179685aedc7e00affbb Changelog.pre109
100644 blob 32589 ce307c8127733a93d036be69555ce39f5d5c0a6d Conn.c
100644 blob 1470 afedf88dd9c3b275e9c7d83d6572c2fcce60e50b Conn.h
100644 blob 726 64b1bad93a84f87c3e93fc24ac5341db691ea578 Conn.spec.in
100644 blob 66 68138d781ca754b15e14c687da91ee261b2c41f3 Conn_config.h.in
100644 blob 30551 727bb838714a57b5005fb74de778a09b644c1250 Conn_engine_core.c
100644 blob 9204 f975897b64a208c33f380addd293832ff2fd24f6 Conn_engine_core.h
100644 blob 3661 999f465eb29de894b978bf8c5f200acc4c1e21b8 Conn_engine_epoll.c
100644 blob 610 b8597ef7043fa9b6ccd58c0f484f040e8621cc95 Conn_engine_epoll.h
100644 blob 2699 cdb9ad643a95b8777c608ef1ca8de10a3599ed4a Conn_engine_poll.c
100644 blob 597 183f7af0b0688200fa8f69527c03ee075c83df12 Conn_engine_poll.h
100644 blob 30 d987fa5df957830331139935d517009e2911b0cf INSTALL
100644 blob 25275 92b8903ff3fea7f49ef5c041b67a087bca21c5ec LICENSE
100644 blob 1311 3c820df3b36b4bc844c52bc8c7e86f7843b67bb6 Makefile.in
100644 blob 192 5b11bdfb23857d8588845465aef993b320596b44 README
100644 blob 2078 1425b11d02e3cd49be474d575a03d0698ce37228 TODO
100755 blob 23 d33bb6c4ecdce1390ce1db3c79ea3b93e22ea755 configure
040000 tree - d4c9c4a69c5cfa2a84316967185f1661b6817779 docs
100755 blob 10910 8fcd88850fe239f609c0d7bb7e09f5b9f853f1b2 duilder
100644 blob 276 1c2b695f44e694e60ac10db747d5c9093472859c duilder.conf
040000 tree - 44bbe0aba6bc0116534b304ab4a5446f282649c8 examples
040000 tree - 751693d0803f700dd060788cc9383aa24b472267 tests
Hints:
Before first commit, do not forget to setup your git environment:
git config --global user.name "your_name_here"
git config --global user.email "your@email_here"

Clone this repository using HTTP(S):
git clone https://rocketgit.com/user/catalinux/Conn

Clone this repository using ssh (do not forget to upload a key first):
git clone ssh://rocketgit@ssh.rocketgit.com/user/catalinux/Conn

Clone this repository using git:
git clone git://git.rocketgit.com/user/catalinux/Conn

You are allowed to anonymously push to this repository.
This means that your pushed commits will automatically be transformed into a merge request:
... clone the repository ...
... make some changes and some commits ...
git push origin main