class redis_thread : public acl::thread
{
public:
	redis_thread(const char* addr, const char* passwd, int conn_timeout,
		int rw_timeout, int fibers_max, int stack_size, int oper_count);

	~redis_thread(void) {}

private:
	acl::redis_client_cluster& get_cluster(void)
	{
		return cluster_;
	}

	int get_fibers_max(void) const
	{
		return fibers_max_;
	}

	int get_oper_count(void) const
	{
		return oper_count_;
	}

	struct timeval& get_begin(void)
	{
		return begin_;
	}

	void fiber_dec(int cnt);

protected:
	void *run(void);

	static double stamp_sub(const struct timeval *from,
		const struct timeval *sub_by);

private:
	acl::string addr_;
	acl::string passwd_;
	int conn_timeout_;
	int rw_timeout_;
	int fibers_max_;
	int fibers_cnt_;
	int stack_size_;
	int oper_count_;
	struct timeval begin_;
	acl::redis_client_cluster cluster_;

	static void fiber_redis(ACL_FIBER *fiber, void *ctx);
};