X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fio%2Ffile.cpp;h=5ead278813d7bd73e8c9eae38282e8b07f1d0bd4;hp=666b1edc784b9fc9d0bc76cf29d77b82ff80b826;hb=c8bf2d6c15893ccc9dbc4e04611b7229029f4808;hpb=7b81490ae4ed6c7c8566f889d146677827f5d4a5 diff --git a/source/io/file.cpp b/source/io/file.cpp index 666b1ed..5ead278 100644 --- a/source/io/file.cpp +++ b/source/io/file.cpp @@ -28,18 +28,24 @@ File::~File() void File::set_block(bool b) { - mode = b?(mode&~M_NONBLOCK):(mode|M_NONBLOCK); + adjust_mode(mode, M_NONBLOCK, !b); sys_set_blocking(handle, b); } -unsigned File::do_write(const char *buf, unsigned size) +void File::set_inherit(bool i) +{ + adjust_mode(mode, M_INHERIT, i); + sys_set_inherit(handle, i); +} + +size_t File::do_write(const char *buf, size_t size) { check_access(M_WRITE); if(size==0) return 0; -#ifdef WIN32 +#ifdef _WIN32 if(mode&M_APPEND) seek(0, S_END); #endif @@ -47,14 +53,14 @@ unsigned File::do_write(const char *buf, unsigned size) return sys_write(handle, buf, size); } -unsigned File::do_read(char *buf, unsigned size) +size_t File::do_read(char *buf, size_t size) { check_access(M_READ); if(size==0) return 0; - unsigned ret = sys_read(handle, buf, size); + size_t ret = sys_read(handle, buf, size); if(ret==0) set_eof(); @@ -91,23 +97,33 @@ BufferedFile::BufferedFile(const string &fn, Mode m, File::CreateMode cm): file.signal_end_of_file.connect(sigc::mem_fun(this, &BufferedFile::set_eof)); } -unsigned BufferedFile::do_write(const char *buf, unsigned size) +void BufferedFile::set_block(bool b) +{ + file.set_block(b); +} + +void BufferedFile::set_inherit(bool) { - unsigned ret = buffer.write(buf, size); + throw logic_error("BufferedFile::set_inherit"); +} + +size_t BufferedFile::do_write(const char *buf, size_t size) +{ + size_t ret = buffer.write(buf, size); position += ret; return ret; } -unsigned BufferedFile::do_read(char *buf, unsigned size) +size_t BufferedFile::do_read(char *buf, size_t size) { - unsigned ret = buffer.read(buf, size); + size_t ret = buffer.read(buf, size); position += ret; return ret; } -unsigned BufferedFile::put(char c) +size_t BufferedFile::put(char c) { - unsigned ret = buffer.put(c); + size_t ret = buffer.put(c); position += ret; return ret; } @@ -128,6 +144,11 @@ int BufferedFile::get() return ret; } +const Handle &BufferedFile::get_handle(Mode) +{ + throw logic_error("BufferedFile::get_handle"); +} + SeekOffset BufferedFile::seek(SeekOffset offset, SeekType type) { if(type==S_CUR)