par2.c

Go to the documentation of this file.

/*
 Copyright (C) 2005-2007 Erik van Pienbroek

 This program is free software; you can redistribute it and/or modify
 it under the terms of the GNU General Public License as published by
 the Free Software Foundation; either version 2 of the License, or
 (at your option) any later version.

 This program 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 General Public License for more details.

 You should have received a copy of the GNU General Public License
 along with this program; if not, write to the Free Software
 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*/

#include 
#include 
#include 
#include 
#include 

#include "nntpgrab_internal.h"
#include "nntpgrab_utils.h"
#include "par2.h"
#include "plugin_par2.h"
#include "nntpgrab_plugin_par2.h"

static PluginPar2ExportedFuncs plugin_funcs;

typedef struct Par2Class Par2Class;

static GType par2_get_type (void);

struct Par2
{
    GObject parent;

    GStaticRWLock rwlock;
};

struct Par2Class
{
    GObjectClass parent;
};

G_DEFINE_TYPE(Par2, par2, G_TYPE_OBJECT);

static void
par2_init (Par2 *obj)
{
    g_static_rw_lock_init(&obj->rwlock);
}

static void
par2_finalize (GObject *obj)
{
    Par2 *par2 = PAR2(obj);

    g_static_rw_lock_free(&par2->rwlock);
}

static void
par2_class_init (Par2Class *klass)
{
    GObjectClass *gobject_class = G_OBJECT_CLASS (klass);

    gobject_class->finalize = par2_finalize;
}

gboolean
par2_initialize(char **errmsg)
{
    GModule *plugin = NULL;
    PluginPar2ImportedFuncs imported_funcs;
    plugin_par2_init_func init_func;
    char *filename;

#ifdef WIN32
#define EXT "-0.dll"
#else
#define EXT ".so"
#endif

    if (g_getenv("NNTPGRAB_LIBDIR")) {
        filename = g_strdup_printf("%s/libnntpgrab_plugin_par2%s", g_getenv("NNTPGRAB_LIBDIR"), EXT);
    } else {
        filename = g_strdup_printf("%s/libnntpgrab_plugin_par2%s", PLUGIN_DIR, EXT);
    }

    plugin = g_module_open(filename, G_MODULE_BIND_LOCAL);

    g_free(filename);

    if (!plugin) {
        if (errmsg) {
            *errmsg = g_strdup(g_module_error());
        }

        return FALSE;
    }

    imported_funcs.version = NNTPGRAB_PLUGIN_API_VERSION;
#if 0
    imported_funcs.update_progress = update_progress_callback;
    imported_funcs.notify_download_complete = download_complete_callback;
    imported_funcs.notify_part_not_available = part_not_available_callback;
    imported_funcs.notify_connecting = connecting_callback;
    imported_funcs.notify_connected = connected_callback;
    imported_funcs.notify_disconnect = disconnect_callback;
#endif

    if (!g_module_symbol(plugin, "nntpgrab_plugin_par2_get_version", (gpointer *) &plugin_funcs.get_version)) {
        if (errmsg) {
            *errmsg = g_strdup(g_module_error());
        }

        return FALSE;
    }

    if (plugin_funcs.get_version() != NNTPGRAB_PLUGIN_API_VERSION) {
        if (errmsg) {
            *errmsg = g_strdup_printf(_("PAR2 Plugin API mismatch (Plugin API version = %i, expected = %i)"), plugin_funcs.get_version(), NNTPGRAB_PLUGIN_API_VERSION);
        }

        return FALSE;
    }

    /* All required methods are found, lets start */
    if (!g_module_symbol(plugin, "nntpgrab_plugin_par2_initialize", (gpointer *) &init_func)) {
        if (errmsg) {
            *errmsg = g_strdup(g_module_error());
        }

        return FALSE;
    }

#if 0
    if (!g_module_symbol(plugin, "nntpgrab_plugin_decoder_decode_file", (gpointer *) &plugin_funcs.decode_file)) {
        if (errmsg) {
            *errmsg = g_strdup(g_module_error());
        }

        return FALSE;
    }
#endif

    if (!init_func(imported_funcs)) {
        if (errmsg) {
            *errmsg = g_strdup(_("PAR2 Plugin initialization failed!"));
        }

        return FALSE;
    }

    nntpgrab_core_emit_debug_message(_("PAR2 plugin initialized"));

    return TRUE;
}

Par2 *
par2_new(void)
{
    Par2 *par2;

    par2 = g_object_new(PAR2_TYPE_OBJECT, NULL);

    return par2;
}

void
par2_destroy(Par2 *obj)
{
    g_object_unref(obj);
}

#if 0
gboolean
decoder_decode_file(Decoder *obj, const char *collection_name, const NNTPFile *file, int *saved_errno)
{
    Decoder *decoder = DECODER(obj);
    ConfigOpts opts;
    char *msg;
    gboolean retval;
    char *errmsg = NULL;

    msg = g_strdup_printf(_("Trying to decode file with from collection '%s' with subject = '%s'"), collection_name, file->subject);
    nntpgrab_core_emit_debug_message(msg);
    g_free(msg);

    g_static_rw_lock_reader_lock(&decoder->rwlock);

    opts = configuration_get_opts(decoder->config);

    g_static_rw_lock_reader_unlock(&decoder->rwlock);

    retval = plugin_funcs.decode_file(collection_name, file, opts.temp_directory, opts.download_directory, saved_errno, &errmsg);

    if (!retval && errmsg) {
        char *filename = NULL;

        nntpgrab_utils_strip_subject(file->subject, NULL, NULL, NULL, &filename, NULL, NULL, NULL, NULL, NULL, NULL);
        msg = g_strdup_printf(_("Decode of file '%s' failed:\n%s"), filename, errmsg);
        nntpgrab_core_emit_warning(msg);

        g_free(filename);
        g_free(errmsg);
    }

    msg = g_strdup_printf(_("Decoder returned %i"), retval);
    nntpgrab_core_emit_debug_message(msg);
    g_free(msg);

    return retval;
}
#endif

---