rteport.cc

Go to the documentation of this file.

/*--------------------------------------------------------------------
 *
 * (C) Copyright Koninklijke Philips Electronics NV 2006. 
 * All rights reserved. This software is licensed under the terms of
 * version 2.1 of the GNU Lesser General Public License as published 
 * by the Free Software Foundation. For licensing and warranty
 * information, see the file COPYING in the main directory.
 *
 *------------------------------------------------------------------*/

#include "rteport.h"
#include "rtefifo.h"
#include "portimpl.h"

rteInPort::rteInPort(InPortImpl& i, rteFifo& f) :
  base(&i),
  fifo(&f)
{ 
  base->impl = this;
  fifo->in = this;
}

rteInPort::~rteInPort() 
{
  base->impl = 0;
  fifo->in = 0;
}

const InPortImpl* rteInPort::api() const
{
  return base;
}

void rteInPort::read(void* p, unsigned int nitems)
{
  fifo->read(p, nitems);
}


rteOutPort::rteOutPort(OutPortImpl& o, rteFifo& f) :
  base(&o),
  fifo(&f)
{ 
  base->impl.push_back(this);
  fifo->out = this;
}

rteOutPort::~rteOutPort() 
{
  std::vector<rteOutPort*>::iterator i;
  for(i = base->impl.begin(); i != base->impl.end(); ++i)
    if (*i == this)
      break;
  if (*i == this)
    base->impl.erase(i);
  fifo->out = 0;
}

const OutPortImpl* rteOutPort::api() const
{
  return base;
}

void rteOutPort::write(const void* p, unsigned int nitems)
{
  fifo->write(p, nitems);
}

---