X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fio%2Ffile.cpp;h=1b4a73884d7b5891a43c461d79901bd7e9d1a147;hp=90694324aa1d6e52f8c59b9f649135725926e031;hb=5a32939eb6e576c223e1be5f80226d9e628a2398;hpb=609c9a508cfdc7b42c46c4f21d17639204165a00 diff --git a/source/io/file.cpp b/source/io/file.cpp index 9069432..1b4a738 100644 --- a/source/io/file.cpp +++ b/source/io/file.cpp @@ -39,7 +39,7 @@ unsigned File::do_write(const char *buf, unsigned size) if(size==0) return 0; -#ifdef WIN32 +#ifdef _WIN32 if(mode&M_APPEND) seek(0, S_END); #endif @@ -81,5 +81,66 @@ const Handle &File::get_handle(Mode m) return handle; } + +BufferedFile::BufferedFile(const string &fn, Mode m, File::CreateMode cm): + file(fn, m, cm), + buffer(file), + position(0) +{ + mode = m; + file.signal_end_of_file.connect(sigc::mem_fun(this, &BufferedFile::set_eof)); +} + +unsigned BufferedFile::do_write(const char *buf, unsigned size) +{ + unsigned ret = buffer.write(buf, size); + position += ret; + return ret; +} + +unsigned BufferedFile::do_read(char *buf, unsigned size) +{ + unsigned ret = buffer.read(buf, size); + position += ret; + return ret; +} + +unsigned BufferedFile::put(char c) +{ + unsigned ret = buffer.put(c); + position += ret; + return ret; +} + +bool BufferedFile::getline(string &line) +{ + bool ret = buffer.getline(line); + if(ret) + position += line.size(); + return ret; +} + +int BufferedFile::get() +{ + int ret = buffer.get(); + if(ret>=0) + ++position; + return ret; +} + +SeekOffset BufferedFile::seek(SeekOffset offset, SeekType type) +{ + if(type==S_CUR) + { + offset += position; + type = S_BEG; + } + + signal_flush_required.emit(); + position = file.seek(offset, type); + eof_flag = false; + return position; +} + } // namespace IO } // namespace Msp