X-Git-Url: http://git.tdb.fi/?a=blobdiff_plain;f=source%2Fio%2Fbuffered.h;h=cd742fee291ea4614c6f0a1d8190bb1d67bbfa49;hb=f24e7b96e76b63c9b9b8a6bce4c7a9db64276ea8;hp=36d2a1165a3e52b7413397bf01575984efa3ac49;hpb=6e0fd758970bcb5bad5e3f2454b694cc4d7b4b66;p=libs%2Fcore.git diff --git a/source/io/buffered.h b/source/io/buffered.h index 36d2a11..cd742fe 100644 --- a/source/io/buffered.h +++ b/source/io/buffered.h @@ -1,16 +1,17 @@ #ifndef MSP_IO_BUFFERED_H_ #define MSP_IO_BUFFERED_H_ +#include #include "base.h" namespace Msp { namespace IO { -class Buffered: public Base +class Buffered: public Base, public sigc::trackable { private: Base &below; - unsigned buf_size; + std::size_t buf_size; char *buf; char *begin; char *end; @@ -20,24 +21,27 @@ public: Buffered(Base &, unsigned =8192); ~Buffered(); + virtual void set_block(bool); + virtual void set_inherit(bool); + void flush(); protected: - unsigned do_write(const char *, unsigned); - unsigned do_read(char *, unsigned); + virtual std::size_t do_write(const char *, std::size_t); + virtual std::size_t do_read(char *, std::size_t); public: - unsigned put(char); + virtual std::size_t put(char); bool getline(std::string &); int get(); + virtual const Handle &get_handle(Mode); + private: void set_op(Mode); public: Mode get_current_op() const { return cur_op; } - unsigned get_current_size() const; - - virtual Handle get_event_handle(); + std::size_t get_current_size() const; }; } // namespace IO