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

#include "ServerMessageDispatcher.h"
#include "ServerState.h"

using namespace CODEX_Server;

void
ServerMessageDispatcher::operator()( CODEX_Quorum::Message* m )
{
   // The message still has all of its headers.
   if ( NULL == m )
   {
      return;
   }
   int header_length = ServerState::nSID + ServerState::nMID;
   if ( m->length() < header_length + 2 )
   {
      // We're responsible for cleaning up the message passed in.
      delete m;
      return;
   }
   unsigned char mType = m->buffer()[ header_length ];
   MapType::const_iterator itr = m_parsers.find(mType);
   if ( m_parsers.end() == itr )
   {
      // We're responsible for cleaning up the message passed in.
      cout << "no parser found for " << (int)mType << endl;
      delete m;
      return;
   }
   unsigned char* server = new unsigned char[ServerState::nSID];
   if ( NULL == server )
   {
      delete m;
      return;
   }
   memcpy( server, m->buffer(), ServerState::nSID );
   unsigned char* mID = new unsigned char[ServerState::nMID];
   if ( NULL == mID )
   {
      delete [] server;
      delete m;
      return;
   }
   memcpy( mID, m->buffer() + ServerState::nSID, ServerState::nMID );
   CODEX_Quorum::Message* msg =
      new CODEX_Quorum::Message( m->buffer() + header_length + 1 ,
                                 m->length() - header_length - 1 );
   // We're responsible for cleaning up the message passed in.
   delete m;
   (*itr->second)( server, mID, msg );
}

bool
ServerMessageDispatcher::addParser( unsigned char mType, MessageParser* mp )
{
   return m_parsers.insert( MapType::value_type( mType, mp ) ).second;
}

---