X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fio%2Fmemory.cpp;h=616150f0ab72937e40989ae19dcdd401d5a95981;hb=f24e7b96e76b63c9b9b8a6bce4c7a9db64276ea8;hp=fa8f9053de029e3965f1fd4c261a43e6c4a69c1c;hpb=82d74297d5b469b0a506d7010a84ab5115cd88ee;p=libs%2Fcore.git diff --git a/source/io/memory.cpp b/source/io/memory.cpp index fa8f905..616150f 100644 --- a/source/io/memory.cpp +++ b/source/io/memory.cpp @@ -8,17 +8,17 @@ using namespace std; namespace Msp { namespace IO { -Memory::Memory(char *d, unsigned s) +Memory::Memory(char *d, size_t s, Mode m) { - init(d, d+s, M_RDWR); + init(d, d+s, m); } -Memory::Memory(char *b, char *e) +Memory::Memory(char *b, char *e, Mode m) { - init(b, e, M_RDWR); + init(b, e, m); } -Memory::Memory(const char *cd, unsigned s) +Memory::Memory(const char *cd, size_t s) { char *d = const_cast(cd); init(d, d+s, M_READ); @@ -37,48 +37,73 @@ void Memory::init(char *b, char *e, Mode m) mode = m; } -unsigned Memory::do_write(const char *buf, unsigned size) +void Memory::set_block(bool) +{ + throw logic_error("Memory::set_block"); +} + +void Memory::set_inherit(bool) +{ + throw logic_error("Memory::set_inherit"); +} + +size_t Memory::do_write(const char *buf, size_t size) { check_access(M_WRITE); - size = min(size, end-pos); + size = min(size, end-pos); memcpy(pos, buf, size); pos += size; return size; } -unsigned Memory::do_read(char *buf, unsigned size) +size_t Memory::do_read(char *buf, size_t size) { + check_access(M_READ); + if(pos==end) { set_eof(); return 0; } - size = min(size, end-pos); + size = min(size, end-pos); memcpy(buf, pos, size); pos += size; return size; } -unsigned Memory::put(char c) +size_t Memory::put(char c) { check_access(M_WRITE); + + if(pos==end) + return 0; + *pos++ = c; return 1; } bool Memory::getline(string &line) { + check_access(M_READ); + + if(pos==end) + { + set_eof(); + return false; + } + char *nl = find(pos, end, '\n'); line.assign(pos, nl); - bool result = (nl!=pos); - pos = nl; - return result; + pos = (nl==end ? end : nl+1); + return true; } int Memory::get() { + check_access(M_READ); + if(pos==end) { set_eof(); @@ -88,6 +113,11 @@ int Memory::get() return static_cast(*pos++); } +const Handle &Memory::get_handle(Mode) +{ + throw logic_error("Memory::get_handle"); +} + SeekOffset Memory::seek(SeekOffset off, SeekType type) { char *new_pos; @@ -101,9 +131,10 @@ SeekOffset Memory::seek(SeekOffset off, SeekType type) throw invalid_argument("Memory::seek"); if(new_posend) - throw out_of_range("Memory::seek"); + throw bad_seek(off, type); pos = new_pos; + eof_flag = false; return pos-begin; }