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)
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