ossp-pkg/sio/sio_sio.c
1.1
#include <stddef.h>
#include <stdlib.h>
#include <string.h>
#include <limits.h>
#include "al.h"
#include "sio.h"
typedef struct {
sio_t *upstream;
al_label_t label;
al_label_t data_label;
al_label_t eof_label;
al_label_t error_label;
char eof;
} private_t;
/*
* create stage
*
* allocate private instance data
*/
static
sio_rc_t siosio_init(sio_t *sio, void **up)
{
private_t *my;
my = (private_t *)malloc(sizeof(private_t));
if (my == NULL)
return SIO_ERR_MEM;
my->upstream = NULL;
my->label = NULL;
my->eof = '\0';
sio_label(sio, SIO_LN_DATA, &my->data_label);
sio_label(sio, SIO_LN_ERROR, &my->error_label);
sio_label(sio, SIO_LN_EOF, &my->eof_label);
*up = my;
return SIO_OK;
}
/*
* configure stage
*
* pass two void pointers
*/
static
sio_rc_t siosio_configure(sio_t *sio, void *u, void *obj, void *val)
{
private_t *my = (private_t *)u;
const char *name = (const char *)obj;
if (!strcmp(name, "upstream")) {
my->upstream = (sio_t *)val;
} else if (!strcmp(name, "label")) {
my->label = (al_label_t)val;
} else {
return SIO_ERR_ARG;
}
return SIO_OK;
}
/*
* destroy stage
*/
static
sio_rc_t siosio_cleanup(sio_t *sio, void *u)
{
private_t *my = (private_t *)u;
free(my);
return SIO_OK;
}
static
sio_rc_t siosio_openr(sio_t *sio, al_t *al, void *u)
{
private_t *my = (private_t *)u;
if (my->upstream == NULL ||
my->label == NULL)
return SIO_ERR_ARG;
return SIO_OK;
}
static
sio_rc_t siosio_closer(sio_t *sio, al_t *al, void *u)
{
return SIO_OK;
}
static
sio_rc_t siosio_openw(sio_t *sio, al_t *al, void *u)
{
private_t *my = (private_t *)u;
if (my->upstream == NULL ||
my->label == NULL)
return SIO_ERR_ARG;
return SIO_OK;
}
static
sio_rc_t siosio_closew(sio_t *sio, al_t *al, void *u)
{
return SIO_OK;
}
static
sio_rc_t siosio_input(sio_t *sio, al_t *al, void *u)
{
private_t *my = (private_t *)u;
if (al_bytes(al) == 0) {
sio_input(my->upstream, al, SIZE_T_MAX, my->label);
if (al_bytes(al) > 0) {
if (my->label != my->data_label)
al_setlabel(al, 0, al_bytes(al), my->label, my->data_label);
} else
al_append_bytes(al, &my->eof, sizeof(my->eof), my->eof_label);
}
return SIO_SCHED_DOWN;
}
static
sio_rc_t siosio_output(sio_t *sio, al_t *al, void *u)
{
private_t *my = (private_t *)u;
if (al_bytes(al) > 0) {
/* recolor data */
if (my->label != my->data_label)
al_setlabel(al, 0, al_bytes(al), my->data_label, my->label);
/* send out */
/* XXX error handling ? */
sio_output(my->upstream, al);
}
return SIO_SCHED_DOWN;
}
sio_module_t sio_module_sio = {
"sio",
siosio_init,
siosio_configure,
siosio_cleanup,
siosio_openr,
siosio_closer,
siosio_openw,
siosio_closew,
siosio_input,
siosio_output,
NULL
};