channel.cpp

Go to the documentation of this file.

#include "channel.h"

//====================================================================
Channel *Communicator::send_init(int count, int idir, int ipm)
{
  LOG;

  assert(ipm == 1 || ipm == -1);

  Channel *ch = new Channel(count);
  if (!ch) {
    printf("%s: allocate channel failed.\n", __func__);
    exit(EXIT_FAILURE);
  }

  return ch;
}


//====================================================================
Channel *Communicator::recv_init(int count, int idir, int ipm)
{
  LOG;

  assert(ipm == 1 || ipm == -1);

  Channel *ch = new Channel(count);
  if (!ch) {
    printf("%s: allocate channel failed.\n", __func__);
    exit(EXIT_FAILURE);
  }

  return ch;
}


//====================================================================
Channel *Communicator::send_init(int count, int idir, int ipm, void *buf)
{
  LOG;

  assert(ipm == 1 || ipm == -1);

  Channel *ch = new Channel(buf);
  if (!ch) {
    printf("%s: allocate channel failed.\n", __func__);
    exit(EXIT_FAILURE);
  }

  return ch;
}


//====================================================================
Channel *Communicator::recv_init(int count, int idir, int ipm, void *buf)
{
  LOG;

  assert(ipm == 1 || ipm == -1);

  Channel *ch = new Channel(buf);
  if (!ch) {
    printf("%s: allocate channel failed.\n", __func__);
    exit(EXIT_FAILURE);
  }

  return ch;
}


//====================================================================
// class Channel
Channel::Channel()
  : m_buf(NULL),
  m_my_buf(false)
{
}


Channel::Channel(void *buf)
  : m_buf(reinterpret_cast<element_type *>(buf)),
  m_my_buf(false)
{
}


Channel::Channel(const int count)
{
  m_buf    = new element_type[count];
  m_my_buf = true;
}


Channel::~Channel()
{
  if (m_my_buf) delete [] m_buf;

  m_buf    = NULL;
  m_my_buf = false;
}


//====================================================================
int Channel::start()
{
  return 0;
}


//====================================================================
int Channel::wait()
{
  return 0;
}


//====================================================================
// class ChannelSet
ChannelSet::ChannelSet(int count)
{
  LOG;
}


//====================================================================
int ChannelSet::append(Channel *p)
{
  return 0;
}


//====================================================================
int ChannelSet::start()
{
  return 0;
}


//====================================================================
int ChannelSet::wait()
{
  return 0;
}


//====================================================================
//============================================================END=====