ownershipTransferManager.h

Go to the documentation of this file.

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

#pragma once


#include "vrfobjcore/vrfobjcoreDefines.h"
#include <boost/signals2.hpp>
#include <set>
#include <vrfutil/uuid.h>

namespace makVrfEvents
{
   class DtEvent;
   class DtTransferRequestEvent;
   class DtTransferResponseEvent;
   class DtEventManager;
   class DtOwnershipAcquisitionAcquiredEvent;
   class DtInitiateTakeEvent;
}

class DtLocalObjectManager;
class DtSimMessage;
class DtLocalObject;

class DT_DLL_vrfobjcore DtOwnershipTransferManager
{
public:
   DtOwnershipTransferManager(DtLocalObjectManager*);
   virtual ~DtOwnershipTransferManager();

   virtual void setEventManager(makVrfEvents::DtEventManager*);
   makVrfEvents::DtEventManager* eventManager() const
   {
      return myEventManager;
   }

   boost::signals2::signal<void (makVrfEvents::DtInitiateTakeEvent&, bool& continueOn)> signal_preTakeEvent;

   boost::signals2::signal<void (makVrfEvents::DtTransferResponseEvent&, bool& continueOn)> signal_preDivestEvent;

   boost::signals2::signal<void (DtLocalObject*, const makVrfEvents::DtOwnershipAcquisitionAcquiredEvent&)> signal_preTranferComplete;

   virtual bool canTransferObjects() const;

protected:
   virtual void processTransferRequestEvent(const makVrfEvents::DtEvent&);
   virtual void processOwnershipAcquired(const makVrfEvents::DtEvent&);
   virtual void processOwnershipDivested(const makVrfEvents::DtEvent&);
   
   static void takeOwnershipCallback(DtSimMessage* msg, void* usr);
   virtual void processTakeOwnership(DtSimMessage* msg);

protected:
   DtLocalObjectManager* myObjectManager;
   std::set<DtUUID> myConvertingToRemote;
   makVrfEvents::DtEventManager* myEventManager;
   boost::signals2::scoped_connection myTransferRequestEventConnection;
   boost::signals2::scoped_connection myOwnershipAcquisitionAcquiredEventConnection;
   boost::signals2::scoped_connection myOwnershipAcquisitionDivestedEventConnection;
};