include/vrfmodel/aggregator.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2008 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: aggregator.h,v $ $Revision: 1.3 $ $State: Exp $
*******************************************************************************/



#ifndef aggregator_H_
#define aggregator_H_

class DtVrfMessageInterface;
class DtVrfObject;
class DtVrfObjectManager;
class DtSubordinateObjectsList;
class DtSubordinateIndividualEntry;
class DtEntityIdentifier;
class DtSubordinateAggregateEntry;
class DtIfSubordinateListRequest;
class DtSimMessage;
class DtIfSubordinateList;

#include <map>
#include <vlpi/entityIdentifier.h>

#include "vrfmodel/vrfmodelDefines.h"
class DT_DLL_vrfmodel DtAggregator 
{
public:

   DtAggregator(DtVrfObject& aggregate,  
      DtSubordinateObjectsList& subordinatesObjectList,
      DtVrfObjectManager& vrfObjectManager, 
      DtVrfMessageInterface& messageInterface);

   virtual ~DtAggregator();

   virtual void init();

   virtual void startAggregation();

   virtual bool aggregationIsComplete() const;

protected:

   virtual void startAggregation(DtVrfObject& parentObj,
      DtSubordinateObjectsList& subordinateObjectsList);

   virtual void setObjectResources(DtVrfObject& Obj, DtSubordinateIndividualEntry* subIndEntry);

   virtual void sendSubordinateListRequestMsg(const DtEntityIdentifier& objIdent);

   virtual void removeAndDeleteSubordinates();

   static void subordinateListRequestMessageCallback(DtSimMessage* msg, void* usr);

   virtual void processSubordinateListRequestMessageCallback(
      DtIfSubordinateListRequest* content,
      const DtSimulationAddress & sender);

   static void subordinateListMessageCallback(DtSimMessage* msg,  void* usr);
   virtual void processSubordinateListMessageCallback(DtIfSubordinateList* content);

   DtAggregator(const DtAggregator& orig);

   DtAggregator& operator=(
      const DtAggregator& orig);

protected:

   DtVrfObject& myEntity;

   DtVrfMessageInterface& myMessageInterface;

   DtVrfObjectManager& myObjectManager;

   std::map<unsigned long, DtEntityIdentifier> myRequestIDs;

   std::map<DtEntityIdentifier, DtSubordinateAggregateEntry*> myPendingSubordinateEntryResponses;

   static unsigned long nextRequestId;

   std::map<DtVrfObject*,DtSubordinateAggregateEntry*> myDisaggregatedSubordinates;

   DtSubordinateObjectsList& mySubordinateObjectsList;
};

#endif