148 lines
2.8 KiB
C
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);
|
|
}
|
|
}
|