2013-01-11 01:48:46 +08:00
|
|
|
#include "stream.h"
|
|
|
|
|
|
|
|
#include <string.h>
|
|
|
|
#include <stdio.h>
|
|
|
|
#include <stdlib.h>
|
|
|
|
|
|
|
|
struct _internal_foug_stream
|
|
|
|
{
|
|
|
|
void* cookie;
|
|
|
|
foug_stream_manip_t manip;
|
|
|
|
};
|
|
|
|
|
|
|
|
foug_stream_t* foug_stream_create(foug_malloc_func_t func, void* data, foug_stream_manip_t manip)
|
|
|
|
{
|
|
|
|
if (func == NULL)
|
|
|
|
return NULL;
|
|
|
|
foug_stream_t* stream = (*func)(sizeof(struct _internal_foug_stream));
|
|
|
|
if (stream != NULL) {
|
|
|
|
stream->cookie = data;
|
|
|
|
stream->manip = manip;
|
|
|
|
}
|
|
|
|
return stream;
|
|
|
|
}
|
|
|
|
|
|
|
|
foug_stream_manip_t foug_stream_manip_null()
|
|
|
|
{
|
|
|
|
foug_stream_manip_t manip;
|
|
|
|
memset(&manip, 0, sizeof(foug_stream_manip_t));
|
|
|
|
return manip;
|
|
|
|
}
|
|
|
|
|
2013-01-15 02:30:42 +08:00
|
|
|
static foug_bool_t foug_stream_stdio_at_end(foug_stream_t* stream)
|
2013-01-11 01:48:46 +08:00
|
|
|
{
|
|
|
|
return feof((FILE*) stream->cookie);
|
|
|
|
}
|
|
|
|
|
2013-01-15 17:40:35 +08:00
|
|
|
static int32_t foug_stream_stdio_error(foug_stream_t* stream)
|
2013-01-11 01:48:46 +08:00
|
|
|
{
|
2013-01-15 17:40:35 +08:00
|
|
|
return ferror((FILE*) stream->cookie);
|
|
|
|
}
|
2013-01-11 01:48:46 +08:00
|
|
|
|
2013-01-15 02:30:42 +08:00
|
|
|
static size_t foug_stream_stdio_read(foug_stream_t* stream,
|
|
|
|
void* ptr,
|
|
|
|
size_t item_size,
|
|
|
|
size_t item_count)
|
2013-01-11 01:48:46 +08:00
|
|
|
{
|
2013-01-15 02:30:42 +08:00
|
|
|
return fread(ptr, item_size, item_count, (FILE*) stream->cookie);
|
2013-01-11 01:48:46 +08:00
|
|
|
}
|
|
|
|
|
2013-01-15 02:30:42 +08:00
|
|
|
static size_t foug_stream_stdio_write(foug_stream_t* stream,
|
|
|
|
const void* ptr,
|
|
|
|
size_t item_size,
|
|
|
|
size_t item_count)
|
2013-01-11 01:48:46 +08:00
|
|
|
{
|
2013-01-15 02:30:42 +08:00
|
|
|
return fwrite(ptr, item_size, item_count, (FILE*) stream->cookie);
|
2013-01-11 01:48:46 +08:00
|
|
|
}
|
|
|
|
|
|
|
|
foug_stream_manip_t foug_stream_manip_stdio()
|
|
|
|
{
|
|
|
|
foug_stream_manip_t manip;
|
2013-01-24 18:29:51 +08:00
|
|
|
manip.at_end_func = foug_stream_stdio_at_end;
|
|
|
|
manip.error_func = foug_stream_stdio_error;
|
|
|
|
manip.read_func = foug_stream_stdio_read;
|
|
|
|
manip.write_func = foug_stream_stdio_write;
|
2013-01-11 01:48:46 +08:00
|
|
|
return manip;
|
|
|
|
}
|
|
|
|
|
2013-01-15 02:30:42 +08:00
|
|
|
foug_bool_t foug_stream_at_end(foug_stream_t* stream)
|
2013-01-11 01:48:46 +08:00
|
|
|
{
|
|
|
|
if (stream != NULL && stream->manip.at_end_func != NULL)
|
|
|
|
return (*(stream->manip.at_end_func))(stream);
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2013-01-15 17:40:35 +08:00
|
|
|
int foug_stream_error(foug_stream_t* stream)
|
2013-01-11 01:48:46 +08:00
|
|
|
{
|
2013-01-15 17:40:35 +08:00
|
|
|
if (stream != NULL && stream->manip.error_func != NULL)
|
|
|
|
return (*(stream->manip.error_func))(stream);
|
|
|
|
return 0;
|
|
|
|
}
|
2013-01-11 01:48:46 +08:00
|
|
|
|
2013-01-15 02:30:42 +08:00
|
|
|
size_t foug_stream_read(foug_stream_t* stream, void *ptr, size_t item_size, size_t item_count)
|
2013-01-11 01:48:46 +08:00
|
|
|
{
|
|
|
|
if (stream != NULL && stream->manip.read_func != NULL)
|
2013-01-15 02:30:42 +08:00
|
|
|
return (*(stream->manip.read_func))(stream, ptr, item_size, item_count);
|
2013-01-11 01:48:46 +08:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
2013-01-15 02:30:42 +08:00
|
|
|
size_t foug_stream_write(foug_stream_t* stream, const void *ptr, size_t item_size, size_t item_count)
|
2013-01-11 01:48:46 +08:00
|
|
|
{
|
|
|
|
if (stream != NULL && stream->manip.write_func != NULL)
|
2013-01-15 02:30:42 +08:00
|
|
|
return (*(stream->manip.write_func))(stream, ptr, item_size, item_count);
|
2013-01-11 01:48:46 +08:00
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
void* foug_stream_get_cookie(const foug_stream_t* stream)
|
|
|
|
{
|
|
|
|
return stream != NULL ? stream->cookie : NULL;
|
|
|
|
}
|