GatherScatterCommunication.hpp

Go to the documentation of this file.

#pragma once
 
#include <stddef.h>
#include <string>
#include <vector>
#include "DistributedCommunication.hpp"
#include "com/SharedPointer.hpp"
#include "logging/Logger.hpp"
#include "mesh/SharedPointer.hpp"
 
namespace precice::m2n {

class GatherScatterCommunication : public DistributedCommunication {
public:
  GatherScatterCommunication(
      com::PtrCommunication com,
      mesh::PtrMesh         mesh);
 
  ~GatherScatterCommunication() override;

  bool isConnected() const override;

  void acceptConnection(
      const std::string &acceptorName,
      const std::string &requesterName) override;

  void requestConnection(
      const std::string &acceptorName,
      const std::string &requesterName) override;
  void acceptPreConnection(
      std::string const &acceptorName,
      std::string const &requesterName) override;

  void requestPreConnection(
      std::string const &acceptorName,
      std::string const &requesterName) override;

  void completeSecondaryRanksConnection() override;

  void closeConnection() override;

  void send(precice::span<double const> itemsToSend, int valueDimension) override;

  void receive(precice::span<double> itemsToReceive, int valueDimension) override;

  void broadcastSend(int itemToSend) override;

  void broadcastReceiveAll(std::vector<int> &itemToReceive) override;

  void broadcastSendMesh() override;

  void broadcastReceiveAllMesh() override;

  void scatterAllCommunicationMap(CommunicationMap &localCommunicationMap) override;

  void gatherAllCommunicationMap(CommunicationMap &localCommunicationMap) override;
 
private:
  logging::Logger _log{"m2n::GatherScatterCommunication"};

  com::PtrCommunication _com;

  bool _isConnected;
};
 
} // namespace precice::m2n