cosyprocess.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 <sys/types.h>
#include "cosyprocess.h"
#include "processimpl.h"
#include "taskapi.h"
#include <assert.h>
#include "rte.h"


static void run_cosy_process(void* arg)
{
  cosyProcess* p = (cosyProcess*)arg;
  p->api()->main();
  p->exit();
}

cosyProcess::cosyProcess(ProcessImpl& p, cosyRte& r) : 
  rteProcess(p),
  run(false)
{
  rte = &r;
  task = new Task(run_cosy_process, this);
}

cosyProcess::~cosyProcess()
{ 
  assert(!run);
  Counters::iterator i;
  for (i=cntr.begin(); i!=cntr.end(); ++i)
  {
    free((*i).name);
  }

  delete task;
}

void cosyProcess::start()
{
#ifdef PREEMPTIVE
  lock();   // enter critical section
#endif
  run = true;
  task->start();
#ifdef PREEMPTIVE
  unlock(); // leave critical section
#endif
}

void cosyProcess::exit()
{
#ifdef PREEMPTIVE
  lock();   // enter critical section
#endif
  run = false;
#ifdef PREEMPTIVE
  unlock(); // leave critical section
#endif
  task->exit(); 
}

void cosyProcess::join()
{
  if (run)
  {
    task->join();
  }
}

void cosyProcess::kill()
{
#ifdef PREEMPTIVE
  lock();   // enter critical section
#endif
  if (run)
  {
    run = false;
#ifdef PREEMPTIVE
    unlock(); // leave critical section
#endif 
    task->kill();
  } 
#ifdef PREEMPTIVE
  else {  
    unlock(); // leave critical section
  }
#endif 
}

bool cosyProcess::finished() const
{
  return !run;
}

void cosyProcess::execute(const char* instr)
{
  count(cntr, instr);
}

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

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

---