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

#include "BroadcastRequestHandler.h"
#include "BroadcastRequestEvent.h"
#include "ServerState.h"

#include "ServerExceptions.h"

#include <sys/time.h>

using namespace CODEX_Server;

bool
BroadcastRequestHandler::handler( BroadcastRequestEvent& 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;
         }
         if ( retVal )
         {
            sendEvent( 0, event.source() );
         }
         return retVal;
      }
      else
      {
         // If the request ID is no longer registered, we don't need
         // to send the message again.
         if ( ( 0 != event.cb() ) &&
              ( ! qs->keyRegistered(event.message().buffer() +
                                    ServerState::nSID) ) )
         {
            sendEvent( 0, event.source() );
            return true;
         }
         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;
         }
         if ( retVal )
         {
            sendEvent( 0, event.source() );
         }
         return retVal;
      }
   }
   catch ( ... )
   {
      return false;
   }
}

---