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

#include "SignRequestHandler.h"
#include "SignRequestEvent.h"
#include "ServerState.h"

#include "ServerExceptions.h"

using namespace CODEX_Server;

bool
SignRequestHandler::handler( SignRequestEvent& event )
{
   // If the broadcast does not reach a quorum, the event will be
   // re-queued.
   CODEX_Quorum::QuorumSystem* qs = ServerState::instance()->quorumSystem();
   if ( NULL == qs )
   {
      throw NoQuorumSystemException( __FILE__ , __LINE__ );
   }
   try
   {
      struct timeval tv;
      gettimeofday(&tv,0);
      if ( ( tv.tv_sec - event.time() ) < 3 )
      {
         return false;
      }
      event.updateTime( tv.tv_sec );
      if ( ! event.bcast() )
      {
         event.setBcast();
         bool bVal = qs->broadcastMessage( event.message(),
                                           event.retVals(),
                                           event.cb() );
         bool retVal = false;
         CODEX_Quorum::ReturnVector::const_iterator itr =
            event.retVals().begin();
         CODEX_Quorum::ReturnVector::const_iterator end =
            event.retVals().end();
         unsigned int nGood = 0;
         for ( ; itr != end ; ++itr )
         {
            if ( itr->returnCode() ==
                 CODEX_Quorum::RemoteServerReturn::kSuccess )
            {
               ++nGood;
            }
         }
         if ( nGood >= qs->quorumSize() )
         {
            retVal = true;
         }
         return retVal;
      }
      else
      {
         // We don't want to register the callback again.
         bool bVal = qs->broadcastMessage( event.message(),
                                           event.retVals(),
                                           NULL );
         bool retVal = false;
         CODEX_Quorum::ReturnVector::const_iterator itr =
            event.retVals().begin();
         CODEX_Quorum::ReturnVector::const_iterator end =
            event.retVals().end();
         unsigned int nGood = 0;
         for ( ; itr != end ; ++itr )
         {
            if ( itr->returnCode() ==
                 CODEX_Quorum::RemoteServerReturn::kSuccess )
            {
               ++nGood;
            }
         }
         if ( nGood >= qs->quorumSize() )
         {
            retVal = true;
         }
         return retVal;
      }
   }
   catch ( ... )
   {
      return false;
   }
}

---