organizationManager.h

Go to the documentation of this file.

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

#pragma once


#include <vlutil/vlConfig.h> 
#include <vector>
#include "vrfobjcore/organizationView.h"
#include <readerWriter/noArgumentCallbackList.h>
#include "vrfutil/rwUUID.h"

#include "vrfobjcore/vrfobjcoreDefines.h"

class DtOrganizationChangeSet;
class DtSimInterfaceMessage;
class DtPrintPendingOpsCommand;
class DtDeletePendingOpsCommand;

typedef void (*DtOrganizationManagerCallbackFcn)(void* usr);

struct DtOrganizationManagerReadyCallbackInfo
{
   bool myReady;
};

typedef DtCallbackList<const DtOrganizationManagerReadyCallbackInfo&>::DtCallbackFunctionType
   DtOrganizationManagerReadyCallbackFcn;

class DT_DLL_vrfobjcore DtOrganizationManager : public DtOrganizationView
{
private:
   DtOrganizationManager();
   DtOrganizationManager(const DtOrganizationManager& orig);
   DtOrganizationManager& operator=(const DtOrganizationManager& orig);

public:
   typedef DtCallbackList<const DtOrganizationManagerReadyCallbackInfo&> DtOrganizationReadyCallbackList;

public:

   DtOrganizationManager(DtVrfObjectManager *objMgr);
   virtual ~DtOrganizationManager();

   virtual bool init();


   virtual DtOrganizationManagerNode* addEntity(const DtVrfObject *vrfObject);

   virtual void removeEntity(const DtVrfObject *vrfObject);

   virtual void updateAggregate(const DtVrfObject *vrfObject);

   virtual void updateEntity(const DtVrfObject *vrfObject);

   virtual void setSuperior(const DtUUID& subordinate,
      const DtUUID& superior, int designator = 0,
      bool localOnly = false);
  
   virtual void setSuperiorToForce(const DtUUID& subordinate,
      int designator = 0, bool localOnly = false);

   virtual void queueSetSuperior(const DtUUID& subordinate, 
      const DtUUID& superior, int designator = 0,
      DtOrganizationManagerCallbackFcn completionCallback = 0, void* usrData = 0);

   virtual void queueSetSuperiorToForce(const DtUUID& subordinate, 
      int designator = 0, DtOrganizationManagerCallbackFcn completionCallback = 0, void* usrData = 0);

   virtual void queueChangeSet(const DtOrganizationChangeSet& changeSet, int& changeSetRequestId,
      DtOrganizationManagerCallbackFcn completionCallback = 0, void* usrData = 0);

   virtual void removeChangeSetCallback(int changeSetRequestId,
      DtOrganizationManagerCallbackFcn completionCallback, void* usrData = 0) const;

   virtual void detatchFromSuperior(const DtUUID& subordinate,
      bool localOnly = false);

   virtual void setSubordinateOrder(const DtUUID& superior,
      const std::vector<DtEntityIdentifier>& orderedSubordinateList, 
      bool localOnly = false);

   static void addToOrganizationCallback(DtSimMessage* msg, void* usr);
   static void removeFromOrganizationCallback(DtSimMessage* msg, void* usr);

   virtual bool allLocalOrgChangesComplete() const;

   virtual bool hasPendingOperations() const;

   virtual void addOrganizationManagerReadyCallback(
      DtOrganizationManagerReadyCallbackFcn fcn, void* usrData);

   virtual void removeOrganizationManagerReadyCallback(
      DtOrganizationManagerReadyCallbackFcn fcn, void* usrData);

   virtual void runPendingOperations();
   
   virtual void printPendingOperations() const;

   virtual void deletePendingOperations();

   virtual void deletePendingOperationsFor(DtString objectName);

   int numberOfOperations() const { return myPendingOperationList.count(); };

   virtual void closingScenario();

protected:
   virtual void invokeOrganizationManagerReadyCallbacks();

   virtual void processAddToOrganization(DtSimMessage* msg);
   virtual void processRemoveFromOrganization(DtSimMessage* msg);

   virtual bool setSuperiorIsLocal(const DtUUID& subordinate,
      const DtUUID& superiorId);

   virtual bool setSuperiorToForceIsLocal(const DtUUID& subordinate);

   virtual bool detatchFromSuperiorIsLocal(const DtUUID& subordinate);

   virtual bool setSubordinateOrderIsLocal(const DtUUID& superior) const;

   virtual void addOperationToQueue(DtOrgManagerOperation* operation);

   virtual unsigned int newPendingOperationId();

   virtual void clearPendingOperationId(unsigned int id);

   static void pendingOperationCompleteCallback(void* usr);

   static int nextId();

protected:
   typedef std::pair<DtOrganizationManager*, unsigned int> DtPendingOperationCompletionCallbackData;

   DtList myPendingOperationList;

   bool myOperationsRunning;

   std::list<unsigned int> myPendingOperationIdList;
   unsigned int myNextPendingOperationId;

   DtOrganizationReadyCallbackList myOrganizationManagerReadyCallbackList;

   DtPrintPendingOpsCommand* myPrintPendingOpsCommand;
   DtDeletePendingOpsCommand* myDeletePendingOpsCommand;

   static int theNextId;

};