#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 ZoO_server_thread_collection c [const restrict static 1]
)
{
	int error;

	c->threads = (struct ZoO_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)
	{
		fprintf
		(
			stderr,
         "[F] Unable to initialize worker collection's mutex: %s.\n",
         strerror(error)
		);

      return -1;
	}

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

   if (error != 0)
	{
		fprintf
		(
			stderr,
         "[F] Unable to initialize worker collection's barrier: %s.\n",
         strerror(error)
		);

      return -1;
	}

   return 0;
}

void initialize_thread_parameters
(
   struct ZoO_server server [const restrict static 1],
   const struct ZoO_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 ZoO_server_initialize
(
   struct ZoO_server server [const restrict static 1],
   const struct ZoO_parameters params [const restrict static 1]
)
{
   if (initialize_worker_collection(&(server->workers)) < 0)
   {
      return -1;
   }

   if (ZoO_knowledge_initialize(&(server->k)) < 0)
   {
      return -1;
   }

   if
   (
      ZoO_server_socket_open
      (
         &(server->socket),
         ZoO_parameters_get_session_name(params)
      ) < 0
   )
   {
      return -2;
   }

   initialize_thread_parameters(server, params);

   return 0;
}