/*========================== begin_copyright_notice ============================

Copyright (C) 2017-2021 Intel Corporation

SPDX-License-Identifier: MIT

============================= end_copyright_notice ===========================*/

#include "Timer.h"
#include "Assertions.h"
#include "Option.h"

#include <fstream>
#include <iostream>
#include <string>
#ifdef _WIN32
#include "Windows.h"
#endif

#if !defined(_WIN32)
// Define Windows types for non-Windows OSes.
// TODO: replace timer implementation with the portable std::chrono class.
typedef int32_t LONG;
typedef int64_t LONGLONG;

typedef uint32_t DWORD;

#ifndef __LARGE_INTEGER_STRUCT_DEFINED__
union LARGE_INTEGER {
  struct dummy {
    DWORD LowPart;
    LONG HighPart;
  };

  struct u {
    DWORD LowPart;
    LONG HighPart;
  };

  LONGLONG QuadPart;
};
#define __LARGE_INTEGER_STRUCT_DEFINED__
#endif // __LARGE_INTEGER_STRUCT_DEFINED__

#endif /* Windows types for non-Windows end */

#undef DEF_TIMER
#define DEF_TIMER(ENUM, DESCR) DESCR,
static const char *timerNames[static_cast<int>(TimerID::NUM_TIMERS)] = {
#include "TimerDefs.h"
};

#ifdef MEASURE_COMPILATION_TIME

#define CLOCK_TYPE CLOCK_MONOTONIC

#if !defined(_WIN32)
bool QueryPerformanceFrequency(LARGE_INTEGER *lpFrequency) {
  struct timespec Res;
  int iRet;

  if ((iRet = clock_getres(CLOCK_TYPE, &Res)) != 0) {
    return false;
  }

  // resolution (precision) can't be in seconds for current machine and OS
  if (Res.tv_sec != 0) {
    return false;
  }
  lpFrequency->QuadPart = 1000000000LL / Res.tv_nsec;

  return true;
}

bool QueryPerformanceCounter(LARGE_INTEGER *lpPerformanceCount) {
  struct timespec Res;
  struct timespec t;
  int iRet;

  if ((iRet = clock_getres(CLOCK_TYPE, &Res)) != 0) {
    return false;
  }
  if (Res.tv_sec != 0) { // resolution (precision) can't be in seconds for
                         // current machine and OS
    return false;
  }
  if ((iRet = clock_gettime(CLOCK_TYPE, &t)) != 0) {
    return false;
  }
  lpPerformanceCount->QuadPart =
      (1000000000LL * t.tv_sec + t.tv_nsec) / Res.tv_nsec;

  return true;
}

#endif
#endif // MEASURE_COMPILATION_TIME

namespace vISA {

struct Timer {
  double time;
  LONGLONG currentStart;
  const char *name;
  LONGLONG ticks;
  bool started;
  unsigned int hits;
};

} // namespace vISA

static vISA::Timer timers[static_cast<int>(TimerID::NUM_TIMERS)];
[[maybe_unused]] static LARGE_INTEGER proc_freq;
static int numTimers = static_cast<int>(TimerID::NUM_TIMERS);

void initTimer() {

#ifdef MEASURE_COMPILATION_TIME
  numTimers = 0;
  for (int i = 0; i < static_cast<int>(TimerID::NUM_TIMERS); i++) {
    timers[i].time = 0;
    timers[i].currentStart = 0;
    timers[i].name = NULL;
    timers[i].ticks = 0;
    timers[i].started = false;
    timers[i].hits = 0;
    createNewTimer(timerNames[i]);
  }
  QueryPerformanceFrequency(&proc_freq);
#endif
}

void resetPerKernel() {
  for (int i = 0; i < static_cast<int>(TimerID::NUM_TIMERS); i++) {
    TimerID ti = static_cast<TimerID>(i);
    if (ti == TimerID::TOTAL || ti == TimerID::BUILDER ||
        ti == TimerID::VISA_BUILDER_APPEND_INST ||
        ti == TimerID::VISA_BUILDER_CREATE_VAR ||
        ti == TimerID::VISA_BUILDER_CREATE_OPND ||
        ti == TimerID::VISA_BUILDER_IR_CONSTRUCTION) {
      continue;
    }
    timers[i].time = 0;
    timers[i].currentStart = 0;
    timers[i].ticks = 0;
    timers[i].started = false;
    timers[i].hits = 0;
  }
}

int createNewTimer(const char *name) {
  timers[numTimers].name = name;
  return numTimers++;
}

void startTimer(TimerID timerId) {
  [[maybe_unused]] int timer = static_cast<int>(timerId);
#ifdef MEASURE_COMPILATION_TIME
  if (timer < static_cast<int>(TimerID::NUM_TIMERS)) {
#if defined(_DEBUG) && defined(CHECK_TIMER)
    if (timers[timer].started) {
      std::cerr << "***********************************************\n";
      std::cerr << "Timer already started.\n";
      vASSERT(false);
    }
#endif
    LARGE_INTEGER start;
    QueryPerformanceCounter(&start);
    timers[timer].currentStart = start.QuadPart;
    timers[timer].hits++;
#if defined(_DEBUG) && defined(CHECK_TIMER)
    timers[timer].started = true;
#endif
  } else {
#ifdef _DEBUG
    std::cerr << "***********************************************\n";
    std::cerr << "Invalid index used when invoking startTimer\n";
#endif
  }
#endif
}

void stopTimer(TimerID timerId) {
  [[maybe_unused]] int timer = static_cast<int>(timerId);
#ifdef MEASURE_COMPILATION_TIME
  if (timer < static_cast<int>(TimerID::NUM_TIMERS)) {
    LARGE_INTEGER stop;
    QueryPerformanceCounter(&stop);
    timers[timer].time += (stop.QuadPart - timers[timer].currentStart) /
                          (double)proc_freq.QuadPart;
    timers[timer].ticks += (stop.QuadPart - timers[timer].currentStart);
    timers[timer].currentStart = 0;
#if defined(_DEBUG) && defined(CHECK_TIMER)
    timers[timer].started = false;
#endif
  } else {
#ifdef _DEBUG
    std::cerr << "***********************************************\n";
    std::cerr << "Invalid index used when invoking stopTimer\n";
#endif
  }
#endif
}

extern "C" unsigned int getTotalTimers() { return numTimers; }

extern "C" double getTimerCounts(unsigned int idx) { return timers[idx].time; }

extern "C" int64_t getTimerTicks(unsigned int idx) { return timers[idx].ticks; }

extern "C" unsigned int getTimerHits(unsigned int idx) {
  return timers[idx].hits;
}

// static double getTimerUS(unsigned int idx)
// {
//     return (timers[idx].ticks * 1000000) / (double)proc_freq.QuadPart;
// }

void dumpAllTimers(const char *asmFileName, bool outputTime) {
  // This generates output like this:
  // TIMER1 TIMER2 TIMER3 ...
  // num1 num2 num3 ...
  std::ofstream krnlOutput;
  krnlOutput.open("jit_time.txt", std::ios_base::app);

  double totalTime = timers[static_cast<int>(TimerID::TOTAL)].time;
  for (unsigned int i = 0; i < getTotalTimers(); i++) {
#ifndef TIME_BUILDER
    TimerID ti = static_cast<TimerID>(i);
    if (ti == TimerID::VISA_BUILDER_APPEND_INST ||
        ti == TimerID::VISA_BUILDER_IR_CONSTRUCTION ||
        ti == TimerID::VISA_BUILDER_CREATE_VAR ||
        ti == TimerID::VISA_BUILDER_CREATE_OPND) {
      continue;
    }
#endif
    krnlOutput << std::left << std::setw(24) << timerNames[i] << "\t";
    if (outputTime) {
      krnlOutput << std::left << std::setw(12) << std::setprecision(6)
                 << timers[i].time << "\t";
    } else {
      krnlOutput << timers[i].ticks << "\t";
    }
    krnlOutput << std::setprecision(4) << (timers[i].time / totalTime * 100)
               << "%";
    krnlOutput << "\n";
  }

  krnlOutput.close();

  // Print timers like this:
  // TIMER1:num1
  // TIMER2:num2
  // ...
  std::ofstream timerFile;
  std::stringstream ss;
  ss << "timers." << asmFileName;
  timerFile.open(ss.str(), std::ios_base::out);
  for (unsigned i = 0, e = getTotalTimers(); i < e; i++) {
    timerFile << timerNames[i] << ":";
    if (outputTime) {
      timerFile << timers[i].time << "\n";
    } else {
      timerFile << timers[i].ticks << "\n";
    }
  }
  timerFile.close();
}