X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;ds=sidebyside;f=source%2Fio%2Fmemory.cpp;h=616150f0ab72937e40989ae19dcdd401d5a95981;hb=c8bf2d6c15893ccc9dbc4e04611b7229029f4808;hp=6ccf84654764cbe8086a3ac841330580d302dcd1;hpb=df5ab3d867c51d72344e443e3adb05bfa29a2b53;p=libs%2Fcore.git diff --git a/source/io/memory.cpp b/source/io/memory.cpp index 6ccf846..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,57 +37,87 @@ 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) { - eof_flag = true; + 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) { - eof_flag = true; + set_eof(); return -1; } 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; }