common/messageable.h

Go to the documentation of this file.

//

#ifndef __MESSAGEABLE_H
#define __MESSAGEABLE_H

extern "C" {
#include <pthread.h>
};

#include <deque>

#include "message.h"

class Messageable
{
  public:
    Messageable();
    virtual ~Messageable();

    void        queue_message(MessageP&);

    // XXX - we need to have something that receives messages from the queue,
    // and either deals with them or passes them to handle_message()
    // void     message_receiver(??)

    virtual std::string get_id(void) const = 0;

  protected:
    MessageP    get_message(void);

    /* XXX - Where is this Data from?  Who allocates it? Who free's it? */
    Data        *handle_message(MessageP&);

  private:
    std::deque<MessageP>        msg_queue;
    pthread_mutex_t             msg_mutex;
    pthread_cond_t              msg_avail;
    typedef std::deque<MessageP>::iterator      queue_iterator;
};

#endif  /* __MESSAGEABLE_H */

---