---

MessageParser.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: MessageParser.cc,v 1.3 2004/05/19 15:56:24 mmarsh Exp $
//
// $Log: MessageParser.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 "MessageParser.h"
#include "RoutedMessageEvent.h"
#include "RoutedMessageHandler.h"

#include "timing.h"

using namespace CODEX_APSS;

void
MessageParser::operator()( unsigned char* server,
                           unsigned char* mID,
                           CODEX_Quorum::Message* m )
{
   if ( 0 == m )
   {
      if ( 0 != server ) delete [] server;
      if ( 0 != mID ) delete [] mID;
      return;
   }
#ifdef TIMING
   ActiveTimer.start();
#endif
   const unsigned char* buff = m->buffer();
   long buffLength = m->length();
   unsigned char* pBuff = (unsigned char*) (buff+1);
   RoutedMessageEventBase* evt = NULL;
   switch( buff[0] )
   {
      case (kInitMsg | SignatureMask) :
         evt = new RoutedMessageEvent< SignedInitMsg >(
            this, m_destination, server, mID );
         break;
      case (kEstablishMsg | SignatureMask) :
         evt = new RoutedMessageEvent< SignedEstablishMsg >(
            this, m_destination, server, mID );
         break;
      case (kComputeMsg | SignatureMask) :
         evt = new RoutedMessageEvent< SignedComputeMsg >(
            this, m_destination, server, mID );
         break;
      case (kRecoverMsg | SignatureMask) :
         evt = new RoutedMessageEvent< SignedRecoverMsg >(
            this, m_destination, server, mID );
         break;
      case (kFinishedMsg | SignatureMask) :
         evt = new RoutedMessageEvent< SignedFinishedMsg >(
            this, m_destination, server, mID );
         break;
      default :
         // Bad message type for an APSS request -- drop it.
         if ( 0 != server ) delete [] server;
         if ( 0 != mID ) delete [] mID;
//         cerr << "Bad message type: "
//              << (unsigned int)buff[0]
//              << endl;
         break;
   }
   if ( 0 != evt )
   {
      if ( evt->unmarshal( &pBuff, buffLength ) )
      {
         // Enqueue the event.
         sendEvent( evt, 0 );
      }
      else
      {
         // Bad message format -- drop it.
         delete evt;
      }
   }
   delete m;
#ifdef TIMING
   ActiveTimer.stop();
#endif
}

---