ClientResponseParser.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: ClientResponseParser.cc,v 1.3 2004/05/19 15:56:51 mmarsh Exp $
//
// $Log: ClientResponseParser.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 "ClientResponseParser.h"
#include "ClientDelegation.h"
#include "SupportedKeyStoredEvent.h"
#include "SupportedClientResponseEvent.h"
#include "SupportedClientResponseHandler.h"

#include "timing.h"

using namespace CODEX_KeyService;

void
ClientResponseParser::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+2);
   SupportedClientResponseEventBase* evt = NULL;
   if ( ClientDelegation::kRequestSignature != buff[0] )
   {
      if ( 0 != server ) delete [] server;
      if ( 0 != mID ) delete [] mID;
      delete m;
#ifdef TIMING
      ActiveTimer.stop();
#endif
      return;
   }
   switch( buff[1] )
   {
      using namespace CODEX_Client;
      case CODEX_Client::kBoundNameMsg :
         evt = new
            SupportedClientResponseEvent< BoundNameMsg, SignedCreateKeyMsg >(
            this, server, mID, m_destination );
         break;
      case CODEX_Client::kKeyStoredMsg :
         evt = new
            SupportedClientResponseEvent< KeyStoredMsg, SignedWriteKeyMsg >(
            this, server, mID, m_destination );
         break;
      case ClientDelegation::kSupportedKeyStoredMsg :
         evt = new SupportedKeyStoredEvent( this, server, mID, m_destination );
         break;
      case CODEX_Client::kBlindKeyMsg :
         evt = new SupportedClientResponseEvent< VerifiableBlindKeyMsg,
            SignedReadKeyMsg >(
               this, server, mID, m_destination );
         break;
      default :
         // Bad message type for a client request -- drop it.
         cerr << "Bad message type: "
              << (unsigned int)buff[1]
              << endl;
         if ( 0 != server ) delete [] server;
         if ( 0 != mID ) delete [] mID;
         break;
   }
   if ( NULL != evt )
   {
      if ( evt->unmarshal( &pBuff, buffLength-2 ) )
      {
         // Enqueue the event.
         sendEvent( evt, 0 );
      }
      else
      {
         // Bad message format -- drop it.
         delete evt;
      }
   }
   delete m;
#ifdef TIMING
   ActiveTimer.stop();
#endif
}

---