src: introduce helper API for creating GSource for socket

We need to be able to create event loop watches using the
GSource API for sockets. GIOChannel is able todo this, but
we don't want to use the GIOChannel APIs for reading/writing,
and testing shows just using its GSource APIs is unreliable
on Windows.

This patch thus creates a standalone helper API for creating
a GSource for a socket file descriptor. This impl is derived
from code in QEMU's io/channel-watch.c file that was written
by myself & Paolo Bonzini & thus under Red Hat copyright.

Reviewed-by: Pavel Hrdina <phrdina@redhat.com>
Signed-off-by: Daniel P. Berrangé <berrange@redhat.com>

1 files changed, 48 insertions, 0 deletions

diff --git a/src/util/vireventglibwatch.h b/src/util/vireventglibwatch.h
new file mode 100644
index 0000000000..2f7e61cfba
--- /dev/null
+++ b/src/util/vireventglibwatch.h
@@ -0,0 +1,48 @@
+/*
+ * vireventglibwatch.h: GSource impl for sockets
+ *
+ * Copyright (C) 2015-2020 Red Hat, Inc.
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library. If not, see
+ * <http://www.gnu.org/licenses/>.
+ */
+
+#pragma once
+
+#include "internal.h"
+
+/**
+ * virEventGLibCreateSocketWatch:
+ * @fd: the file descriptor
+ * @condition: the I/O condition
+ *
+ * Create a new main loop source that is able to
+ * monitor the file descriptor @fd for the
+ * I/O conditions in @condition.
+ *
+ * Returns: the new main loop source
+ */
+GSource *virEventGLibCreateSocketWatch(int fd,
+                                       GIOCondition condition);
+
+typedef gboolean (*virEventGLibSocketFunc)(int fd,
+                                           GIOCondition condition,
+                                           gpointer data);
+
+guint virEventGLibAddSocketWatch(int fd,
+                                 GIOCondition condition,
+                                 GMainContext *context,
+                                 virEventGLibSocketFunc func,
+                                 gpointer opaque,
+                                 GDestroyNotify notify);