Rework of many things

Change-Id: Iadeba6f0602f7be017244c2602fae2bbe2abf74e
Signed-off-by: José Bollo <jose.bollo@iot.bzh>

1 files changed, 91 insertions, 0 deletions

diff --git a/src/pollitem.c b/src/pollitem.c
new file mode 100644
index 0000000..d183594
--- /dev/null
+++ b/src/pollitem.c
@@ -0,0 +1,91 @@
+/*
+ * Copyright (C) 2018 "IoT.bzh"
+ * Author José Bollo <jose.bollo@iot.bzh>
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <stdint.h>
+#include <sys/epoll.h>
+
+/*
+#include <stddef.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <stdarg.h>
+#include <string.h>
+#include <unistd.h>
+#include <fcntl.h>
+#include <errno.h>
+#include <poll.h>
+#include <limits.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+*/
+
+#include "pollitem.h"
+
+static
+int
+pollitem_do(
+	pollitem_t *pollitem,
+	uint32_t events,
+	int pollfd,
+	int op
+) {
+	struct epoll_event ev = { .events = events, .data.ptr = pollitem };
+	return epoll_ctl(pollfd, op, pollitem->fd, &ev);
+}
+
+int
+pollitem_add(
+	pollitem_t *pollitem,
+	uint32_t events,
+	int pollfd
+) {
+	return pollitem_do(pollitem, events, pollfd, EPOLL_CTL_ADD);
+}
+
+int
+pollitem_mod(
+	pollitem_t *pollitem,
+	uint32_t events,
+	int pollfd
+) {
+	return pollitem_do(pollitem, events, pollfd, EPOLL_CTL_MOD);
+}
+
+int
+pollitem_del(
+	pollitem_t *pollitem,
+	int pollfd
+) {
+	return pollitem_do(pollitem, 0, pollfd, EPOLL_CTL_DEL);
+}
+
+int
+pollitem_wait_dispatch(
+	int pollfd,
+	int timeout
+) {
+	int rc;
+	struct epoll_event ev;
+	pollitem_t *pi;
+
+	rc = epoll_wait(pollfd, &ev, 1, timeout);
+	if (rc == 1) {
+		pi = ev.data.ptr;
+		pi->handler(pi, ev.events, pollfd);
+	}
+	return rc;
+}