X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Futil.cpp;h=623702dfc1546150222e5cab95209fe906c378a7;hb=8e831f9b2e461c94a8ee0e229812bcf2d42ae2a5;hp=1d0601aff93d632bc1838e98b186ec1d3d856b8d;hpb=cb5568e11bbe2d499d4d43dc30a779a5869b12ea;p=staging%2Fwindowmanager.git

diff --git a/src/util.cpp b/src/util.cpp
index 1d0601a..623702d 100644
--- a/src/util.cpp
+++ b/src/util.cpp
@@ -1,10 +1,12 @@
 #include "util.hpp"
 
-#include <errno.h>
-#include <stdarg.h>
-#include <stdio.h>
-#include <stdlib.h>
-#include <time.h>
+#include <cerrno>
+#include <cstdarg>
+#include <cstdio>
+#include <cstdlib>
+#include <ctime>
+
+#include <unistd.h>
 
 struct strftime_cache {
    time_t time;
@@ -15,7 +17,7 @@ static void log_(char const *log_type, FILE *stream, char const *fmt,
                  va_list args) {
    static struct strftime_cache strft;
 
-   time_t t = time(NULL);
+   time_t t = time(nullptr);
    if (t != strft.time) {
       strft.time = t;
       struct tm tm;
@@ -33,21 +35,21 @@ static void log_(char const *log_type, FILE *stream, char const *fmt,
    fputs("\n", stream);
 }
 
-void lognotice(char const *fmt, ...) {
+void lognotice(char const *fmt, ...) noexcept {
    va_list a;
    va_start(a, fmt);
    log_("notice", stdout, fmt, a);
    va_end(a);
 }
 
-void logerror(char const *fmt, ...) {
+void logerror(char const *fmt, ...) noexcept {
    va_list a;
    va_start(a, fmt);
    log_("error", stderr, fmt, a);
    va_end(a);
 }
 
-void fatal(char const *fmt, ...) {
+void fatal(char const *fmt, ...) noexcept {
    va_list a;
    va_start(a, fmt);
    log_("fatal", stderr, fmt, a);
@@ -56,10 +58,38 @@ void fatal(char const *fmt, ...) {
 }
 
 #ifdef DEBUG_OUTPUT
-void logdebug(char const *fmt, ...) {
+void logdebug(char const *fmt, ...) noexcept {
    va_list a;
    va_start(a, fmt);
    log_("debug", stdout, fmt, a);
    va_end(a);
 }
 #endif
+
+void Poller::add_fd(int fd, std::function<int(int)> handler) {
+   pfds.emplace_back(pollfd{.fd = fd, .events = POLLIN, .revents = 0});
+   handlers.emplace_back(std::move(handler));
+}
+
+int Poller::check_events() {
+   int ret = 0;
+   if ((ret = poll(this->pfds.data(), this->pfds.size(), -1)) != -1 &&
+       errno != EINTR) {
+      for (unsigned i = 0; i < pfds.size(); i++) {
+         if ((pfds[i].revents & POLLIN) != 0) {
+            if (handlers[i](pfds[i].fd) == -1) {
+               return -1;
+            }
+            pfds[i].revents = 0;
+            pfds[i].events = POLLIN;
+         }
+      }
+   }
+   return ret;
+}
+
+unique_fd::~unique_fd() {
+   if (this->fd != -1) {
+      close(this->fd);
+   }
+}