#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#include <qapplication.h>
#include <qdir.h>
#include <qsettings.h>
#include <qstring.h>
#include <time.h>
#include <sched.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <iostream>
#include <fstream>
#include "Log.h"
#include "Profiler.h"
#include "loadtest.h"

using namespace std;

int no_of_points;
struct sockaddr_in addr;
struct ip_mreq mreq;
Profiler profiler;
struct timespec delay;

void onTimer(int);

int main(int argc, char **argv)
{


  struct itimerval timer;
  struct itimerval otimer;
  struct sigaction action;
  struct sigaction oaction;

  struct sched_param param;

  struct tm *t;
 
  Q_UINT16 Port;

  QSettings settings;  

  QString Dir = QDir::currentDirPath();
  settings.insertSearchPath(QSettings::Unix, Dir);

  if(argc < 4)
  {
    cout << "Not enough params: loadtest <inifile> <number of data> <delay>" << endl;
    exit(1);
  }

  printf("Max Priority %d Min Priority %d\n", sched_get_priority_max(SCHED_FIFO), sched_get_priority_min(SCHED_FIFO));

  param.sched_priority = 1;

  if(sched_setscheduler(0, SCHED_FIFO, &param) == -1)
  {
    perror("sched_setscheduler");
  }

  delay.tv_sec = 0;
  delay.tv_nsec = atoi(argv[3]) * 1000;


  if((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
  {
    perror("socket");
    exit(1);
  }

  //read in the ip address from the rc file
  QString file(argv[1]);
  QString address = settings.readEntry(QString(file) + "/common/ip");
  Port = settings.readNumEntry(file + "/common/port");

  memset(&addr, 0, sizeof(addr));
  addr.sin_family = AF_INET;
  addr.sin_addr.s_addr = inet_addr(address);
  addr.sin_port = htons(Port);

  // setup the signal handler 

  action.sa_handler = onTimer;
  sigemptyset(&action.sa_mask);
  action.sa_flags = 0;
  sigaction(SIGALRM, &action, &oaction);

  timer.it_interval.tv_sec = 1;
  timer.it_interval.tv_usec = 0;
  timer.it_value.tv_sec = 1;
  timer.it_value.tv_usec = 0; 

  Data = atoi(argv[2]);

  
  for(int p = 0; p < Data; p++)
  {
    try
    {
      //do stuff
      new Mess;
    }
    catch(std::bad_alloc)
    {
      cout << "Bad Alloc" << endl;
    }
    catch(...)
    {
      cout << "Unknown" << endl;
    }

    try
    {
      //do more stuff
    }
    catch(EAsterixObject & e)
    {
      std::cout << time
        << "Untrapped Asterix Exception: " << e.what() << std::endl
        << "Exiting" << std::endl;
    }
    catch(std::exception & e)
    {
      std::cout << time
        << "Untrapped standard Exception: " << e.what() << std::endl
        << "Exiting" << std::endl;
    }
    catch(...)
    {
      std::cout << time
        << "Unknown Exception caught!" << std::endl << "Exiting" << std::endl;
    }
  }

  setitimer(ITIMER_REAL, &timer, &otimer);

  while(1)
    pause();

  return 0;
}

void onTimer(int a)
{
  profiler.start();
  struct timeval now;
  struct tm *t;
  time_t midnight;

  // calculate time at midnight

  gettimeofday(&now, NULL);
  t = gmtime(&now.tv_sec);
  t->tm_sec = 0;
  t->tm_min = 0;
  t->tm_hour = 0;
  midnight = mktime(t);

  for(int p = 0; p < NumTrack; p++)
  {
   //do stuff

    if(sendto(fd, Message, Mess[p].record->getLength() + 3, 0, (struct sockaddr *)&addr, sizeof(addr)) < 0)
    {
      perror("sendto");
    }

    nanosleep(&delay, NULL);
  }

  secs++;
  cout << "Loop time " << profiler.elapsed() << std::endl;
}