mirror of
https://github.com/wesnoth/wesnoth
synced 2025-04-30 13:05:45 +00:00
bb01934b85
* Wesnoth is distributed under the terms of the GPL version 2, made that more explicit * updated the copyright range to 2007 * updated Dave's email adress
59 lines
1.3 KiB
C++
59 lines
1.3 KiB
C++
/* $Id$ */
|
|
/*
|
|
Copyright (C) 2003 - 2007 by David White <dave@whitevine.net>
|
|
Part of the Battle for Wesnoth Project http://www.wesnoth.org/
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License version 2.
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY.
|
|
|
|
See the COPYING file for more details.
|
|
*/
|
|
|
|
#ifndef NETWORK_WORKER_HPP_INCLUDED
|
|
#define NETWORK_WORKER_HPP_INCLUDED
|
|
|
|
#include <map>
|
|
#include <vector>
|
|
#include "config.hpp"
|
|
|
|
#include "SDL_net.h"
|
|
|
|
namespace network
|
|
{
|
|
struct statistics;
|
|
}
|
|
|
|
namespace network_worker_pool
|
|
{
|
|
|
|
struct manager
|
|
{
|
|
explicit manager(size_t min_threads,size_t max_threads);
|
|
~manager();
|
|
|
|
private:
|
|
manager(const manager&);
|
|
void operator=(const manager&);
|
|
|
|
bool active_;
|
|
};
|
|
|
|
//function to asynchronously received data to the given socket
|
|
void receive_data(TCPsocket sock);
|
|
|
|
TCPsocket get_received_data(TCPsocket sock, config& cfg);
|
|
|
|
void queue_data(TCPsocket sock, const config& buf);
|
|
bool socket_locked(TCPsocket sock);
|
|
bool close_socket(TCPsocket sock);
|
|
std::pair<unsigned int,size_t> thread_state();
|
|
TCPsocket detect_error();
|
|
|
|
std::pair<network::statistics,network::statistics> get_current_transfer_stats(TCPsocket sock);
|
|
|
|
}
|
|
|
|
#endif
|