federateAmbassadorWrapper.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2025 MAK Technologies
** All rights reserved.
*********************************************************************/

#pragma once

#include <rtiutil/rtiMsConfig.h>

#include <fedPro/protobuf/FederateAmbassador.pb.h>

#include <RTI/Typedefs.h>

#include <map>

namespace rti1516_2025
{
   class FederateAmbassador;
};

namespace FedProWrap
{
   class DtRtiAmbassadorFedProBase;

   class DT_DLL_FEDPRO_WRAPPER DtFederateAmbassadorWrapper
   {
   public:

      DtFederateAmbassadorWrapper(DtRtiAmbassadorFedProBase& rtiAmb, rti1516_2025::FederateAmbassador& federateAmb);

      virtual ~DtFederateAmbassadorWrapper();

      virtual void processCallback(const rti1516_2025::fedpro::CallbackRequest& request, unsigned long sequenceNumber);

   protected:
      typedef void (DtFederateAmbassadorWrapper::* CallbackFunction)(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);

      virtual int sendCallbackResponse(unsigned long sequenceNumber);

      virtual void addCallback(rti1516_2025::fedpro::CallbackRequest::CallbackRequestCase type, CallbackFunction callback);
      virtual void removeCallback(rti1516_2025::fedpro::CallbackRequest::CallbackRequestCase);

      void connectionLost(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void reportFederationExecutions(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void reportFederationExecutionMembers(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void reportFederationExecutionDoesNotExist(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void federateResigned(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void objectInstanceNameReservationSucceeded(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void objectInstanceNameReservationFailed(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void discoverObjectInstance(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void removeObjectInstance(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void reflectAttributeValues(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);
      void receiveInteraction(const rti1516_2025::fedpro::CallbackRequest& callback, unsigned long sequenceNumber);

   protected:

      std::map<rti1516_2025::fedpro::CallbackRequest::CallbackRequestCase, CallbackFunction> myCallbackFunctions;
      DtRtiAmbassadorFedProBase& myRtiAmbassador;
      rti1516_2025::FederateAmbassador& myFederateAmbassador;
      std::vector<char> myCallbackResponseBuffer;
   };
};