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

#include "socket_header.h"
#include "Interface/Mutex.h"
#include <deque>

class FCGIProtocolDriver;
class OutputCallback;
class FCGIRequest;

class CClient
{
public:
	CClient();
	~CClient();

	SOCKET getSocket();
	OutputCallback *getOutputCallback();
	FCGIProtocolDriver *getFCGIProtocolDriver();

	void addRequest( FCGIRequest* req);
	bool removeRequest( FCGIRequest *req);
	size_t numRequests(void);
	FCGIRequest* getRequest(size_t num);
	FCGIRequest* getAndRemoveReadyRequest(void);

	bool isProcessing(void);
	bool setProcessing(bool b);

	void set(SOCKET ps, OutputCallback *poutput, FCGIProtocolDriver * pdriver );

	void lock();
	void unlock();
	void remove();
private:
	SOCKET s;
	OutputCallback * output;
	FCGIProtocolDriver * driver;
	bool processing;
	IMutex * mutex;
	IScopedLock *m_lock;
	std::deque<FCGIRequest*> requests;
};