Actor.hh

Go to the documentation of this file.

#ifndef COSA_NUCLEO_ACTOR_HH
#define COSA_NUCLEO_ACTOR_HH

#include "Thread.hh"

namespace Nucleo {

class Actor : public Thread {
public:
  Actor() :
    Thread(),
    m_receiving(false),
    m_sending(),
    m_port(0),
    m_size(0),
    m_buf(NULL)
  {}

  int send(uint8_t port, const void* buf = NULL, size_t size = 0);

  int recv(Actor*& sender, uint8_t& port, void* buf = NULL, size_t size = 0);

protected:
  volatile bool m_receiving;
  Head m_sending;
  uint8_t m_port;
  size_t m_size;
  const void* m_buf;
};

};
#endif