aggregateWeaponListResponder.h

Go to the documentation of this file.

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


#pragma once

#include "vrfmodel/vrfmodelDefines.h"

#include "vrfobjcore/simComponent.h"
#include "vrfobjcore/aggregateLocalObjectFacade.h"
#include "vrftasks/weaponListResponseAdmin.h"

#include <map>

class DtString;
class DtSimulationServices;
class DtSimMessage;


class DT_DLL_vrfmodel DtAggregateWeaponListResponder : public DtSimComponent
{
public:

   typedef std::map<DtUUID,double> AgingMap;
   typedef std::map<DtUUID,DtWeaponList> WeaponsMap;

public:

   DtAggregateWeaponListResponder(const DtString& name, 
      DtLocalObject* owner, 
      DtSimulationServices* simServices, 
      DtComponentDescriptor* desc = 0,
      DtReaderWriterRegistry* parentRegistry = 0);

   virtual ~DtAggregateWeaponListResponder();

   virtual void addWeaponsList(const DtUUID& sub, const DtWeaponList& weapons);
   virtual void removeWeaponsList(const DtUUID& sub);

   virtual void ageResponses();

   virtual void emptyWeaponsMap();

   virtual bool init();

   virtual const char* type() const;

   virtual bool postAddComponentsInit();

   virtual void preFirstTickInit();


   virtual void processSubordinateAdded(const DtUUID& sub);
   virtual void processSubordinateRemoved(const DtUUID& sub);

   virtual void sendWeaponResponse(const DtUUID& recipient, bool bIncludeResources);
   virtual void sendResponsesToRequestors();

   virtual void tick();


   static void weaponListRequestCallback(const DtVrfObjectMessage* msg, void* usr);
   virtual void processWeaponListRequest(const DtVrfObjectMessage* msg);


   static void weaponListResponseCallback(const DtVrfObjectMessage* msg, void* usr);
   virtual void processWeaponResponse(const DtVrfObjectMessage* msg);

   static DtSimComponent * creator(const DtString& name, 
      DtLocalObject* owner,
      DtSimulationServices* simManager, 
      DtComponentDescriptor* desc = 0,
      DtReaderWriterRegistry* parentRegistry = 0);

protected:

   DtVrfProcessStateRepository* createComponentPsr(const DtString& defaultPsrType,
      const DtString& defaultPsrName, bool useDescriptorParams = true);
  
   DtAggregateWeaponListResponder();

   DtAggregateWeaponListResponder(const DtAggregateWeaponListResponder & orig);

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

   virtual void connectToWeaponListResponses();
   virtual void disconnectFromWeaponListResponses();

   virtual void sendWeaponListRequest(const DtUUID& subId);
   virtual void sendWeaponListRequests();

protected:

   boost::signals2::scoped_connection mySubordinateAddedConnection;
   boost::signals2::scoped_connection mySubordinateRemovedConnection;

   bool bMySendWeaponRequestToSubordinates;
   bool bMyPushToSuperior;

   DtTime myNextSendWeaponRequestTime;
   DtTime myNextAgingTime;

   DtAggregateLocalObjectFacade myAggregateLocalObjectFacade;

   AgingMap mySubordinateRequestAgingMap;
   AgingMap myRequestorsAgingMap;

   WeaponsMap myWeaponsMap;

};