connection.h

Go to the documentation of this file.

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

#pragma once

#include "legionNet/export.h"

#include "legionDataStore/dataTypes.h"
#include "legionNet/boundary.h"

#include <memory>

namespace Legion
{
   class Configuration;
   class SimulationDatabase;
   class OwnershipManager;
   class Boundary;

   typedef UInt64 ConnectionHandle;
   const  UInt32 ALL_ATTRIBUTE_SETS = 0xffff;

   class LEGIONNET_DLL Connection
   {
   public:
      Connection(const SimulationDatabase& db, const Configuration& config);
      virtual ~Connection();

      virtual ConnectionHandle handle() { return myHandle; }

      virtual bool isConnected();

      virtual void startProcessingMessages(double maxProcessingTime = 0.0); 

      virtual void stopProcessingMessages();

      virtual void waitUntilDoneProcessingMessages();

      virtual ClientId clientId();

      virtual void setInterest(const Boundary& boundary, InterestGranularity granularityToUse = Boundary::theDefaultGranularity);

      virtual void removeInterest();

      virtual std::unique_ptr<Boundary> interest() const;

      virtual InterestGranularity interestGranularity() const;

      virtual void setIntent(const Boundary& boundary);

      virtual void removeIntent();

      virtual std::unique_ptr<Boundary> intent() const;

      virtual bool isAbsoluteTimestamp() const;

      virtual void setIsAbsoluteTimestamp(bool isAbsolute);

      virtual OwnershipManager* ownershipManager();


      virtual void setAttributeSetInterest(const UInt32 attrSetType = ALL_ATTRIBUTE_SETS);
      virtual void addAttributeSetInterest(const UInt32 attrSetType = ALL_ATTRIBUTE_SETS);
      virtual void removeAttributeSetInterest(const UInt32 attrSetType = ALL_ATTRIBUTE_SETS);
   
   protected:
      ConnectionHandle myHandle;
      OwnershipManager* myOwnershipManager;
   };
}