/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */ /* camel-stream-mem.c: memory buffer based stream */ /* * Authors: Bertrand Guiheneuf * Michael Zucchi * * Copyright 1999, 2000 Helix Code, Inc. (http://www.helixcode.com) * * 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 "camel-stream-mem.h" #include #include #include #include static CamelSeekableStreamClass *parent_class = NULL; /* Returns the class for a CamelStreamMem */ #define CSM_CLASS(so) CAMEL_STREAM_MEM_CLASS(CAMEL_OBJECT_GET_CLASS(so)) static ssize_t stream_read (CamelStream *stream, char *buffer, size_t n); static ssize_t stream_write (CamelStream *stream, const char *buffer, size_t n); static gboolean stream_eos (CamelStream *stream); static off_t stream_seek (CamelSeekableStream *stream, off_t offset, CamelStreamSeekPolicy policy); static void camel_stream_mem_finalize (CamelObject *object); static void camel_stream_mem_class_init (CamelStreamMemClass *camel_stream_mem_class) { CamelSeekableStreamClass *camel_seekable_stream_class = CAMEL_SEEKABLE_STREAM_CLASS (camel_stream_mem_class); CamelStreamClass *camel_stream_class = CAMEL_STREAM_CLASS (camel_stream_mem_class); parent_class = CAMEL_SEEKABLE_STREAM_CLASS( camel_type_get_global_classfuncs( CAMEL_SEEKABLE_STREAM_TYPE ) ); /* virtual method overload */ camel_stream_class->read = stream_read; camel_stream_class->write = stream_write; camel_stream_class->eos = stream_eos; camel_seekable_stream_class->seek = stream_seek; } static void camel_stream_mem_init (CamelObject *object) { CamelStreamMem *stream_mem = CAMEL_STREAM_MEM (object); stream_mem->owner = FALSE; stream_mem->buffer = 0; } CamelType camel_stream_mem_get_type (void) { static CamelType camel_stream_mem_type = CAMEL_INVALID_TYPE; if (camel_stream_mem_type == CAMEL_INVALID_TYPE) { camel_stream_mem_type = camel_type_register( CAMEL_SEEKABLE_STREAM_TYPE, "CamelStreamMem", sizeof( CamelStreamMem ), sizeof( CamelStreamMemClass ), (CamelObjectClassInitFunc) camel_stream_mem_class_init, NULL, (CamelObjectInitFunc) camel_stream_mem_init, (CamelObjectFinalizeFunc) camel_stream_mem_finalize ); } return camel_stream_mem_type; } CamelStream * camel_stream_mem_new (void) { return camel_stream_mem_new_with_byte_array (g_byte_array_new ()); } CamelStream * camel_stream_mem_new_with_buffer (const char *buffer, size_t len) { GByteArray *ba; ba = g_byte_array_new (); g_byte_array_append (ba, (const guint8 *)buffer, len); return camel_stream_mem_new_with_byte_array (ba); } CamelStream * camel_stream_mem_new_with_byte_array (GByteArray *byte_array) { CamelStreamMem *stream_mem; stream_mem = CAMEL_STREAM_MEM( camel_object_new (CAMEL_STREAM_MEM_TYPE) ); stream_mem->buffer = byte_array; stream_mem->owner = TRUE; return CAMEL_STREAM (stream_mem); } /* note: with these functions the caller is the 'owner' of the buffer */ void camel_stream_mem_set_byte_array (CamelStreamMem *s, GByteArray *buffer) { if (s->buffer && s->owner) g_byte_array_free(s->buffer, TRUE); s->owner = FALSE; s->buffer = buffer; } void camel_stream_mem_set_buffer (CamelStreamMem *s, const char *buffer, size_t len) { GByteArray *ba; ba = g_byte_array_new (); g_byte_array_append(ba, (const guint8 *)buffer, len); camel_stream_mem_set_byte_array(s, ba); s->owner = TRUE; } static void camel_stream_mem_finalize (CamelObject *object) { CamelStreamMem *stream_mem = CAMEL_STREAM_MEM (object); if (stream_mem->buffer && stream_mem->owner) g_byte_array_free (stream_mem->buffer, TRUE); /* Will be called automagically in the Camel Type System! * Wheeee! * G_TK_OBJECT_CLASS (parent_class)->finalize (object); */ } static ssize_t stream_read (CamelStream *stream, char *buffer, size_t n) { CamelStreamMem *camel_stream_mem = CAMEL_STREAM_MEM (stream); CamelSeekableStream *seekable = CAMEL_SEEKABLE_STREAM (stream); ssize_t nread; if (seekable->bound_end != CAMEL_STREAM_UNBOUND) n = MIN(seekable->bound_end - seekable->position, n); nread = MIN (n, camel_stream_mem->buffer->len - seekable->position); if (nread > 0) { memcpy (buffer, camel_stream_mem->buffer->data + seekable->position, nread); seekable->position += nread; } else nread = 0; return nread; } static ssize_t stream_write (CamelStream *stream, const char *buffer, size_t n) { CamelStreamMem *stream_mem = CAMEL_STREAM_MEM (stream); CamelSeekableStream *seekable = CAMEL_SEEKABLE_STREAM (stream); ssize_t nwrite = n; if (seekable->bound_end != CAMEL_STREAM_UNBOUND) nwrite = MIN(seekable->bound_end - seekable->position, n); #ifndef NO_WARNINGS #warning "g_byte_arrays use g_malloc and so are totally unsuitable for this object" #endif if (seekable->position == stream_mem->buffer->len) { g_byte_array_append(stream_mem->buffer, (const guint8 *)buffer, nwrite); } else { g_byte_array_set_size(stream_mem->buffer, nwrite + stream_mem->buffer->len); memcpy(stream_mem->buffer->data + seekable->position, buffer, nwrite); } seekable->position += nwrite; return nwrite; } static gboolean stream_eos (CamelStream *stream) { CamelStreamMem *stream_mem = CAMEL_STREAM_MEM (stream); CamelSeekableStream *seekable_stream = CAMEL_SEEKABLE_STREAM (stream); return stream_mem->buffer->len <= seekable_stream->position; } static off_t stream_seek (CamelSeekableStream *stream, off_t offset, CamelStreamSeekPolicy policy) { off_t position; CamelStreamMem *stream_mem = CAMEL_STREAM_MEM (stream); switch (policy) { case CAMEL_STREAM_SET: position = offset; break; case CAMEL_STREAM_CUR: position = stream->position + offset; break; case CAMEL_STREAM_END: position = (stream_mem->buffer)->len + offset; break; default: position = offset; break; } if (stream->bound_end != CAMEL_STREAM_UNBOUND) position = MIN (position, stream->bound_end); if (stream->bound_start != CAMEL_STREAM_UNBOUND) position = MAX (position, 0); else position = MAX (position, stream->bound_start); if (position > stream_mem->buffer->len) { int oldlen = stream_mem->buffer->len; g_byte_array_set_size (stream_mem->buffer, position); memset (stream_mem->buffer->data + oldlen, 0, position - oldlen); } stream->position = position; return position; } s='left'>Lines * The FreeBSD KDE Team is pleased to announce KDE SC 4.6.1 and KDE PIMavilla2011-03-252-16/+9 * - Get Rid MD5 supportmiwi2011-03-195-5/+0 * - Remove unnecessary PKGNAMEPREFIX declarationsunpoet2011-01-094-4/+0 * - The KDE FreeBSD team is proud to announce the release of KDE 4.5.5fluffy2011-01-081-2/+2 * KDE FreeBSD team presents KDE SC 4.5.4.makc2010-12-031-2/+2 * KDE FreeBSD team presents KDE SC 4.5.3.makc2010-11-041-3/+2 * KDE FreeBSD team presents KDE SC 4.5.2.makc2010-10-061-3/+3 * Autotools update. Read ports/UPDATING 20100915 for details.ade2010-09-162-4/+2 * KDE FreeBSD team presents KDE SC 4.5.1.makc2010-09-032-74/+34 * Present KDE SC 4.4.5 for FreeBSD.makc2010-06-301-3/+3 * - Update to 2.01.stefan2010-06-284-16/+21 * Present KDE SC 4.4.4 for FreeBSD.makc2010-06-021-3/+3 * Bounce PORTREVISION for gettext-related ports. Have fun, ya'll.ade2010-05-312-2/+2 * Convert LDCONFIG_DIRS to USE_LDCONFIG for unmaintained ports.makc2010-05-241-2/+1 * - The FreeBSD KDE team is pleased to announce KDE SC 4.4.3 for FreeBSDfluffy2010-05-113-28/+11 * - update to 1.4.1dinoex2010-03-284-3/+4 * Presenting KDE 4.3.5 for FreeBSD. The official release notes for thismiwi2010-02-072-4/+3 * - update to jpeg-8dinoex2010-02-054-3/+4 * - Update to 0.7.0wen2010-01-104-50/+6 * - Update to 1.6.2wen2010-01-103-8/+6 * - SUB_FILES += pkg-messagepgollucci2010-01-082-9/+9 * - SUB_FILES += pkg-messagepgollucci2010-01-083-18/+18 * - Use SUB_FILES for pkg-messagepgollucci2010-01-072-3/+3 * The FreeBSD KDE is please to announce the release of KDE 4.3.4,miwi2009-12-021-3/+3 * The KDE FreeBSD team is proud to announce the release of KDE 4.3.3miwi2009-11-272-5/+5 * - Mark MAKE_JOBS_UNSAFEpav2009-11-201-0/+1 * The FreeBSD KDE is please to announce the release of KDE 4.3.1,tabthorpe2009-09-022-6/+6 * - Switch SourceForge ports to the new File Release System: categories startin...amdmi32009-08-224-7/+4 * Reset sbahra at his request due to lack of time to work on these ports.linimon2009-08-209-18/+6 * clean upmakc2009-08-081-4/+1 * The KDE FreeBSD team is proud to announce the release of KDE 4.3.0miwi2009-08-053-17/+93 * - bump all port that indirectly depends on libjpeg and have not yet been bump...dinoex2009-07-314-2/+4 * The KDE FreeBSD team is pleased to announce KDE 4.2.4, the last bugfixmiwi2009-06-03