include/pipe.hpp

   1 #ifndef PIPE_H
   2 #define PIPE_H
   3
   4 namespace Sinkhole
   5 {
   6         struct PipeData
   7         {
   8                 int rfd, wfd;
   9
  10                 PipeData();
  11         };
  12
  13         class Pipe : public Socket
  14         {
  15                 /** The FD of the write pipe
  16                  * this->Sock is the readfd
  17                  */
  18                 int WriteFD;
  19          public:
  20                 /** Default constructor
  21                  * @param d Pipe data for r/w sockets
  22                  */
  23                 Pipe(PipeData d);
  24
  25                 /** Destructor, closes WriteFD
  26                  */
  27                 ~Pipe();
  28
  29                 /** Allocates and returns a new Pipe
  30                  * @return the new Pipe
  31                  */
  32                 static Pipe *Create();
  33
  34                 /** Called when data is to be read
  35                  */
  36                 bool ProcessRead();
  37
  38                 /** Called when data can be written
  39                  */
  40                 bool ProcessWrite();
  41
  42                 /** Called when this pipe needs to be woken up
  43                  */
  44                 void Notify();
  45
  46                 /** Should be overloaded to do something useful
  47                  */
  48                 virtual void OnNotify() = 0;
  49         };
  50 }
  51
  52 #endif // PIPE_H
  53