SupportedClientResponseEvent.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: SupportedClientResponseEvent.h,v 1.4 2005/01/21 19:44:17 mmarsh Exp $
//
// $Log: SupportedClientResponseEvent.h,v $
// Revision 1.4  2005/01/21 19:44:17  mmarsh
// Updated for compatibility with Doxygen 1.4.1
//
// Revision 1.3  2004/05/19 15:56:53  mmarsh
// *** empty log message ***
//
// Revision 1.2  2003/11/04 22:31:49  mmarsh
// *** empty log message ***
//
//

#ifndef __CODEX_KEYSERVICE_SUPPORTEDCLIENTRESPONSEEVENT_H__
#define __CODEX_KEYSERVICE_SUPPORTEDCLIENTRESPONSEEVENT_H__

#include "CODEX_Events/Event.h"
#include "SupportedClientResponse.h"
#include "CODEX_Server/RoutingInfo.h"

namespace CODEX_KeyService
{
   class SupportedClientResponseHandler;

   class SupportedClientResponseEventBase : public CODEX_Events::EventBase,
                                            public CODEX_Server::RoutingInfo
   {
      public :
         SupportedClientResponseEventBase( CODEX_Events::Activity* source,
                                           unsigned char* server,
                                           unsigned char* seqNum ) :
            CODEX_Events::EventBase( source ),
            RoutingInfo( server, seqNum )
         {}

         virtual ~SupportedClientResponseEventBase() {}

         virtual int marshal( unsigned char ** pp ) = 0;

         virtual bool unmarshal( unsigned char ** pp, long length ) = 0;
   };

   template< class RespT , class ReqT >
   class SupportedClientResponseEvent : public SupportedClientResponseEventBase
   {
      public :
         typedef SupportedClientResponse< RespT , ReqT > MsgType;

         SupportedClientResponseEvent(
            CODEX_Events::Activity* source,
            unsigned char* server,
            unsigned char* seqNum,
            SupportedClientResponseHandler* destination,
            const MsgType& message ) :
            SupportedClientResponseEventBase( source, server, seqNum ),
            m_destination( destination ),
            m_message( message )
         {}

         SupportedClientResponseEvent(
            CODEX_Events::Activity* source,
            unsigned char* server,
            unsigned char* seqNum,
            SupportedClientResponseHandler* destination ) :
            SupportedClientResponseEventBase( source, server, seqNum ),
            m_destination( destination )
         {}

         virtual ~SupportedClientResponseEvent() {}

         const MsgType& message() const { return m_message; }

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

         void reRoute( SupportedClientResponseHandler* newDestination )
         {
            m_destination = newDestination;
         }

         int marshal( unsigned char ** pp )
         {
            return m_message.marshal(pp);
         }

         bool unmarshal( unsigned char ** pp, long length )
         {
            if ( NULL == m_message.unmarshal( NULL, pp, length ) )
            {
               return false;
            }
            return true;
         }

      private :
         SupportedClientResponseHandler*  m_destination;
         MsgType                          m_message;
   };
}

#endif /* __CODEX_KEYSERVICE_SUPPORTEDCLIENTRESPONSEEVENT_H__ */

---