X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fio%2Fbase.cpp;h=9c2b40a1f2a9460eee16a34f6e0b08aab245786c;hp=926440a9c4575da477b37e4ad60eea3593ef86a4;hb=be8ea216d23bf36bdfb2d3e302638782575fc136;hpb=c21ab7e49852585df01b4cc19599e25a918b581b

diff --git a/source/io/base.cpp b/source/io/base.cpp
index 926440a..9c2b40a 100644
--- a/source/io/base.cpp
+++ b/source/io/base.cpp
@@ -8,12 +8,20 @@ namespace IO {
 
 Base::Base():
 	mode(M_READ),
-	eof_flag(false)
+	eof_flag(false),
+	mutex(0)
 { }
 
 Base::~Base()
 {
 	signal_deleted.emit();
+	delete mutex;
+}
+
+void Base::check_access(Mode m) const
+{
+	if(!(mode&m))
+		throw invalid_access(m);
 }
 
 bool Base::getline(string &line)
@@ -23,7 +31,7 @@ bool Base::getline(string &line)
 	if(eof_flag)
 		return false;
 
-	while(1)
+	while(!eof())
 	{
 		int c = get();
 		if(c==-1 || c=='\n')
@@ -42,5 +50,28 @@ int Base::get()
 	return static_cast<unsigned char>(c);
 }
 
+void Base::set_eof()
+{
+	if(!eof_flag)
+	{
+		eof_flag = true;
+		signal_end_of_file.emit();
+	}
+}
+
+
+Base::Synchronize::Synchronize(Base &i):
+	io(i)
+{
+	if(!io.mutex)
+		io.mutex = new Mutex;
+	io.mutex->lock();
+}
+
+Base::Synchronize::~Synchronize()
+{
+	io.mutex->unlock();
+}
+
 } // namespace IO
 } // namespace Msp