Class check_job

lib_acl_cpp/src/connpool/connect_pool.cpp:12–47

namespace acl {

class check_job : public thread_job {
public:
	check_job(tbox<bool>& box, connect_client& conn, bool opened)
	: box_(box), conn_(conn), opened_(opened), aliving_(true) {}

	~check_job() {}

	// Get the checking result for the given connection.
	bool aliving() const {
		return aliving_;
	}

	// Get the connection.
	connect_client& get_conn() const {
		return conn_;
	}

protected:
	// @overide
	void* run() {
		if (opened_) {
			aliving_ = conn_.alive();
		} else {
			aliving_ = conn_.open();
		}

		box_.push(NULL);
		return NULL;
	}

private:
	tbox<bool>& box_;
	connect_client& conn_;
	bool opened_;
	bool aliving_;
};

connect_pool::connect_pool(const char* addr, size_t max, size_t idx /* = 0 */)
: alive_(true)