1 files changed, 109 insertions, 0 deletions
diff --git a/libsoup/soup-message-io-source.c b/libsoup/soup-message-io-source.c
new file mode 100644
index 00000000..d26cb080
--- /dev/null
+++ b/libsoup/soup-message-io-source.c
@@ -0,0 +1,109 @@
+
+/* soup-message-io-source.c
+ *
+ * Copyright 2020 Igalia S.L.
+ *
+ * This file 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 3 of the
+ * License, or (at your option) any later version.
+ *
+ * This file 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 program.  If not, see <http://www.gnu.org/licenses/>.
+ *
+ * SPDX-License-Identifier: LGPL-3.0-or-later
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "soup-message-io-source.h"
+
+static gboolean
+message_io_source_prepare (GSource *source,
+                           gint    *timeout)
+{
+        SoupMessageIOSource *message_io_source = (SoupMessageIOSource *)source;
+	*timeout = -1;
+	return message_io_source->check_func (source);
+}
+
+static gboolean
+message_io_source_dispatch (GSource     *source,
+                            GSourceFunc  callback,
+                            gpointer     user_data)
+{
+	SoupMessageIOSourceFunc func = (SoupMessageIOSourceFunc)callback;
+	SoupMessageIOSource *message_io_source = (SoupMessageIOSource *)source;
+
+	return (*func) (message_io_source->msg, user_data);
+}
+
+static void
+message_io_source_finalize (GSource *source)
+{
+	SoupMessageIOSource *message_io_source = (SoupMessageIOSource *)source;
+
+	g_object_unref (message_io_source->msg);
+}
+
+static gboolean
+message_io_source_closure_callback (SoupMessage *msg,
+				    gpointer     data)
+{
+	GClosure *closure = data;
+	GValue param = G_VALUE_INIT;
+	GValue result_value = G_VALUE_INIT;
+	gboolean result;
+
+	g_value_init (&result_value, G_TYPE_BOOLEAN);
+
+	g_value_init (&param, SOUP_TYPE_MESSAGE);
+	g_value_set_object (&param, msg);
+
+	g_closure_invoke (closure, &result_value, 1, &param, NULL);
+
+	result = g_value_get_boolean (&result_value);
+	g_value_unset (&result_value);
+	g_value_unset (&param);
+
+	return result;
+}
+
+static GSourceFuncs message_io_source_funcs =
+{
+	message_io_source_prepare,
+	NULL,
+	message_io_source_dispatch,
+	message_io_source_finalize,
+	(GSourceFunc)message_io_source_closure_callback,
+	(GSourceDummyMarshal)g_cclosure_marshal_generic,
+};
+
+GSource *
+soup_message_io_source_new (GSource *base_source,
+                            GObject *msg,
+                            gboolean paused,
+                            gboolean (*check_func) (GSource*))
+{
+        GSource *source = g_source_new (&message_io_source_funcs, sizeof (SoupMessageIOSource));
+	g_source_set_name (source, "SoupMessageIOSource");
+	SoupMessageIOSource *message_io_source = (SoupMessageIOSource *)source;
+	message_io_source->msg = g_object_ref (msg);
+	message_io_source->paused = paused;
+        message_io_source->check_func = check_func;
+
+	if (base_source) {
+		g_source_set_dummy_callback (base_source);
+		g_source_add_child_source (source, base_source);
+		g_source_unref (base_source);
+	}
+
+        return source;
+}