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_ */