simpleRadioCommModel.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2019 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/



#pragma once

#include "vrfobjcore/vrfobjcoreDefines.h"
#include "vrfobjcore/commModel.h"
#include "vrfobjcore/simObject.h"
#include "vrfMsgTransport/signalMessageTransporter.h"
#include <deque>

class DtSimpleRadioCommModelDescriptor;

namespace makVrfEvents
{
   class DtEvent;
}

class DT_DLL_vrfobjcore DtSimpleRadioCommModel : public DtCommModel
{
private:

   DtSimpleRadioCommModel();
   DtSimpleRadioCommModel(const DtSimpleRadioCommModel& orig);
   DtSimpleRadioCommModel& operator=(const DtSimpleRadioCommModel& orig);

protected:
   DtSimpleRadioCommModel(DtCommModelCreationParams& params);
   virtual bool init();

   virtual void tick();

   virtual void clearPendingRadioMessages();

public:
   static DtCommModel* create(DtCommModelCreationParams& params);

   virtual ~DtSimpleRadioCommModel();

   virtual DtString type() const;

   virtual void registerRadio(DtVrfRadio* radio);

   virtual void sendMessage(DtVrfObjectMessage* message, DtVrfRadio* sendingRadio);

protected:
   virtual DtSignalMessageTransporter* createTransporter();

   virtual bool checkRadioConnectivity(DtSimObjectReference sender, DtSimObjectReference receiver) const;
   
   virtual void deliverMessageToRecipients(const DtVrfObjectMessage* message);

   static void messageReceivedCallback(DtSignalMessageTransporterCallbackParams* params,
      void* usr);

   virtual void processMessageReceived(DtSignalMessageTransporterCallbackParams* params);

protected:
   enum ConnectionMode
   {
      ConnectionModeAll = 0,
      ConnectionModeAggregate = 1,
      ConnectionModeForce = 2
   };

   DtSignalMessageTransporter* myTransporter;
   typedef std::deque<DtVrfObjectMessageConstPtr> DtMessageQueue;
   DtMessageQueue myMessagesToDeliver;
   const DtSimpleRadioCommModelDescriptor* mySimpleCommDescriptor;
   ConnectionMode myConnectionMode;
};