partnerMgr.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1998 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: partnerMgr.h,v $ $Revision: 1.3 $ $State: Exp $
*********************************************************************/

#ifndef partnerMgr_H_
#define partnerMgr_H_

#ifndef DtUNDOCUMENTED


#include "rtiMsConfig.h"
#include "partnerFederateMsg.h"

class DtResignMsg;
class DtConnectionMgr;
class DtRtiMsg;

enum DtPartnerState
{
   DtPartnerAccepting,
   DtPartnerPendingConfirm,
   DtPartnerConfirmed
};

class DT_DLL_LRC DtPartnerMgr
{
public:

   DtPartnerMgr(DtConnectionMgr* connectMgr);

   ~DtPartnerMgr();

private:
   
   DtPartnerMgr(DtPartnerMgr const& );

   DtPartnerMgr& operator= (DtPartnerMgr const& );

public:

   virtual void joinFederationExecution(
      const char* federateType,
      const char* executionName,
      const char* federateName,
      unsigned long flags);

   virtual void resign();

   virtual bool acceptMessage( const DtRtiMsg& msg );

protected:

   virtual void sendJoinMessage(MAKRti::DtString federateType,
      MAKRti::DtString fedexName, MAKRti::DtString federateName);

   virtual void sendPartnerMessage(DtFederateHandle partnerFederate, DtPartnerResponse response);

   virtual void processOtherMessage(DtRtiMsg const& msg);

   virtual void processResignMessage(const DtResignMsg& msg);

   virtual void processPartnerMessage(const DtPartnerFederateMsg& msg);

   virtual void processPartnerAccept(const DtPartnerFederateMsg& msg);

   virtual void processPartnerConfirm(const DtPartnerFederateMsg& msg);

   virtual void processPartnerReject(const DtPartnerFederateMsg& msg);

   virtual bool partnerSlotAvailable() const;

   virtual bool waitingForConfirm() const;

   virtual bool isPartner(DtFederateHandle federate) const;

   virtual bool isPending(DtFederateHandle federate) const;

   virtual bool isConfirmed(DtFederateHandle federate) const;

   virtual void acceptPartner(DtFederateHandle federate, bool confirmed = false);

   virtual void confirmPartner(DtFederateHandle federate);

   virtual void removePartner(DtFederateHandle federate);

   virtual void removePendingPartner(DtFederateHandle federate);

   virtual void removeConfirmedPartner(DtFederateHandle federate);

   virtual bool isMe(DtFederateHandle federate) const;

   virtual DtFederateHandle federateHandle() const;

protected:

   DtConnectionMgr* myConnectMgr;

   bool myIsJoined;

   DtPartnerState myPartnerState;

   std::vector<DtFederateHandle> myPartners;

   std::vector<DtFederateHandle> myPendingPartners;

   std::vector<DtFederateHandle> myConfirmedPartners;

   DtFederateHandleStdSet myFilteredFederates;
};

#endif // DtUNDOCUMENTED
#endif // partnerMgr_H_