Cool_Tools/vgmstream
1
0
Fork 0
mirror of https://github.com/vgmstream/vgmstream.git synced 2025-02-07 07:01:16 +01:00
Code Issues Packages Projects Releases Wiki Activity

dos2unix

Browse Source 
git-svn-id: https://vgmstream.svn.sourceforge.net/svnroot/vgmstream@383 51a99a44-fe44-0410-b1ba-c3e57ba2b86b
This commit is contained in:
halleyscometsw 2008-08-02 03:15:24 +00:00
parent 55fba8f190
commit 70c7fb1532
1 changed files with 204 additions and 204 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

408
src/streamfile.c
View File

@ -1,207 +1,207 @@
#ifndef _MSC_VER #ifndef _MSC_VER
#include <unistd.h> #include <unistd.h>
#endif #endif
#include "streamfile.h" #include "streamfile.h"
#include "util.h" #include "util.h"
typedef struct { typedef struct {
STREAMFILE sf; STREAMFILE sf;
FILE * infile; FILE * infile;
off_t offset; off_t offset;
size_t validsize; size_t validsize;
uint8_t * buffer; uint8_t * buffer;
size_t buffersize; size_t buffersize;
char name[260]; char name[260];
#ifdef PROFILE_STREAMFILE #ifdef PROFILE_STREAMFILE
size_t bytes_read; size_t bytes_read;
int error_count; int error_count;
#endif #endif
} STDIOSTREAMFILE; } STDIOSTREAMFILE;
static STREAMFILE * open_stdio_streamfile_buffer_by_FILE(FILE *infile,const char * const filename, size_t buffersize); static STREAMFILE * open_stdio_streamfile_buffer_by_FILE(FILE *infile,const char * const filename, size_t buffersize);
static size_t read_the_rest(uint8_t * dest, off_t offset, size_t length, STDIOSTREAMFILE * streamfile) { static size_t read_the_rest(uint8_t * dest, off_t offset, size_t length, STDIOSTREAMFILE * streamfile) {
size_t length_read_total=0; size_t length_read_total=0;
/* is the beginning at least there? */ /* is the beginning at least there? */
if (offset >= streamfile->offset && offset < streamfile->offset+streamfile->validsize) { if (offset >= streamfile->offset && offset < streamfile->offset+streamfile->validsize) {
size_t length_read; size_t length_read;
off_t offset_into_buffer = offset-streamfile->offset; off_t offset_into_buffer = offset-streamfile->offset;
length_read = streamfile->validsize-offset_into_buffer; length_read = streamfile->validsize-offset_into_buffer;
memcpy(dest,streamfile->buffer+offset_into_buffer,length_read); memcpy(dest,streamfile->buffer+offset_into_buffer,length_read);
length_read_total += length_read; length_read_total += length_read;
length -= length_read; length -= length_read;
offset += length_read; offset += length_read;
dest += length_read; dest += length_read;
} }
/* TODO: What would make more sense here is to read the whole request /* TODO: What would make more sense here is to read the whole request
* at once into the dest buffer, as it must be large enough, and then * at once into the dest buffer, as it must be large enough, and then
* copy some part of that into our own buffer. * copy some part of that into our own buffer.
* The destination buffer is supposed to be much smaller than the * The destination buffer is supposed to be much smaller than the
* STREAMFILE buffer, though. Maybe we should only ever return up * STREAMFILE buffer, though. Maybe we should only ever return up
* to the buffer size to avoid having to deal with things like this * to the buffer size to avoid having to deal with things like this
* which are outside of my intended use. * which are outside of my intended use.
*/ */
/* read as much of the beginning of the request as possible, proceed */ /* read as much of the beginning of the request as possible, proceed */
while (length>0) { while (length>0) {
size_t length_to_read; size_t length_to_read;
size_t length_read=0; size_t length_read=0;
streamfile->validsize=0; streamfile->validsize=0;
if (fseeko(streamfile->infile,offset,SEEK_SET)) return length_read; if (fseeko(streamfile->infile,offset,SEEK_SET)) return length_read;
streamfile->offset=offset; streamfile->offset=offset;
/* decide how much must be read this time */ /* decide how much must be read this time */
if (length>streamfile->buffersize) length_to_read=streamfile->buffersize; if (length>streamfile->buffersize) length_to_read=streamfile->buffersize;
else length_to_read=length; else length_to_read=length;
/* always try to fill the buffer */ /* always try to fill the buffer */
length_read = fread(streamfile->buffer,1,streamfile->buffersize,streamfile->infile); length_read = fread(streamfile->buffer,1,streamfile->buffersize,streamfile->infile);
streamfile->validsize=length_read; streamfile->validsize=length_read;
#ifdef PROFILE_STREAMFILE #ifdef PROFILE_STREAMFILE
if (ferror(streamfile->infile)) { if (ferror(streamfile->infile)) {
clearerr(streamfile->infile); clearerr(streamfile->infile);
streamfile->error_count++; streamfile->error_count++;
} }
streamfile->bytes_read += length_read; streamfile->bytes_read += length_read;
#endif #endif
/* if we can't get enough to satisfy the request we give up */ /* if we can't get enough to satisfy the request we give up */
if (length_read < length_to_read) { if (length_read < length_to_read) {
memcpy(dest,streamfile->buffer,length_read); memcpy(dest,streamfile->buffer,length_read);
length_read_total+=length_read; length_read_total+=length_read;
return length_read_total; return length_read_total;
} }
/* use the new buffer */ /* use the new buffer */
memcpy(dest,streamfile->buffer,length_to_read); memcpy(dest,streamfile->buffer,length_to_read);
length_read_total+=length_to_read; length_read_total+=length_to_read;
length-=length_to_read; length-=length_to_read;
dest+=length_to_read; dest+=length_to_read;
offset+=length_to_read; offset+=length_to_read;
} }
return length_read_total; return length_read_total;
} }
static size_t read_stdio(STDIOSTREAMFILE *streamfile,uint8_t * dest, off_t offset, size_t length) static size_t read_stdio(STDIOSTREAMFILE *streamfile,uint8_t * dest, off_t offset, size_t length)
{ {
// read // read
if (!streamfile || !dest || length<=0) return 0; if (!streamfile || !dest || length<=0) return 0;
/* if entire request is within the buffer */ /* if entire request is within the buffer */
if (offset >= streamfile->offset && offset+length <= streamfile->offset+streamfile->validsize) { if (offset >= streamfile->offset && offset+length <= streamfile->offset+streamfile->validsize) {
memcpy(dest,streamfile->buffer+(offset-streamfile->offset),length); memcpy(dest,streamfile->buffer+(offset-streamfile->offset),length);
return length; return length;
} }
return read_the_rest(dest,offset,length,streamfile); return read_the_rest(dest,offset,length,streamfile);
} }
static void close_stdio(STDIOSTREAMFILE * streamfile) { static void close_stdio(STDIOSTREAMFILE * streamfile) {
fclose(streamfile->infile); fclose(streamfile->infile);
free(streamfile->buffer); free(streamfile->buffer);
free(streamfile); free(streamfile);
} }
static size_t get_size_stdio(STDIOSTREAMFILE * streamfile) { static size_t get_size_stdio(STDIOSTREAMFILE * streamfile) {
fseeko(streamfile->infile,0,SEEK_END); fseeko(streamfile->infile,0,SEEK_END);
return ftello(streamfile->infile); return ftello(streamfile->infile);
} }
static off_t get_offset_stdio(STDIOSTREAMFILE *streamFile) { static off_t get_offset_stdio(STDIOSTREAMFILE *streamFile) {
return streamFile->offset; return streamFile->offset;
} }
static void get_name_stdio(STDIOSTREAMFILE *streamfile,char *buffer,size_t length) { static void get_name_stdio(STDIOSTREAMFILE *streamfile,char *buffer,size_t length) {
strcpy(buffer,streamfile->name); strcpy(buffer,streamfile->name);
} }
#ifdef PROFILE_STREAMFILE #ifdef PROFILE_STREAMFILE
static size_t get_bytes_read_stdio(STDIOSTREAMFILE *streamFile) { static size_t get_bytes_read_stdio(STDIOSTREAMFILE *streamFile) {
return streamFile->bytes_read; return streamFile->bytes_read;
} }
static size_t get_error_count_stdio(STDIOSTREAMFILE *streamFile) { static size_t get_error_count_stdio(STDIOSTREAMFILE *streamFile) {
return streamFile->error_count; return streamFile->error_count;
} }
#endif #endif
static STREAMFILE *open_stdio(STDIOSTREAMFILE *streamFile,const char * const filename,size_t buffersize) { static STREAMFILE *open_stdio(STDIOSTREAMFILE *streamFile,const char * const filename,size_t buffersize) {
int newfd; int newfd;
FILE *newfile; FILE *newfile;
STREAMFILE *newstreamFile; STREAMFILE *newstreamFile;
if (!filename) if (!filename)
return NULL; return NULL;
// if same name, duplicate the file pointer we already have open // if same name, duplicate the file pointer we already have open
if (!strcmp(streamFile->name,filename)) { if (!strcmp(streamFile->name,filename)) {
if (((newfd = dup(fileno(streamFile->infile))) >= 0) && if (((newfd = dup(fileno(streamFile->infile))) >= 0) &&
(newfile = fdopen( newfd, "rb" ))) (newfile = fdopen( newfd, "rb" )))
{ {
newstreamFile = open_stdio_streamfile_buffer_by_FILE(newfile,filename,buffersize); newstreamFile = open_stdio_streamfile_buffer_by_FILE(newfile,filename,buffersize);
if (newstreamFile) { if (newstreamFile) {
return newstreamFile; return newstreamFile;
} }
// failure, close it and try the default path (which will probably fail a second time) // failure, close it and try the default path (which will probably fail a second time)
fclose(newfile); fclose(newfile);
} }
} }
// a normal open, open a new file // a normal open, open a new file
return open_stdio_streamfile_buffer(filename,buffersize); return open_stdio_streamfile_buffer(filename,buffersize);
} }
static STREAMFILE * open_stdio_streamfile_buffer_by_FILE(FILE *infile,const char * const filename, size_t buffersize) { static STREAMFILE * open_stdio_streamfile_buffer_by_FILE(FILE *infile,const char * const filename, size_t buffersize) {
uint8_t * buffer; uint8_t * buffer;
STDIOSTREAMFILE * streamfile; STDIOSTREAMFILE * streamfile;
buffer = calloc(buffersize,1); buffer = calloc(buffersize,1);
if (!buffer) { if (!buffer) {
return NULL; return NULL;
} }
streamfile = calloc(1,sizeof(STDIOSTREAMFILE)); streamfile = calloc(1,sizeof(STDIOSTREAMFILE));
if (!streamfile) { if (!streamfile) {
free(buffer); free(buffer);
return NULL; return NULL;
} }
streamfile->sf.read = (void*)read_stdio; streamfile->sf.read = (void*)read_stdio;
streamfile->sf.get_size = (void*)get_size_stdio; streamfile->sf.get_size = (void*)get_size_stdio;
streamfile->sf.get_offset = (void*)get_offset_stdio; streamfile->sf.get_offset = (void*)get_offset_stdio;
streamfile->sf.get_name = (void*)get_name_stdio; streamfile->sf.get_name = (void*)get_name_stdio;
streamfile->sf.get_realname = (void*)get_name_stdio; streamfile->sf.get_realname = (void*)get_name_stdio;
streamfile->sf.open = (void*)open_stdio; streamfile->sf.open = (void*)open_stdio;
streamfile->sf.close = (void*)close_stdio; streamfile->sf.close = (void*)close_stdio;
#ifdef PROFILE_STREAMFILE #ifdef PROFILE_STREAMFILE
streamfile->sf.get_bytes_read = (void*)get_bytes_read_stdio; streamfile->sf.get_bytes_read = (void*)get_bytes_read_stdio;
streamfile->sf.get_error_count = (void*)get_error_count_stdio; streamfile->sf.get_error_count = (void*)get_error_count_stdio;
#endif #endif
streamfile->infile = infile; streamfile->infile = infile;
streamfile->buffersize = buffersize; streamfile->buffersize = buffersize;
streamfile->buffer = buffer; streamfile->buffer = buffer;
strcpy(streamfile->name,filename); strcpy(streamfile->name,filename);
return &streamfile->sf; return &streamfile->sf;
} }
STREAMFILE * open_stdio_streamfile_buffer(const char * const filename, size_t buffersize) { STREAMFILE * open_stdio_streamfile_buffer(const char * const filename, size_t buffersize) {
FILE * infile; FILE * infile;
STREAMFILE *streamFile; STREAMFILE *streamFile;
infile = fopen(filename,"rb"); infile = fopen(filename,"rb");
if (!infile) return NULL; if (!infile) return NULL;
streamFile = open_stdio_streamfile_buffer_by_FILE(infile,filename,buffersize); streamFile = open_stdio_streamfile_buffer_by_FILE(infile,filename,buffersize);
if (!streamFile) { if (!streamFile) {
fclose(infile); fclose(infile);
} }
return streamFile; return streamFile;
} }
/* Read a line into dst. The source files are MS-DOS style, /* Read a line into dst. The source files are MS-DOS style,
* separated (not terminated) by CRLF. Return 1 if the full line was * separated (not terminated) by CRLF. Return 1 if the full line was