//#define DEBUG 1
//#define DEBUG0_1 1
//#define DEBUG3 1
#include "headers.h"
#include "template.h"
#include "utils.h"

using namespace std;
class LoadTimeInitializer
{
  public:
    LoadTimeInitializer()		//will be called when library is loaded
    {
      ConvertChar::init();
    }
};
LoadTimeInitializer g_load_time_initializer;

#define BATCH_SIZE  10000
#define RUN_HYBRID

double getCurrClk() {
  struct timeval tv ;
  gettimeofday(&tv, NULL);
  return (double)tv.tv_sec + (double)tv.tv_usec / 1000000.0;
}

int main(int argc, char** argv)
{
  if(argc < 2)
  {
    cerr << "Needs path to input file as argument\n";
    exit(0);
  }
  bool use_old_read_testcase = false;
  if(argc >= 3 && string(argv[2]) == "1")
    use_old_read_testcase = true;
  unsigned chunk_size = 100;
  if(argc >= 4)
    chunk_size = strtol(argv[3],0,10);


  initialize_function_pointers(); 

  std::ifstream ifptr;
  FILE* fptr = 0;
  if(use_old_read_testcase)
  {
    fptr = fopen(argv[1],"r");
    assert(fptr);
  }
  else
  {
    ifptr.open(argv[1]);
    assert(ifptr.is_open());
  }

  vector<testcase> tc_vector;
  tc_vector.clear();
  testcase tc;
  while(1)
  {
    int break_value = use_old_read_testcase ? read_testcase(&tc, fptr) : read_mod_testcase(ifptr,&tc,true);
    if(break_value < 0)
      break;
    tc_vector.push_back(tc);
  }
  vector<double> results_vec;
  results_vec.clear();
  results_vec.resize(tc_vector.size());
  double start_time = getCurrClk();
#pragma omp parallel for schedule(dynamic,chunk_size)  num_threads(12)
  for(unsigned i=0;i<tc_vector.size();++i)
  {
    testcase& tc = tc_vector[i];
    float result_avxf = g_compute_full_prob_float(&tc, 0);
    double result = 0;
    if (result_avxf < MIN_ACCEPTED) {
      double result_avxd = g_compute_full_prob_double(&tc, 0);
      result = log10(result_avxd) - log10(ldexp(1.0, 1020.0));
    }
    else
      result = (double)(log10f(result_avxf) - log10f(ldexpf(1.f, 120.f)));

    results_vec[i] = result;
  }
  cout << "Time taken "<<getCurrClk()-start_time << "\n";
  for(unsigned i=0;i<tc_vector.size();++i)
  {
    testcase& tc = tc_vector[i];
    double baseline_result = compute_full_prob<double>(&tc);
    baseline_result = log10(baseline_result) - log10(ldexp(1.0, 1020.0)); 
    double abs_error = fabs(baseline_result-results_vec[i]);
    double rel_error = (baseline_result != 0) ? fabs(abs_error/baseline_result) : 0;
    if(abs_error > 1e-5 && rel_error > 1e-5)
      cout << std::scientific << baseline_result << " "<<results_vec[i]<<"\n";
    delete tc_vector[i].rs;
    delete tc_vector[i].hap;
  }
  results_vec.clear();
  tc_vector.clear();
  if(use_old_read_testcase)
    fclose(fptr);
  else
    ifptr.close();
  return 0;  
}