X-Git-Url: http://git.tdb.fi/?p=libs%2Fcore.git;a=blobdiff_plain;f=source%2Fio%2Fbase.h;h=c58be90f7ebd039504e261105e53dc7329a1ac13;hp=9447c66fc9a6551dcdcb5644c9333b882de7dcec;hb=5a32939eb6e576c223e1be5f80226d9e628a2398;hpb=df5ab3d867c51d72344e443e3adb05bfa29a2b53 diff --git a/source/io/base.h b/source/io/base.h index 9447c66..c58be90 100644 --- a/source/io/base.h +++ b/source/io/base.h @@ -2,6 +2,8 @@ #define MSP_IO_BASE_H_ #include +#include +#include "handle.h" #include "mode.h" #include "poll.h" @@ -17,6 +19,18 @@ leaving stale pointers in an EventDispatcher. class Base { public: + /** RAII synchronization primitive. Prevents concurrent access to the + target object during the lifetime of the Synchronize object. */ + class Synchronize + { + private: + Base &io; + + public: + Synchronize(Base &); + ~Synchronize(); + }; + /** Emitted when there is no more data to be read. */ sigc::signal signal_end_of_file; @@ -24,9 +38,6 @@ public: seeked) and any data buffered by upper layers needs to be flushed. */ sigc::signal signal_flush_required; - /** Emitted when the I/O object has closed. */ - sigc::signal signal_closed; - /** Emitted when the object is deleted. Mainly for use by EventDispatcher. */ sigc::signal signal_deleted; @@ -34,6 +45,7 @@ public: protected: Mode mode; bool eof_flag; + Mutex *mutex; Base(); private: @@ -85,8 +97,18 @@ public: to end-of-file or non-blocking operation. */ virtual int get(); - /** Returns the end-of-file flag. */ +protected: + void set_eof(); + +public: + /** Returns the end-of-file flag. Note that some types of objects won't + indicate end-of-file until you try to read at least one byte past the actual + end, while others indicate it when you've read the last byte. */ bool eof() const { return eof_flag; } + + /** Returns the system-level handle for the object. Used by Console to + perform redirections. */ + virtual const Handle &get_handle(Mode); }; } // namespace IO