PipeQ.h

Go to the documentation of this file.

#ifndef PIPEQ_h
#define PIPEQ_h

#include "Pipe.h"

namespace sza {
  namespace util {
    
    template<class Msg>
      class PipeQ {
      
      public:
      
      PipeQ();
      
      ~PipeQ();
      
      void sendMsg(Msg* msg);
      
      void readMsg(Msg* msg);
      
      int fd();
      
      fd_set rfds();
      
      private:
      
      Pipe pipe_;
    };
    
    template<class Msg>
      void PipeQ<Msg>::sendMsg(Msg* msg) 
      {
        pipe_.writePipe((void*) msg, sizeof(Msg), -1);
      };
    
    template<class Msg>
      void PipeQ<Msg>::readMsg(Msg* msg) 
      {
        pipe_.readPipe((void*) msg, sizeof(Msg), -1);
      };
    
    template<class Msg>
      int PipeQ<Msg>::fd() 
      {
        return pipe_.fd();
      };
    
    template<class Msg>
      fd_set PipeQ<Msg>::rfds() 
      {
        return pipe_.rfds();
      };
    
    template<class Msg>
      PipeQ<Msg>::PipeQ() {};
    
    template<class Msg>
      PipeQ<Msg>::~PipeQ() {};
    
  }; // End namespace util
}; // End namespace sza

#endif