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 }