/*
/*
Low Latency IPC Library for high-speed traffic
Copyright (C) 2019 Michael Fabian Dirks <info@xaymar.com>

This program is free software: you can redistribute it and/or modify
it under the terms of the GNU Affero General Public License as published
by the Free Software Foundation, either version 3 of the License, or
(at your option) any later version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU Affero General Public License for more details.

You should have received a copy of the GNU Affero General Public License
along with this program.  If not, see <https://www.gnu.org/licenses/>.
*/

#pragma once
#include <atomic>
#include <memory>
#include <string>

#include "error.hpp"
#include "windows-socket.hpp"

// Windows Client:
// - Also uses IOCP (best support, least issues unlike completion routines).

namespace datapath::windows {
	class client_socket : public ::datapath::windows::socket,
						  public std::enable_shared_from_this<datapath::windows::client_socket> {
		// Data
		std::mutex         _lock;
		std::atomic_bool   _opened;
		std::wstring       _path;
		std::atomic_size_t _worker_count;

		// Windows
		std::shared_ptr<void> _handle;
		std::shared_ptr<void> _iocp;

		public:
		client_socket();
		virtual ~client_socket();

		public /* Virtual Implementations */:
		virtual void set_path(std::string path) override;

		virtual void open() override;

		virtual void close() override;

		virtual bool is_open() override;

		virtual void work(std::chrono::milliseconds time_limit) override;
	};
} // namespace datapath::windows