Server.h

#pragma once

#include "../socket/Adapter.h"
#include "../system/Module.h"

#include "ServerControls.h"
#include "ServerSettings.h"
#include "SocketsQueue.h"

#include <gnutls/gnutls.h>

namespace HttpServer
{
	class Server
	{
	protected:
		ServerSettings settings;

		std::unordered_map<int, std::tuple<gnutls_certificate_credentials_t, gnutls_priority_t> > tls_data;
	//	std::unordered_map<SocketAdapter *, std::queue<std::tuple<uint32_t> > > http_streams;

		std::vector<System::Module> modules;
		std::vector<Socket::Socket> liseners;

		mutable std::atomic_size_t threads_working_count;
		System::CachePadding<std::atomic_size_t> padding_1;

	public:
		mutable ServerControls controls;

	protected:
		int cycleQueue(SocketsQueue &sockets);

		void threadRequestProc(
			Socket::Adapter &sock,
			SocketsQueue &sockets,
			Http2::IncStream *stream
		) const;

		void threadRequestCycle(
			SocketsQueue &sockets,
			Utils::Event &eventThreadCycle
		) const;

		bool tryBindPort(
			const int port,
			std::unordered_set<int> &ports
		);

		void initAppsPorts();

		bool init();
		int run();
		void clear();

		static System::native_processid_type getServerProcessId(const std::string &serverName);

		void updateModules();

		bool updateModule(
			System::Module &module,
			std::unordered_set<ServerApplicationSettings *> &applications,
			const size_t moduleIndex
		);

	private:
		static bool get_start_args(
			const int argc,
			const char *argv[],
			struct server_start_args *st
		);

	public:
		Server() = default;

		void stop();
		void restart();
		void update();

		int command_help(const int argc, const char *argv[]) const;
		int command_start(const int argc, const char *argv[]);
		int command_restart(const int argc, const char *argv[]) const;
		int command_terminate(const int argc, const char *argv[]) const;
		int command_update_module(const int argc, const char *argv[]) const;
	};
}