source/io/buffered.h

   1 #ifndef MSP_IO_BUFFERED_H_
   2 #define MSP_IO_BUFFERED_H_
   3
   4 #include <sigc++/trackable.h>
   5 #include <msp/core/mspcore_api.h>
   6 #include "base.h"
   7
   8 namespace Msp {
   9 namespace IO {
  10
  11 class MSPCORE_API Buffered: public Base, public sigc::trackable
  12 {
  13 private:
  14         Base &below;
  15         std::size_t buf_size = 0;
  16         char *buf = nullptr;
  17         char *begin = nullptr;
  18         char *end = nullptr;
  19         Mode cur_op = M_NONE;
  20
  21 public:
  22         Buffered(Base &, unsigned = 8192);
  23         ~Buffered();
  24
  25         void set_block(bool) override;
  26         void set_inherit(bool) override;
  27
  28         void flush();
  29
  30 protected:
  31         std::size_t do_write(const char *, std::size_t) override;
  32         std::size_t do_read(char *, std::size_t) override;
  33 public:
  34         std::size_t put(char) override;
  35
  36         bool getline(std::string &) override;
  37         int get() override;
  38
  39         const Handle &get_handle(Mode) override;
  40
  41 private:
  42         void set_op(Mode);
  43 public:
  44         Mode get_current_op() const { return cur_op; }
  45         std::size_t get_current_size() const;
  46 };
  47
  48 } // namespace IO
  49 } // namespace Msp
  50
  51 #endif