include/vrfobjcore/simpleRadioCommModel.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2007 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: simpleRadioCommModel.h,v $ $Revision: 1.4 $ $State: Exp $
*******************************************************************************/



#ifndef simpleRadioCommModel_h
#define simpleRadioCommModel_h

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

class DtSimpleRadioCommModelDescriptor;

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();

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(DtVrfObject* sender, DtVrfObject* receiver);
   
   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;
};

#endif