GenericGlobalSharing.hpp

#pragma once
 
#include "GlobalSharingStrategy.hpp"
 
class GenericGlobalSharing : public GlobalSharingStrategy
{
  public:
    GenericGlobalSharing(const std::shared_ptr<ClauseDatabase>& clauseDB,
                         const std::vector<int>& subscriptions,
                         const std::vector<int>& subscribers,
                         unsigned long bufferSize);
 
    ~GenericGlobalSharing();
 
    bool initMpiVariables() override;
 
    bool doSharing() override;
 
    void joinProcess(int winnerRank, SatResult res, const std::vector<int>& model) override;
 
  protected:
    int serializeClauses(std::vector<int>& serialized_v_cls);
 
    void deserializeClauses(std::vector<int>& serialized_v_cls);
 
    unsigned int totalSize; 
 
    std::vector<MPI_Request> sendRequests; 
 
    BloomFilter b_filter_send; 
 
    BloomFilter b_filter_recv; 
 
    std::vector<int> clausesToSendSerialized; 
 
    std::vector<int> receivedClauses; 
 
    std::vector<int> subscriptions; 
 
    std::vector<int> subscribers; 
};