common/messager.cc

Go to the documentation of this file.

//
// messager - This is a super-class/interface describing things that send
// messages (and/or data).  It holds a list of recipients (Messagables),
// and the necessary functionality to deal with it.
//

#include "consmgr.h"
#include "messager.h"
#include "guard.h"

Messager::Messager()
{
    int         ret;

    ret = pthread_mutex_init(&recip_mutex, NULL);
    PTHREAD_CHECK_AND_THROW(ret, "mutex_init(recip_mutex)");

    return;
}

Messager::~Messager(void)
{
    int         ret;

    ret = pthread_mutex_destroy(&recip_mutex);
    PTHREAD_CHECK_AND_THROW(ret, "mutex_destroy(recip_mutex)");

    return;
}

// Add a recipient to the list of recipients for this Messager's data
void
Messager::add_recipient(const Messageable *outlet)
{
    if (!outlet)
        throw(CMInvalidParameter("Tried to add a NULL Messageble* to recipient list"));
    
    Guard       locker(&recip_mutex);

    this->recipients.push_back(const_cast<Messageable*>(outlet));

    return;
}

// Delete a recipient from the list (set) of recipients for this Messager
void
Messager::del_recipient(const Messageable *messageable)
{
    Guard       locker(&recip_mutex);

    this->recipients.remove(const_cast<Messageable*>(messageable));

    return;
}

void
Messager::send_message(MessageP &message) const
{
    // XXX - Is there something I need to do to add to message's ref-count?

    Guard       locker(&recip_mutex);

    for (recipient_const_iterator ri = recipients.begin() ;
         ri != recipients.end() ; ri++) {
        clog << "Sending message " << message->name();
        if (message->type() == Message::M_Data) {
            clog << " ("
                 << dynamic_cast<Data*>(MessageP::GetPointer(message))->len()
                 << " bytes)";
        }
        clog << " to recipient " << (*ri)->get_id() << endl;
        (*ri)->queue_message(message);
        clog << "Message " << message << " sent." << endl;
    }

    return;

}

---