Sharer.hpp

#pragma once
 
#include "sharing/SharingEntity.hpp"
#include "sharing/SharingStrategy.hpp"
#include "utils/Logger.hpp"
#include "utils/Threading.hpp"
 
static void* mainThrSharing(void* arg);
 
class Sharer
{
  public:
    Sharer(int id_, std::vector<std::shared_ptr<SharingStrategy>>& sharingStrategies);
 
    Sharer(int id_, std::shared_ptr<SharingStrategy> sharingStrategy);
 
    virtual ~Sharer();
 
    virtual void printStats();
 
    inline void join()
    {
        if (sharer == nullptr)
            return;
        sharer->join();
        delete sharer;
        sharer = nullptr;
        LOGDEBUG1("Sharer %d joined", this->getId());
    }
 
    inline void setThreadAffinity(int coreId) { this->sharer->setThreadAffinity(coreId); }
 
    inline int getId() { return this->m_sharerId; }
 
    inline void setId(int id) { this->m_sharerId = id; }
 
  protected:
    Thread* sharer;
 
    double totalSharingTime = 0;
 
    unsigned int round;
 
    std::vector<std::shared_ptr<SharingStrategy>> sharingStrategies;
 
    friend void* mainThrSharing(void*);
 
    int m_sharerId;
};