PipeQ.h

Go to the documentation of this file.

#ifndef PIPEQ_H
#define PIPEQ_H

#include "Pipe.h"

namespace gcp {
  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 gcp


#endif