X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fio%2Fbase.cpp;h=da2b5a98cb1c8db3f211b292137783b0c19d4e7d;hb=4e8408b966dfe65d971237c72a892f4720d885b1;hp=48de3ee56ca8e3fc304f5d4caca2fcf8a57b8a9a;hpb=c7afef88380ebebc8c2b04e48664d73281ec8848;p=libs%2Fcore.git

diff --git a/source/io/base.cpp b/source/io/base.cpp
index 48de3ee..da2b5a9 100644
--- a/source/io/base.cpp
+++ b/source/io/base.cpp
@@ -8,13 +8,20 @@ namespace IO {
 
 Base::Base():
 	mode(M_READ),
-	events(P_NONE),
-	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)
@@ -43,18 +50,32 @@ int Base::get()
 	return static_cast<unsigned char>(c);
 }
 
-void Base::set_events(PollEvent e)
+void Base::set_eof()
 {
-	events = e;
-	signal_events_changed.emit(events);
+	if(!eof_flag)
+	{
+		eof_flag = true;
+		signal_end_of_file.emit();
+	}
 }
 
-void Base::event(PollEvent ev)
+const Handle &Base::get_handle(Mode)
 {
-	if(ev&P_INPUT)
-		signal_data_available.emit();
+	throw logic_error("Base::get_handle");
+}
 
-	on_event(ev);
+
+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