GlobalSharingStrategy.hpp

#pragma once
 
#include "sharing/Filters/BloomFilter.hpp"
#include "sharing/SharingStatistics.hpp"
#include "sharing/SharingStrategy.hpp"
 
#include "solvers/SolverInterface.hpp"
 
#include <mpi.h>
 
class GlobalSharingStrategy : public SharingStrategy
{
 
  public:
    GlobalSharingStrategy(const std::shared_ptr<ClauseDatabase>& clauseDB,
                          const std::vector<std::shared_ptr<SharingEntity>>& producers = {},
                          const std::vector<std::shared_ptr<SharingEntity>>& consumers = {});
 
    virtual ~GlobalSharingStrategy();
 
    //===================================================================================
    // SharingEntity interface (save in m_clauseDB)
    //===================================================================================
    bool importClause(const ClauseExchangePtr& cls) override
    {
        LOGDEBUG3("Global Strategy %d importing a cls %p", this->getSharingId(), cls.get());
        return m_clauseDB->addClause(cls);
    };
 
    void importClauses(const std::vector<ClauseExchangePtr>& v_cls) override
    {
        for (auto& cls : v_cls)
            importClause(cls);
    }
 
    bool exportClauseToClient(const ClauseExchangePtr& clause, std::shared_ptr<SharingEntity> client)
    {
        LOGDEBUG3(
            "Global Strategy %d exports a cls %p to %d", this->getSharingId(), clause.get(), client->getSharingId());
        return client->importClause(clause);
    }
 
    //===================================================================================
    // GlobalSharingStrategy interface
    //===================================================================================
 
    std::chrono::microseconds getSleepingTime() override;
 
    virtual void joinProcess(int winnerRank, SatResult res, const std::vector<int>& model);
 
    void printStats() override;
 
    virtual bool initMpiVariables();
 
    virtual bool doSharing() override;
 
  protected:
    GlobalSharingStatistics gstats; 
    bool requests_sent; 
    std::vector<MPI_Request> recv_end_requests; 
    MPI_Request send_end_request;               
    std::vector<int> receivedFinalResultRoot; 
};