/* -*- Mode: C; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 8 -*- */

/*

 * soup-message-io-source.c

 *

 * Copyright (C) 2000-2003, Ximian, Inc.

 * Copyright (C) 2021 Igalia S.L.

 */

#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;

}