cosyrte.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 "rte.h"
#include "cosynetwork.h"
#include "cosyprocess.h"
#include "cosyfifo.h"
#include "cosyselect.h"
#include "check.h"
#include "network.h"
#include <stdlib.h>
#include <iostream>

/*----------------------------------------------------------------------------*/

rteNetwork* cosyRte::create(NetworkImpl& n)
{
#ifdef PREEMPTIVE
  lock();   // enter critical section
#endif
        rteNetwork* r = new cosyNetwork(n,*os, *this);
#ifdef PREEMPTIVE
  unlock(); // leave critical section
#endif
  return r;
}

/*----------------------------------------------------------------------------*/

rteProcess* cosyRte::create(ProcessImpl& p)
{
#ifdef PREEMPTIVE
  lock();   // enter critical section
#endif
        rteProcess* r = new cosyProcess(p, *this);
#ifdef PREEMPTIVE
  unlock(); // leave critical section
#endif
  return r;
}

/*----------------------------------------------------------------------------*/

rteFifo* cosyRte::create(FifoImpl& f)
{
#ifdef PREEMPTIVE
  lock();   // enter critical section
#endif
        rteFifo* r = new cosyFifo(f, *this);
#ifdef PREEMPTIVE
  unlock(); // leave critical section
#endif
  return r;
}

/*----------------------------------------------------------------------------*/

rteSelect* cosyRte::create(SelectImpl& s)
{
#ifdef PREEMPTIVE
  lock();   // enter critical section
#endif
        rteSelect* r = new cosySelect(s, *this);
#ifdef PREEMPTIVE
  unlock(); // leave critical section
#endif
  return r;
}

/*----------------------------------------------------------------------------*/

#ifdef PREEMPTIVE
void cosyRte::lock()
{
  mutex.lock();
}

/*----------------------------------------------------------------------------*/

void cosyRte::unlock()
{
  mutex.unlock();
}
#endif

/*----------------------------------------------------------------------------*/

cosyRte::cosyRte() : 
  Rte(),
  os(boot())
{
  outStream = &std::cout;
  errStream = &std::cerr;
  inStream  = &std::cin;
}

/*----------------------------------------------------------------------------*/

cosyRte::~cosyRte()
{ 
  delete os;
}

/*----------------------------------------------------------------------------*/

void cosyRte::start(ProcessNetwork& n)
{
  if (check(&(NetworkBase&)n, cerr()) != 0)
    exit(1);

  rteNetwork* net = create((NetworkImpl&)n);

  net->start();
  net->api()->compWorkload->clean();
  net->api()->commWorkload->clean();
  ((cosyNetwork*)net)->printComputationWorkload();
  ((cosyNetwork*)net)->printCommunicationWorkload();
  
  delete net;
}

/*----------------------------------------------------------------------------*/

Rte* newRte() {
  return new cosyRte();
}

/*----------------------------------------------------------------------------*/

void start(ProcessNetwork& n) {

  cosyRte* rte = new cosyRte();
        rte->start(n);
  delete rte;
}

---