UtilityFunctions.hpp

Go to the documentation of this file.

 
// Copyright (C) 2021 by the INTELLI team (https://github.com/intellistream)
 
#ifndef IntelliStream_SRC_UTILS_UTILITYFUNCTIONS_HPP_
#define IntelliStream_SRC_UTILS_UTILITYFUNCTIONS_HPP_
 
#include <string>
#include <experimental/filesystem>
#include <barrier>
#include <functional>
//#include <Common/Types.h>
 
#include <vector>
/* Period parameters */
 
#define TRUE 1
#define FALSE 0
#include <sys/time.h>
namespace INTELLI {
typedef std::shared_ptr<std::barrier<>> BarrierPtr;
#define TIME_LAST_UNIT_MS 1000
#define TIME_LAST_UNIT_US 1000000
class UtilityFunctions {
 
 public:
  UtilityFunctions();
 
  static std::shared_ptr<std::barrier<>> createBarrier(int count);
 
  // static void timerStart(Result &result);
 
  //static void timerEnd(Result &result);
 
  static size_t timeLast(size_t past, size_t unitTime);
  static size_t timeLastUs(struct timeval past);
 
  //bind to CPU
  static int bind2Core(int id);
  //partition
 
  static std::vector<size_t> avgPartitionSizeFinal(size_t inS, std::vector<size_t> partitionWeight);
  static std::vector<size_t> weightedPartitionSizeFinal(size_t inS, std::vector<size_t> partitionWeight);
  static size_t to_periodical(size_t val, size_t period) {
    if (val < period) {
      return val;
    }
    size_t ru = val % period;
    /* if(ru==0)
     {
       return  period;
     }*/
    return ru;
  }
};
}
#endif //IntelliStream_SRC_UTILS_UTILITYFUNCTIONS_HPP_