channel.h

Go to the documentation of this file.

#ifndef CHANNEL_INCLUDED
#define CHANNEL_INCLUDED

#include <cassert>

#include "Communicator/communicator.h"

static const int max_dimension = 8;

// forward declaration
class ChannelSet;


class Channel {
 public:
  typedef char element_type;    

  Channel();                
  Channel(const int count); 
  Channel(void *buf); 
  virtual ~Channel();       

  int start();              
  int wait();               

  inline element_type& operator[](unsigned int idx) { return m_buf[idx]; }
  inline element_type operator[](unsigned int idx) const { return m_buf[idx]; }
  inline const element_type *ptr() { return &m_buf[0]; }

 private:
  element_type *m_buf;  
  bool m_my_buf;  

  friend class Communicator;
  friend class ChannelSet;
};


class ChannelSet {
 public:
  ChannelSet(int nchannel = 8); 

  int append(Channel *const p); 

  int start();                  
  int wait();                   
};
#endif /* _CHANNEL_H_ */