concurrency.h

Go to the documentation of this file.

#ifndef FRECHET_VIEW_CONCURRENCY_H
#define FRECHET_VIEW_CONCURRENCY_H

#include <tbb/task_scheduler_init.h>
#include <tbb/tbb.h>
#include <chrono>
#include <clm4rm.h>

namespace frechet { namespace app {
class ConcurrencyContext
{
private:
    tbb::task_scheduler_init* tbb_context;
    int num_cores;
    int num_threads;

    cl_platform_id platform = nullptr;
    cl_context ctx;
    cl_device_id device = nullptr;
    cl_command_queue queue = nullptr;
    cl_event event = nullptr;
    cl_int clerr;

    std::string device_name;
    cl_uint gpu_units;
    size2_t max_tile;

public:
    ConcurrencyContext();
    ~ConcurrencyContext();
    static ConcurrencyContext instance;

    void setup(int max_threads);
    bool setupGpu(size2_t max_tile);
    void close();

    static int countThreads();
    static int countCores();
    static tbb::tbb_thread::id currentThread();

    static bool hasGpuSupport();

    static std::string gpuName();
    static cl_uint countGpuUnits();

    static cl_context clContext();
    static cl_command_queue clQueue();

    static void maxMaxtrixTile(size2_t&);

    //  System info: number of physical cores
    //static int countCpuCores();
    //  System info: size (in bytes) of L1,2,3 cache
    static int cacheSize(int level);    

private:
    void findCacheSizes();
    static void cpuid(int leaf, unsigned int regs[4]);
    static void cpuid(int leaf, int level, unsigned int regs[4]);
    static const char* findKernelDirectory(const char* subdir);
};

//  Debug timers
typedef std::chrono::high_resolution_clock Clock;
typedef Clock::time_point time_point;

void pushTimer();
time_point printTimer(std::string label, bool do_print = true);
time_point popTimer(std::string label, bool do_print = true);
time_point printDebugTimer(std::string label);
time_point popDebugTimer(std::string label);

} }  //namespace frechet

#endif //FRECHET_VIEW_CONCURRENCY_H