---

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

#include "ClientMessageParser.h"
#include "RoutedClientMessageEvent.h"
#include "RoutedClientMessageHandler.h"

#include "timing.h"

using namespace CODEX_KeyService;

void
ClientMessageParser::operator()( unsigned char* server,
                                 unsigned char* mID,
                                 CODEX_Quorum::Message* m )
{
   if ( NULL == 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);
   ClientMessageEventBase* evt = NULL;
   switch( buff[0] )
   {
      using namespace CODEX_Client;
      case (CODEX_Client::kCreateKeyMsg |
            CODEX_Client::SignatureMask) :
         evt = new RoutedClientMessageEvent< SignedCreateKeyMsg >(
            this, m_destination, server, mID );
         break;
      case (CODEX_Client::kWriteKeyMsg |
            CODEX_Client::SignatureMask) :
         evt = new RoutedClientMessageEvent< SignedWriteKeyMsg >(
            this, m_destination, server, mID );
         break;
      case (CODEX_Client::kReadKeyMsg |
            CODEX_Client::SignatureMask) :
         evt = new RoutedClientMessageEvent< LabeledReadKeyMsg >(
            this, m_destination, server, mID );
         break;
      default :
         // Bad message type for a client request -- drop it.
         cerr << "Bad message type: "
              << (unsigned int)buff[0]
              << endl;
         if ( 0 != server ) delete [] server;
         if ( 0 != mID ) delete [] mID;
         break;
   }
   if ( NULL != 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
}

---