|
Packit |
b00eeb |
/*
|
|
Packit |
b00eeb |
* gnome-keyring
|
|
Packit |
b00eeb |
*
|
|
Packit |
b00eeb |
* Copyright (C) 2011 Collabora Ltd.
|
|
Packit |
b00eeb |
*
|
|
Packit |
b00eeb |
* This program is free software; you can redistribute it and/or modify
|
|
Packit |
b00eeb |
* it under the terms of the GNU Lesser General Public License as
|
|
Packit |
b00eeb |
* published by the Free Software Foundation; either version 2.1 of
|
|
Packit |
b00eeb |
* the License, or (at your option) any later version.
|
|
Packit |
b00eeb |
*
|
|
Packit |
b00eeb |
* This program is distributed in the hope that it will be useful, but
|
|
Packit |
b00eeb |
* WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
Packit |
b00eeb |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Packit |
b00eeb |
* Lesser General Public License for more details.
|
|
Packit |
b00eeb |
*
|
|
Packit |
b00eeb |
* You should have received a copy of the GNU Lesser General Public
|
|
Packit |
b00eeb |
* License along with this program; if not, see <http://www.gnu.org/licenses/>.
|
|
Packit |
b00eeb |
*
|
|
Packit |
b00eeb |
* Author: Stef Walter <stefw@collabora.co.uk>
|
|
Packit |
b00eeb |
*/
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
#include "config.h"
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
#include "gcr-callback-output-stream.h"
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
#include <glib/gi18n-lib.h>
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
struct _GcrCallbackOutputStream {
|
|
Packit |
b00eeb |
GOutputStream parent;
|
|
Packit |
b00eeb |
GcrCallbackOutputFunc callback;
|
|
Packit |
b00eeb |
gpointer user_data;
|
|
Packit |
b00eeb |
GDestroyNotify destroy_func;
|
|
Packit |
b00eeb |
};
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
struct _GcrCallbackOutputStreamClass {
|
|
Packit |
b00eeb |
GOutputStreamClass parent_class;
|
|
Packit |
b00eeb |
};
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
G_DEFINE_TYPE (GcrCallbackOutputStream, _gcr_callback_output_stream, G_TYPE_OUTPUT_STREAM);
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
static void
|
|
Packit |
b00eeb |
_gcr_callback_output_stream_init (GcrCallbackOutputStream *self)
|
|
Packit |
b00eeb |
{
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
}
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
static gssize
|
|
Packit |
b00eeb |
_gcr_callback_output_stream_write (GOutputStream *stream,
|
|
Packit |
b00eeb |
const void *buffer,
|
|
Packit |
b00eeb |
gsize count,
|
|
Packit |
b00eeb |
GCancellable *cancellable,
|
|
Packit |
b00eeb |
GError **error)
|
|
Packit |
b00eeb |
{
|
|
Packit |
b00eeb |
GcrCallbackOutputStream *self = GCR_CALLBACK_OUTPUT_STREAM (stream);
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
if (g_cancellable_set_error_if_cancelled (cancellable, error)) {
|
|
Packit |
b00eeb |
return -1;
|
|
Packit |
b00eeb |
} else if (self->callback == NULL) {
|
|
Packit |
b00eeb |
g_set_error (error, G_IO_ERROR, G_IO_ERROR_CLOSED,
|
|
Packit |
b00eeb |
_("The stream was closed"));
|
|
Packit |
b00eeb |
return -1;
|
|
Packit |
b00eeb |
}
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
return (self->callback) (buffer, count, cancellable, self->user_data, error);
|
|
Packit |
b00eeb |
}
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
static gboolean
|
|
Packit |
b00eeb |
_gcr_callback_output_stream_close (GOutputStream *stream,
|
|
Packit |
b00eeb |
GCancellable *cancellable,
|
|
Packit |
b00eeb |
GError **error)
|
|
Packit |
b00eeb |
{
|
|
Packit |
b00eeb |
GcrCallbackOutputStream *self = GCR_CALLBACK_OUTPUT_STREAM (stream);
|
|
Packit |
b00eeb |
if (g_cancellable_set_error_if_cancelled (cancellable, error)) {
|
|
Packit |
b00eeb |
return FALSE;
|
|
Packit |
b00eeb |
} else if (self->callback == NULL) {
|
|
Packit |
b00eeb |
g_set_error (error, G_IO_ERROR, G_IO_ERROR_CLOSED,
|
|
Packit |
b00eeb |
_("The stream was closed"));
|
|
Packit |
b00eeb |
return FALSE;
|
|
Packit |
b00eeb |
}
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
if (self->destroy_func != NULL)
|
|
Packit |
b00eeb |
(self->destroy_func) (self->user_data);
|
|
Packit |
b00eeb |
self->destroy_func = NULL;
|
|
Packit |
b00eeb |
self->user_data = NULL;
|
|
Packit |
b00eeb |
self->callback = NULL;
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
return TRUE;
|
|
Packit |
b00eeb |
}
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
static void
|
|
Packit |
b00eeb |
_gcr_callback_output_stream_dispose (GObject *obj)
|
|
Packit |
b00eeb |
{
|
|
Packit |
b00eeb |
_gcr_callback_output_stream_close (G_OUTPUT_STREAM (obj), NULL, NULL);
|
|
Packit |
b00eeb |
G_OBJECT_CLASS (_gcr_callback_output_stream_parent_class)->dispose (obj);
|
|
Packit |
b00eeb |
}
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
static void
|
|
Packit |
b00eeb |
_gcr_callback_output_stream_class_init (GcrCallbackOutputStreamClass *klass)
|
|
Packit |
b00eeb |
{
|
|
Packit |
b00eeb |
GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
|
|
Packit |
b00eeb |
GOutputStreamClass *output_class = G_OUTPUT_STREAM_CLASS (klass);
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
gobject_class->dispose = _gcr_callback_output_stream_dispose;
|
|
Packit |
b00eeb |
output_class->write_fn = _gcr_callback_output_stream_write;
|
|
Packit |
b00eeb |
output_class->close_fn = _gcr_callback_output_stream_close;
|
|
Packit |
b00eeb |
}
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
/**
|
|
Packit |
b00eeb |
* _gcr_callback_output_stream_new: (skip)
|
|
Packit |
b00eeb |
*
|
|
Packit |
b00eeb |
* Create a new output stream which invokes the callback.
|
|
Packit |
b00eeb |
*
|
|
Packit |
b00eeb |
* Returns: (transfer full) (type Gcr.CallbackOutputStream): the new stream
|
|
Packit |
b00eeb |
*/
|
|
Packit |
b00eeb |
GOutputStream *
|
|
Packit |
b00eeb |
_gcr_callback_output_stream_new (GcrCallbackOutputFunc callback,
|
|
Packit |
b00eeb |
gpointer user_data,
|
|
Packit |
b00eeb |
GDestroyNotify destroy_func)
|
|
Packit |
b00eeb |
{
|
|
Packit |
b00eeb |
GcrCallbackOutputStream *self;
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
g_return_val_if_fail (callback, NULL);
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
self = g_object_new (GCR_TYPE_CALLBACK_OUTPUT_STREAM, NULL);
|
|
Packit |
b00eeb |
self->callback = callback;
|
|
Packit |
b00eeb |
self->user_data = user_data;
|
|
Packit |
b00eeb |
self->destroy_func = destroy_func;
|
|
Packit |
b00eeb |
|
|
Packit |
b00eeb |
return G_OUTPUT_STREAM (self);
|
|
Packit |
b00eeb |
}
|