hard_data_sync.h

Go to the documentation of this file.

#ifndef FPMAS_HARD_DATA_SYNC_H
#define FPMAS_HARD_DATA_SYNC_H
 
#include "fpmas/api/graph/distributed_graph.h"
#include "server_pack.h"
 
namespace fpmas { namespace synchro { namespace hard {
 
    template<typename T>
        class HardDataSync : public fpmas::api::synchro::DataSync<T> {
            typedef api::MutexServer<T> MutexServer;
            typedef api::TerminationAlgorithm TerminationAlgorithm;
 
            fpmas::api::communication::MpiCommunicator& comm;
            ServerPackBase& server_pack;
            fpmas::api::graph::DistributedGraph<T>& graph;
 
            public:
            HardDataSync(
                    fpmas::api::communication::MpiCommunicator& comm,
                    ServerPackBase& server_pack,
                    fpmas::api::graph::DistributedGraph<T>& graph)
                : comm(comm), server_pack(server_pack), graph(graph) {
                }
 
            void synchronize() override {
                FPMAS_LOGI(comm.getRank(), "HARD_DATA_SYNC", "Synchronizing data sync...", "");
                server_pack.terminate();
                FPMAS_LOGI(comm.getRank(), "HARD_DATA_SYNC", "Synchronized.", "");
            };
 
            void synchronize(
                    std::unordered_set<fpmas::api::graph::DistributedNode<T>*>
                    ) override {
                synchronize();
            }
        };
 
}}}
#endif