---

MessageDeliverer.cc

/*
 * Copyright 2003 Michael A. Marsh, Cornell University. All rights reserved.
 * This software is released under the modified BSD license.
 * See the file LICENSE in the top-level directory for details.
 */
//
// $Id: MessageDeliverer.cc,v 1.3 2004/05/19 15:56:24 mmarsh Exp $
//
// $Log: MessageDeliverer.cc,v $
// Revision 1.3  2004/05/19 15:56:24  mmarsh
// Added copyright and license statements.
//
// Revision 1.2  2003/11/04 22:31:45  mmarsh
// *** empty log message ***
//
//

#include "MessageDeliverer.h"
#include "CODEX_Server/ServerResponseEvent.h"
#include "CODEX_Server/BroadcastRequestEvent.h"

using namespace CODEX_APSS;

MessageDeliverer::MessageDeliverer(
   CODEX_Events::DeadPileType& deadPile,
   CODEX_Events::QType& eventQueue,
   CODEX_Server::ServerResponseHandler* responder,
   CODEX_Server::BroadcastRequestHandler* broadcaster ) :
   CODEX_Events::Activity( deadPile, eventQueue ),
   m_responder( responder ),
   m_broadcaster( broadcaster )
{
}

MessageDeliverer::~MessageDeliverer()
{
}

void
MessageDeliverer::sendTo( unsigned int server,
                          const CODEX_Quorum::Message& message )
{
   CODEX_Server::ServerResponseEvent* event =
      new CODEX_Server::ServerResponseEvent( this,
                                             m_responder,
                                             message,
                                             server );
   sendEvent( event, 0 );
}

void
MessageDeliverer::broadcast( const CODEX_Quorum::Message& message,
                             CODEX_Quorum::ResponseCallback* cb )
{
   CODEX_Server::BroadcastRequestEvent* event =
      new CODEX_Server::BroadcastRequestEvent( this,
                                               m_broadcaster,
                                               message,
                                               cb );
   sendEvent( event, 0 );
}

---