dev

分支 (7)

标签 (101)

管理

管理

dev

2.5.x

2.4.x

2.3.x

2.2.x

2.1.x

next

2.5.20

2.4.11client

2.4.8client

2.4.9

2.3.7

2.3.6

2.2.4client

2.2.7

2.2.6

2.1.20

2.2.3client

2.2.5

2.2.4

2.2.1client

2.2.2

2.1.15client

2.1.14client

2.1.18

2.1.13client

2.1.17

urbackup_backend
/
ServiceAcceptor.h

#include <vector>
#include <string>
#include "socket_header.h"
#include "Interface/Thread.h"
#include "Interface/Pipe.h"
#include "Server.h"

class CServiceWorker;
class IService;

class CServiceAcceptor : public IThread
{
public:
	CServiceAcceptor(IService * pService, std::string pName, unsigned short port, int pMaxClientsPerThread, IServer::BindTarget bindTarget);
	~CServiceAcceptor();

	void operator()(void);

private:
	void AddToWorker(SOCKET pSocket, const std::string& endpoint);

	bool init_socket_v4(unsigned short port, IServer::BindTarget bindTarget);

	bool init_socket_v6(unsigned short port, IServer::BindTarget bindTarget);

	std::vector<CServiceWorker*> workers;
	SOCKET s;
	SOCKET s_v6;

	std::string name;

	IService * service;
	IPipe *exitpipe;
#ifndef _WIN32
	int xpipe[2];
#endif

	bool do_exit;

	bool has_error;

	int maxClientsPerThread;
};