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 {
namespace 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 m2n
} // namespace precice