PipeQueue.h

Go to the documentation of this file.

#ifndef GCP_UTIL_PIPEQUEUE_H
#define GCP_UTIL_PIPEQUEUE_H

#include "gcp/util/common/Pipe.h"

#include <queue>

namespace gcp {
  namespace util {
    
    class PipeQueue : public Pipe {
      
    public:
    
      // A class for handling a single message

      class QueueNode {
      public:
    
    QueueNode();
    QueueNode(void* buffer, size_t nbyte);

    QueueNode(const QueueNode& node);
    QueueNode(QueueNode& node);
    void operator=(const QueueNode& node);
    void operator=(QueueNode& node);

    ~QueueNode();

    unsigned nbyte_;
    unsigned char* buffer_;

      };

    // A class for handling a queue of messages

      class MsgQueue {
      public:

    void push(void* buffer, size_t nbyte);
    void pop(void* buffer, size_t nbyte);
    
      private:

    std::queue<QueueNode> queue_;

      };

      PipeQueue();
      
      ~PipeQueue();
      
      PipeState write(void *buffer, size_t nbyte, long timeout=PIPE_NOWAIT);
      
      PipeState read(void *buffer, size_t nbyte, long timeout=PIPE_NOWAIT);
      
    public:

      Mutex queueGuard_;
      MsgQueue messages_;

    }; // End class Pipe
    
  }; // End namespace util
}; // End namespace gcp

#endif // PIPE_H