Calling set_idle_ttl/set_check_inter in connect_manager should set all pools' status.

Author: zhengshuxin

lib_acl_cpp/samples/connect_manager/connect_manager.cpp

@@ -2,10 +2,9 @@
 #include "connect_pool.h"
 #include "connect_manager.h"
 
-connect_manager::connect_manager(size_t min_conns, time_t ttl)
+connect_manager::connect_manager(size_t min_conns)
 : min_conns_(min_conns)
 {
-	this->set_idle_ttl(ttl);
 }
 
 connect_manager::~connect_manager()

lib_acl_cpp/samples/connect_manager/connect_manager.h

@@ -3,7 +3,7 @@
 class connect_manager : public acl::connect_manager
 {
 public:
-	connect_manager(size_t min_conns, time_t ttl);
+	connect_manager(size_t min_conns);
 
 	virtual ~connect_manager();
 

lib_acl_cpp/samples/connect_manager/main.cpp

@@ -33,10 +33,11 @@ static void init(const char* addrs, int max, int min, int ttl,
 	int check_type, const char* proto)
 {
 	// 创建 HTTP 请求连接池集群管理对象
-	__conn_manager = new connect_manager((size_t) min, (time_t) ttl);
+	__conn_manager = new connect_manager((size_t) min);
 
 	// 添加服务器集群地址
 	__conn_manager->init(addrs, addrs, (size_t) max);
+	__conn_manager->set_idle_ttl(ttl);
 
 	printf(">>>start monitor thread\r\n");
 

lib_acl_cpp/src/connpool/connect_manager.cpp

@@ -76,28 +76,37 @@ static int check_addr(const char* addr, string& buf, size_t default_count)
 void connect_manager::set_retry_inter(int n)
 {
 	lock_guard guard(lock_);
-
-	if (n == retry_inter_) {
-		return;
-	}
 	retry_inter_ = n;
 	for (manager_it mit = manager_.begin(); mit != manager_.end(); ++mit) {
 		for (pools_t::iterator it = mit->second->pools.begin();
-			it != mit->second->pools.end(); ++it) {
-
+		     it != mit->second->pools.end(); ++it) {
 			(*it)->set_retry_inter(retry_inter_);
 		}
 	}
 }
 
 void connect_manager::set_check_inter(int n)
 {
+	lock_guard guard(lock_);
 	check_inter_ = n;
+	for (manager_it it = manager_.begin(); it != manager_.end(); ++it) {
+		for (pools_it it2 = it->second->pools.begin();
+		     it2 != it->second->pools.end(); ++it2) {
+			(*it2)->set_check_inter(n);
+		}
+	}
 }
 
 void connect_manager::set_idle_ttl(time_t ttl)
 {
+	lock_guard guard(lock_);
 	idle_ttl_ = ttl;
+	for (manager_it it = manager_.begin(); it != manager_.end(); ++it) {
+		for (pools_it it2 = it->second->pools.begin();
+		     it2 != it->second->pools.end(); ++it2) {
+			(*it2)->set_idle_ttl(ttl);
+		}
+	}
 }
 
 void connect_manager::init(const char* default_addr, const char* addr_list,