#include "httpd.h"
#include "http_core.h"
#include "http_config.h"
#include <stdlib.h>
#include <time.h>
#include <sys/time.h>
#include <sys/types.h>
#include "sessions.h"
#include <regex.h>
#include <stdio.h>
#include <sys/mman.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <unistd.h>


void set_shared_region(int *shared_int)
{
   int fd;

   /* Create shared memory object and set its size */
   fd = shm_open("/myregion", O_CREAT | O_RDWR, S_IRUSR | S_IWUSR);
   if(fd == -1)
      fprintf(stderr,"shm_open error");

   if(ftruncate(fd, sizeof(int)) == -1)
       fprintf(stderr,"ftruncate error");

    /* Map shared memory object */
   shared_int = mmap(NULL, sizeof(int),PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
   if(shared_int == MAP_FAILED)
      fprintf(stderr,"mmap error");
}

int start_mutex()
{
   if(initial_mutex_value == 0)
   {
      if(sem_init(&session_mutex,1,1) < 0)
      {
         fprintf(stderr,"error initializing semaphore");
         return 0;
      }
      initial_mutex_value = 1;
   }
   return 1;
}

static int counter_handler(request_rec* r) 
{
   char time_buffer[30]; 
   char entry[1024];
   long int tid,pid;
   apr_ctime(time_buffer,r->request_time);
   start_mutex();
   sem_wait(&session_mutex);
   set_shared_region(&ctr);
   ctr++;
   sem_post(&session_mutex);
   //tid = (long int)getthreadid();
   pid = (long int)getpid();
   sprintf(entry,"counter: %i, thread: %ld, process: %ld, request: %s,  time: %s;",ctr,(long int)0,pid,r->the_request,time_buffer);
   tempToDB(entry);

   return DECLINED;
}

static void counter_register_hooks (apr_pool_t *p)
{
   ap_hook_handler(counter_handler, NULL, NULL, APR_HOOK_REALLY_FIRST);
}

module AP_MODULE_DECLARE_DATA counter_module = 
{
  STANDARD20_MODULE_STUFF,
  NULL,//uvds_metrics_dir_conf,      /* Per-Directory Configuration */
  NULL,//uvds_metrics_dir_merge,           /* Directory Config Merger */
  NULL,//uvds_metrics_server_conf,         /* Per-Server Configuration */
  NULL,//uvds_metrics_server_merge,  /* Server Config Merger */
  NULL,//uvds_metrics_cmds,                /* Command Table (Directives) */
  counter_register_hooks             /* Registering Hooks */
};

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "libpq-fe.h"
#include <semaphore.h>

sem_t session_mutex;
int initial_mutex_value = 0;
int ctr = 0;

void tempToDB(char *entry);