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
/
AcceptThread.h

#include <vector>

#include "socket_header.h"
#include "types.h"
#include "libfastcgi/fastcgi.hpp"

class CSelectThread;
class CClient;

class CAcceptThread
{
public:
	CAcceptThread(unsigned int nWorkerThreadsPerMaster, unsigned short int uPort);
	~CAcceptThread();

	void operator()(bool single=false);

	bool has_error(void);

private:
	void AddToSelectThread(CClient *client);

	bool init_socket_v4(unsigned short port);
	bool init_socket_v6(unsigned short port);

	std::vector<CSelectThread*> SelectThreads;

	SOCKET s;
	SOCKET s_v6;
	unsigned int WorkerThreadsPerMaster;
	bool error;
};

class OutputCallback : public FCGIProtocolDriver::OutputCallback
{
public:

  virtual ~OutputCallback();
  OutputCallback(SOCKET fd_);

  virtual void operator() (const void* buf, size_t count);
private:
  SOCKET fd;
};