Main Page | Alphabetical List | Data Structures | Directories | File List | Data Fields | Globals

wsstream_data.c

Go to the documentation of this file.
00001 /* ==================================================================== 
00002  * The Kannel Software License, Version 1.0 
00003  * 
00004  * Copyright (c) 2001-2008 Kannel Group  
00005  * Copyright (c) 1998-2001 WapIT Ltd.   
00006  * All rights reserved. 
00007  * 
00008  * Redistribution and use in source and binary forms, with or without 
00009  * modification, are permitted provided that the following conditions 
00010  * are met: 
00011  * 
00012  * 1. Redistributions of source code must retain the above copyright 
00013  *    notice, this list of conditions and the following disclaimer. 
00014  * 
00015  * 2. Redistributions in binary form must reproduce the above copyright 
00016  *    notice, this list of conditions and the following disclaimer in 
00017  *    the documentation and/or other materials provided with the 
00018  *    distribution. 
00019  * 
00020  * 3. The end-user documentation included with the redistribution, 
00021  *    if any, must include the following acknowledgment: 
00022  *       "This product includes software developed by the 
00023  *        Kannel Group (http://www.kannel.org/)." 
00024  *    Alternately, this acknowledgment may appear in the software itself, 
00025  *    if and wherever such third-party acknowledgments normally appear. 
00026  * 
00027  * 4. The names "Kannel" and "Kannel Group" must not be used to 
00028  *    endorse or promote products derived from this software without 
00029  *    prior written permission. For written permission, please  
00030  *    contact org@kannel.org. 
00031  * 
00032  * 5. Products derived from this software may not be called "Kannel", 
00033  *    nor may "Kannel" appear in their name, without prior written 
00034  *    permission of the Kannel Group. 
00035  * 
00036  * THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED 
00037  * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES 
00038  * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE 
00039  * DISCLAIMED.  IN NO EVENT SHALL THE KANNEL GROUP OR ITS CONTRIBUTORS 
00040  * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,  
00041  * OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT  
00042  * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR  
00043  * BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,  
00044  * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE  
00045  * OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,  
00046  * EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 
00047  * ==================================================================== 
00048  * 
00049  * This software consists of voluntary contributions made by many 
00050  * individuals on behalf of the Kannel Group.  For more information on  
00051  * the Kannel Group, please see <http://www.kannel.org/>. 
00052  * 
00053  * Portions of this software are based upon software originally written at  
00054  * WapIT Ltd., Helsinki, Finland for the Kannel project.  
00055  */ 
00056 
00057 /*
00058  *
00059  * wsstream_data.c
00060  *
00061  * Author: Markku Rossi <mtr@iki.fi>
00062  *
00063  * Copyright (c) 1999-2000 WAPIT OY LTD.
00064  *       All rights reserved.
00065  *
00066  * Implementation of the data streams.
00067  *
00068  */
00069 
00070 #include "wmlscript/wsint.h"
00071 
00072 /********************* Types and definitions ****************************/
00073 
00074 struct WsStreamDataInputCtxRec
00075 {
00076     const unsigned char *data;
00077     size_t data_len;
00078     size_t data_pos;
00079 };
00080 
00081 typedef struct WsStreamDataInputCtxRec WsStreamDataInputCtx;
00082 
00083 /********************* Static method functions **************************/
00084 
00085 static size_t data_input(void *context, WsUInt32 *buf, size_t buflen)
00086 {
00087     WsStreamDataInputCtx *ctx = (WsStreamDataInputCtx *) context;
00088     size_t read;
00089 
00090     for (read = 0;
00091          read < buflen && ctx->data_pos < ctx->data_len;
00092          read++, ctx->data_pos++)
00093         buf[read] = ctx->data[ctx->data_pos];
00094 
00095     return read;
00096 }
00097 
00098 
00099 static void data_close(void *context)
00100 {
00101     WsStreamDataInputCtx *ctx = (WsStreamDataInputCtx *) context;
00102 
00103     ws_free(ctx);
00104 }
00105 
00106 /********************* Global functions *********************************/
00107 
00108 WsStream *ws_stream_new_data_input(const unsigned char *data, size_t data_len)
00109 {
00110     WsStreamDataInputCtx *ctx = ws_calloc(1, sizeof(*ctx));
00111     WsStream *stream;
00112 
00113     if (ctx == NULL)
00114         return NULL;
00115 
00116     ctx->data = data;
00117     ctx->data_len = data_len;
00118 
00119     stream = ws_stream_new(ctx, data_input, NULL, data_close);
00120 
00121     if (stream == NULL)
00122         /* The stream creation failed.  Close the stream context. */
00123         data_close(ctx);
00124 
00125     return stream;
00126 }
See file LICENSE for details about the license agreement for using, modifying, copying or deriving work from this software.