#include <signal.h>
#include <string.h>
#include <stdio.h>

#include "../parameters/parameters.h"

#include "../knowledge/knowledge.h"

#include "server.h"

static int initialize_worker_collection
(
   struct JH_server_thread_collection c [const restrict static 1]
)
{
   int error;

   c->threads = (struct JH_server_thread_data *) NULL;
   c->threads_capacity = 0;
   c->currently_running = 0;

   error =
      pthread_mutex_init
      (
         &(c->mutex),
         (const pthread_mutexattr_t *) NULL
      );

   if (error != 0)
   {
      JH_FATAL
      (
         stderr,
         "Unable to initialize worker collection's mutex: %s.",
         strerror(error)
      );

      return -1;
   }

   error =
      pthread_barrier_init
      (
         &(c->barrier),
         (const pthread_barrierattr_t *) NULL,
         2
      );

   if (error != 0)
   {
      pthread_mutex_destroy(&(c->mutex));

      JH_FATAL
      (
         stderr,
         "[F] Unable to initialize worker collection's barrier: %s.",
         strerror(error)
      );

      return -1;
   }

   return 0;
}

static void finalize_worker_collection
(
   struct JH_server_thread_collection c [const restrict static 1]
)
{
   pthread_mutex_destroy(&(c->mutex));
   pthread_barrier_destroy(&(c->barrier));
}

static void initialize_thread_parameters
(
   struct JH_server server [const restrict static 1],
   const struct JH_parameters params [const restrict static 1]
)
{
   server->thread_params.thread_collection = &(server->workers);
   server->thread_params.server_params = params;
   server->thread_params.knowledge = &(server->k);
   server->thread_params.socket = -1;
}

int JH_server_initialize
(
   struct JH_server server [const restrict static 1],
   const struct JH_parameters params [const restrict static 1]
)
{
   if (JH_server_set_signal_handlers() < 0)
   {
      return -1;
   }

   if (initialize_worker_collection(&(server->workers)) < 0)
   {
      return -1;
   }

   if (JH_knowledge_initialize(&(server->k)) < 0)
   {
      finalize_worker_collection(&(server->workers));

      return -1;
   }

   if
   (
      JH_server_socket_open
      (
         &(server->socket),
         JH_parameters_get_session_name(params)
      ) < 0
   )
   {
      finalize_worker_collection(&(server->workers));
      JH_knowledge_finalize(&(server->k));

      return -2;
   }

   initialize_thread_parameters(server, params);

   return 0;
}