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;
};