X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fio%2Ffile.cpp;h=d4b2da3454f0a29e3ba32808256780ba6aa8954d;hp=0f5652ad9484cf460a2e266f666470c00b67dd02;hb=3f7aa81d9212811b323d89949adcccda212cbed3;hpb=a56e05106571f28dc3044296849ccd5127d7d859 diff --git a/source/io/file.cpp b/source/io/file.cpp index 0f5652a..d4b2da3 100644 --- a/source/io/file.cpp +++ b/source/io/file.cpp @@ -17,7 +17,9 @@ File::File(const string &fn, Mode m, CreateMode cm) { if(!(m&M_RDWR)) throw invalid_argument("File::File mode"); - if(cm&~(C_CREATE|C_TRUNCATE)) + if(cm&~(C_CREATE|C_TRUNCATE|C_EXCLUSIVE)) + throw invalid_argument("File::File create"); + if((cm&C_EXCLUSIVE) && (!(cm&C_CREATE) || (cm&C_TRUNCATE))) throw invalid_argument("File::File create"); mode = m; @@ -37,7 +39,8 @@ File::File(const string &fn, Mode m, CreateMode cm) case C_NONE: create_flags = OPEN_EXISTING; break; case C_CREATE: create_flags = OPEN_ALWAYS; break; case C_TRUNCATE: create_flags = TRUNCATE_EXISTING; break; - case C_CREATE+C_TRUNCATE: create_flags = CREATE_ALWAYS; break; + case C_OVERWRITE: create_flags = CREATE_ALWAYS; break; + case C_NEW: create_flags = CREATE_NEW; break; } } @@ -47,6 +50,8 @@ File::File(const string &fn, Mode m, CreateMode cm) int err = GetLastError(); if(err==ERROR_FILE_NOT_FOUND) throw file_not_found(fn); + else if(err==ERROR_FILE_EXISTS) + throw file_already_exists(fn); else throw system_error(format("CreateFile(%s)", fn), err); } @@ -66,6 +71,8 @@ File::File(const string &fn, Mode m, CreateMode cm) flags |= O_CREAT; if(cm&C_TRUNCATE) flags |= O_TRUNC; + if(cm&C_EXCLUSIVE) + flags |= O_EXCL; } if(mode&M_APPEND) flags |= O_APPEND; @@ -78,6 +85,8 @@ File::File(const string &fn, Mode m, CreateMode cm) int err = errno; if(err==ENOENT) throw file_not_found(fn); + else if(err==EEXIST) + throw file_already_exists(fn); else throw system_error(format("open(%s)", fn), err); } @@ -86,26 +95,12 @@ File::File(const string &fn, Mode m, CreateMode cm) File::~File() { - close(); -} - -void File::close() -{ - if(!handle) - return; - signal_flush_required.emit(); - sys_close(handle); - - handle = Handle(); - signal_closed.emit(); } void File::set_block(bool b) { - check_access(M_NONE); - mode = (mode&~M_NONBLOCK); if(b) mode = (mode|M_NONBLOCK); @@ -139,10 +134,7 @@ unsigned File::do_read(char *buf, unsigned size) unsigned ret = sys_read(handle, buf, size); if(ret==0) - { - eof_flag = true; - signal_end_of_file.emit(); - } + set_eof(); return ret; } @@ -158,8 +150,6 @@ void File::sync() SeekOffset File::seek(SeekOffset off, SeekType type) { - check_access(M_NONE); - signal_flush_required.emit(); off = sys_seek(handle, off, type); eof_flag = false; @@ -169,15 +159,13 @@ SeekOffset File::seek(SeekOffset off, SeekType type) SeekOffset File::tell() const { - check_access(M_NONE); - return sys_seek(const_cast(handle), 0, S_CUR); } -void File::check_access(Mode m) const +const Handle &File::get_handle(Mode m) { - if(!handle || (m && !(mode&m))) - throw invalid_access(m); + check_access(m); + return handle; } } // namespace IO