QuorumSystem.h

/*
 * 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: QuorumSystem.h,v 1.3 2004/05/19 15:56:55 mmarsh Exp $
//
// $Log: QuorumSystem.h,v $
// Revision 1.3  2004/05/19 15:56:55  mmarsh
// *** empty log message ***
//
// Revision 1.2  2003/11/04 22:17:23  mmarsh
// General code cleanup.
//
//

#ifndef __CODEX_QUORUM_QUORUMSYSTEM_H__
#define __CODEX_QUORUM_QUORUMSYSTEM_H__

#include <vector>
#include <algorithm>
#include <map>

#include "Message.h"
#include "RemoteServer.h"
#include "ResponseTracker.h"
#include "MessageDispatcher.h"

namespace CODEX_Quorum
{
   typedef vector<Message>  MessageVector;
   typedef vector<RemoteServerReturn>  ReturnVector;
   //typedef pair<const RemoteServerReturn*, const Response*>  ResponsePair;
   //typedef vector<ResponsePair>  ResponsePairVector;

   class QuorumSystem
   {
      public :
         QuorumSystem( ResponseTracker* aRT ) : m_responseTracker( aRT ) {}

         virtual ~QuorumSystem() { delete m_responseTracker; }

         virtual unsigned int  quorumSystemSize() = 0;

         virtual unsigned int  quorumSize() = 0;

         virtual unsigned int  faultsTolerated() = 0;

         virtual bool  broadcastMessage( const Message& msg,
                                         ReturnVector& rets,
                                         ResponseCallback* cb ) = 0;

         virtual bool  unicastMessage( const MessageVector& msgs,
                                       ReturnVector& rets,
                                       ResponseCallback* cb = 0 ) = 0;

         virtual void poll( MessageDispatcher& requestDispatcher,
                            QuorumDispatcher& responseDispatcher ) = 0;

         virtual unsigned char* extractKey(const unsigned char* data) {
            return m_responseTracker->extractKey( data );
         }

         virtual bool keyRegistered( const unsigned char* key ) {
            return ( 0 != (*m_responseTracker)( key ) );
         }

      protected :
         ResponseTracker* m_responseTracker;
   };

   class ByzantineQuorumSystem : public QuorumSystem
   {
      public :
         ByzantineQuorumSystem( ResponseTracker* aRT ) : QuorumSystem( aRT ) {}

         virtual ~ByzantineQuorumSystem() {}
   };

}

#endif /* __CODEX_QUORUM_QUORUMSYSTEM_H__ */

---