---

UnicastRequestEvent.h

/*
 * 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: UnicastRequestEvent.h,v 1.3 2004/05/19 15:56:59 mmarsh Exp $
//
// $Log: UnicastRequestEvent.h,v $
// Revision 1.3  2004/05/19 15:56:59  mmarsh
// *** empty log message ***
//
// Revision 1.2  2003/11/04 22:31:51  mmarsh
// *** empty log message ***
//
//

#ifndef __CODEX_SERVER_UNICASTREQUESTEVENT_H__
#define __CODEX_SERVER_UNICASTREQUESTEVENT_H__

#include "CODEX_Events/Event.h"
#include "CODEX_Events/Activity.h"
#include "CODEX_Quorum/Message.h"
#include "CODEX_Quorum/ResponseCallback.h"
#include "CODEX_Quorum/QuorumSystem.h"
#include "UnicastRequestHandler.h"
#include "ServerState.h"

namespace CODEX_Server
{
   class UnicastRequestEvent : public CODEX_Events::EventBase
   {
      public :
         UnicastRequestEvent( CODEX_Events::Activity* source,
                              UnicastRequestHandler* destination,
                              const CODEX_Quorum::MessageVector& messages,
                              const unsigned char* key,
                              CODEX_Quorum::ResponseCallback* cb );

         virtual ~UnicastRequestEvent();

         const CODEX_Quorum::MessageVector& messages() const
         {
            return m_messages;
         }

         const unsigned char* key() const { return m_key; }

         CODEX_Quorum::ReturnVector& retVals() { return m_retVals; }

         CODEX_Quorum::ResponseCallback* cb() const { return m_cb; }

         bool bcast() const { return m_bcast; }

         void setBcast() { m_bcast = true; }

         unsigned long time() const { return m_time; }

         void updateTime( unsigned long time ) { m_time = time; }

         bool handle() { return m_destination->handler( *this ); }

      private :
         UnicastRequestHandler*           m_destination;
         CODEX_Quorum::MessageVector      m_messages;
         unsigned char                    m_key[ ServerState::nMID ];
         CODEX_Quorum::ResponseCallback*  m_cb;
         CODEX_Quorum::ReturnVector       m_retVals;
         bool                             m_bcast;
         unsigned long                    m_time;
   };

}

#endif /* __CODEX_SERVER_UNICASTREQUESTEVENT_H__ */

---