MessageClient.cpp

Go to the documentation of this file.

////////////////////////////////////////////////////////////////////////////////
/*! \file MessageClient.cpp
*  \brief Defines the base classes used by the application to communicate.
*  \author $Author: rsharo $
*  \version $Revision: 1.1 $
*  \date    $Date: 2004/04/07 13:45:04 $
*///////////////////////////////////////////////////////////////////////////////
#include "Comm/MessageClient.h"



int MessageClient::Register(MessageServer *pServer)
{
        if (m_pServer != NULL)
        {
                ACE_ERROR_RETURN((LM_ERROR,
                        "(%N:%l) Attempt register a message client twice.\n"),
                        -1);
        }
        
        int retVal = pServer->RegisterClient(m_id, this);
                
        return retVal;
}



int MessageClient::Deregister()
{
        if (m_pServer == NULL)
                return -1;
        
        int retVal = m_pServer->RemoveClient(m_id, this);
                
        return retVal;
}



//
// Constructs a multi-message client.
MultiMessageClient::MultiMessageClient(u_int *id, u_int numIDs)
        : m_numChildren(numIDs)
{
        m_ppChildren = new MC *[m_numChildren];

        for (u_int i = 0; i < m_numChildren; ++i)
        {
                m_ppChildren[i] = new MC(id[i], this);
        }
}

//
// Virtual destructor for the multi-message client.
MultiMessageClient::~MultiMessageClient()
{
        for (u_int i = 0; i < m_numChildren; ++i)
        {
                delete m_ppChildren[i];
        }

        delete [] m_ppChildren;
}


//
// If registered with a message server with the given origination ID,
// this method sends a message to another client.
// It returns -1 on error and the number of bytes sent on success.
int MultiMessageClient::SendMessage(u_int originator, const void *msg, size_t len, u_int dest)
{
        for (u_int i = 0; i < m_numChildren; ++i)
        {
                if (m_ppChildren[i]->id() == originator)
                {
                        return m_ppChildren[i]->SendMessage(msg, len, dest);
                }
        }

        ACE_ERROR_RETURN((LM_ERROR,
                "(%N:%l) Attempt to send a message with ID for which the client"
                " is not registered.\n"),
                -1);
}

//
// Registers this client with a message server.
// Returns 0 if all IDs successfully register and -1 on any failure.
int MultiMessageClient::Register(MessageServer *pServer)
{
        int retVal = 0;

        for (u_int i = 0; i < m_numChildren; ++i)
        {
                if (m_ppChildren[i]->Register(pServer) == -1)
                {
                        retVal = -1;
                }
        }

        return -1;
}

//
// Deregisters this client with its message server.
// Returns 0 if all IDs successfully deregister and -1 on any failure.
int MultiMessageClient::Deregister()
{
        int retVal = 0;

        for (u_int i = 0; i < m_numChildren; ++i)
        {
                if (m_ppChildren[i]->Deregister() == -1)
                {
                        retVal = -1;
                }
        }

        return -1;
}

---