libisofs/src/stream.c
2007-12-02 22:04:26 +01:00

148 lines
2.8 KiB
C

/*
* Copyright (c) 2007 Vreixo Formoso
*
* This file is part of the libisofs project; you can redistribute it and/or
* modify it under the terms of the GNU General Public License version 2 as
* published by the Free Software Foundation. See COPYING file for details.
*/
#include "libisofs.h"
#include "stream.h"
#include "fsource.h"
#include "error.h"
#include <stdlib.h>
typedef struct
{
IsoFileSource *src;
} _FSrcStream;
static
int fsrc_open(IsoStream *stream)
{
IsoFileSource *src;
if (stream == NULL) {
return ISO_NULL_POINTER;
}
src = (IsoFileSource*)stream->data;
return src->open(src);
}
static
int fsrc_close(IsoStream *stream)
{
IsoFileSource *src;
if (stream == NULL) {
return ISO_NULL_POINTER;
}
src = (IsoFileSource*)stream->data;
return src->close(src);
}
static
off_t fsrc_get_size(IsoStream *stream)
{
struct stat info;
IsoFileSource *src;
if (stream == NULL) {
return ISO_NULL_POINTER;
}
src = (IsoFileSource*)stream->data;
if (src->lstat(src, &info) < 0) {
return (off_t) -1;
}
return info.st_size;
}
static
int fsrc_read(IsoStream *stream, void *buf, size_t count)
{
IsoFileSource *src;
if (stream == NULL) {
return ISO_NULL_POINTER;
}
src = (IsoFileSource*)stream->data;
return src->read(src, buf, count);
}
static
int fsrc_is_repeatable(IsoStream *stream)
{
int ret;
struct stat info;
IsoFileSource *src;
if (stream == NULL) {
return ISO_NULL_POINTER;
}
src = (IsoFileSource*)stream->data;
ret = src->stat(src, &info);
if (ret < 0) {
return ret;
}
if (info.st_mode & (S_IFREG | S_IFBLK)) {
return 1;
} else {
return 0;
}
}
static
void fsrc_free(IsoStream *stream)
{
IsoFileSource *src;
src = (IsoFileSource*)stream->data;
iso_file_source_unref(src);
}
int iso_file_source_stream_new(IsoFileSource *src, IsoStream **stream)
{
int r;
struct stat info;
IsoStream *str;
if (src == NULL || stream == NULL) {
return ISO_NULL_POINTER;
}
r = src->stat(src, &info);
if (r < 0) {
return r;
}
if (S_ISDIR(info.st_mode)) {
return ISO_FILE_IS_DIR;
}
str = malloc(sizeof(IsoStream));
if (str == NULL) {
return ISO_MEM_ERROR;
}
str->refcount = 1;
str->data = src;
str->open = fsrc_open;
str->close = fsrc_close;
str->get_size = fsrc_get_size;
str->read = fsrc_read;
str->is_repeatable = fsrc_is_repeatable;
str->free = fsrc_free;
*stream = str;
return ISO_SUCCESS;
}
void iso_stream_ref(IsoStream *stream)
{
++stream->refcount;
}
void iso_stream_unref(IsoStream *stream)
{
if (--stream->refcount == 0) {
stream->free(stream);
free(stream);
}
}