hydrocoupledistributed.h

Go to the documentation of this file.

 
#ifndef HYDROCOUPLEDISTRIBUTED_H
#define HYDROCOUPLEDISTRIBUTED_H
 
#include "hydrocouple.h"
 
namespace HydroCouple
{
  namespace Distributed
  {
    class IExchangeRequest
    {
    public:
      virtual ~IExchangeRequest() = default;

      [[nodiscard]] virtual bool test() = 0;

      virtual void wait() = 0;

      [[nodiscard]] virtual bool failed(std::string &message) const = 0;
    };

    class ITransport : public virtual IIdentity
    {
    public:
      struct Endpoint
      {
        std::string address; 
        int32_t     rank = -1; 
      };

      virtual ~ITransport() = default;

      [[nodiscard]] virtual Endpoint localEndpoint() const = 0;

      [[nodiscard]] virtual int32_t participantCount() const = 0;

      [[nodiscard]] virtual bool send(const Endpoint &to, int32_t tag, const BufferDescriptor &payload, std::string *message = nullptr) = 0;

      [[nodiscard]] virtual bool receive(const Endpoint &from, int32_t tag, const BufferDescriptor &into, std::string *message = nullptr) = 0;

      [[nodiscard]] virtual std::unique_ptr<IExchangeRequest> sendAsync(const Endpoint &to, int32_t tag, const BufferDescriptor &payload) = 0;

      [[nodiscard]] virtual std::unique_ptr<IExchangeRequest> receiveAsync(const Endpoint &from, int32_t tag, const BufferDescriptor &into) = 0;
    };

    class IDistributedModelComponent : public virtual IModelComponent
    {
    public:
      virtual ~IDistributedModelComponent() = default;

      [[nodiscard]] virtual ITransport *transport() const = 0;

      [[nodiscard]] virtual int32_t partitionCount() const = 0;

      [[nodiscard]] virtual int32_t partitionRank() const = 0;
    };

    class IProxyModelComponent : public virtual IDistributedModelComponent
    {
 
    public:
      virtual ~IProxyModelComponent() = default;

      [[nodiscard]] virtual ITransport::Endpoint remoteEndpoint() const = 0;

      [[nodiscard]] virtual std::string remoteId() const = 0;

      [[nodiscard]] virtual bool connect(std::string &message) = 0;

      virtual void disconnect() = 0;

      [[nodiscard]] virtual bool isConnected() const = 0;

      [[nodiscard]] virtual bool ping(double timeoutSeconds) = 0;

      [[nodiscard]] virtual double requestTimeout() const = 0;

      virtual void setRequestTimeout(double seconds) = 0;
    };

    class IPartitionedComponentDataItem : public virtual IComponentDataItem
    {
    public:
      virtual ~IPartitionedComponentDataItem() = default;

      [[nodiscard]] virtual int64_t globalCount() const = 0;

      [[nodiscard]] virtual std::span<const int64_t> ownedGlobalIndexes() const = 0;

      [[nodiscard]] virtual std::span<const int64_t> virtualGlobalIndexes() const = 0;

      [[nodiscard]] virtual std::span<const int32_t> virtualOwners() const = 0;

      [[nodiscard]] virtual uint64_t synchronizationEpoch() const = 0;

      [[nodiscard]] virtual std::unique_ptr<IExchangeRequest> synchronizeAsync() = 0;
    };
  }
}
 
#endif // HYDROCOUPLEDISTRIBUTED_H