wsstream_data.c File Reference

#include "wmlscript/wsint.h"

Go to the source code of this file.

Data Structures
struct	WsStreamDataInputCtxRec

Typedefs
typedef struct WsStreamDataInputCtxRec	WsStreamDataInputCtx

Functions
static size_t	data_input (void *context, WsUInt32 *buf, size_t buflen)
static void	data_close (void *context)
WsStream *	ws_stream_new_data_input (const unsigned char *data, size_t data_len)

Typedef Documentation

WsStreamDataInputCtx

typedef struct WsStreamDataInputCtxRec WsStreamDataInputCtx

Definition at line 81 of file wsstream_data.c.

Function Documentation

data_close()

static void data_close ( void *  context )

static

Definition at line 99 of file wsstream_data.c.

References ws_free().

Referenced by ws_stream_new_data_input().

{
    WsStreamDataInputCtx *ctx = (WsStreamDataInputCtx *) context;

    ws_free(ctx);
}

data_input()

static size_t data_input ( void *  context, WsUInt32 *  buf, size_t  buflen  )

static

Definition at line 85 of file wsstream_data.c.

References WsStreamDataInputCtxRec::data, WsStreamDataInputCtxRec::data_len, and WsStreamDataInputCtxRec::data_pos.

Referenced by ws_stream_new_data_input().

{
    WsStreamDataInputCtx *ctx = (WsStreamDataInputCtx *) context;
    size_t read;

    for (read = 0;
         read < buflen && ctx->data_pos < ctx->data_len;
         read++, ctx->data_pos++)
        buf[read] = ctx->data[ctx->data_pos];

    return read;
}

ws_stream_new_data_input()

WsStream* ws_stream_new_data_input	(	const unsigned char *	data,
		size_t	data_len
	)

Definition at line 108 of file wsstream_data.c.

References WsStreamDataInputCtxRec::data, data_close(), data_input(), WsStreamDataInputCtxRec::data_len, ws_calloc(), and ws_stream_new().

Referenced by ws_compile_data().

{
    WsStreamDataInputCtx *ctx = ws_calloc(1, sizeof(*ctx));
    WsStream *stream;

    if (ctx == NULL)
        return NULL;

    ctx->data = data;
    ctx->data_len = data_len;

    stream = ws_stream_new(ctx, data_input, NULL, data_close);

    if (stream == NULL)
        /* The stream creation failed.  Close the stream context. */
        data_close(ctx);

    return stream;
}