acl/lib_acl_cpp/src/redis/redis_client_pool.cpp at master · acl-dev/acl · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
#include "acl_stdafx.hpp"
#ifndef ACL_PREPARE_COMPILE
#include "acl_cpp/redis/redis_client.hpp"
#include "acl_cpp/redis/redis_client_pool.hpp"
#endif

#if !defined(ACL_CLIENT_ONLY) && !defined(ACL_REDIS_DISABLE)

namespace acl {

redis_client_pool::redis_client_pool(const char* addr, size_t count,
	size_t idx /* = 0 */)
: connect_pool(addr, count, idx)
, pass_(NULL)
, dbnum_(0)
, ssl_conf_(NULL)
{
}

redis_client_pool::~redis_client_pool()
{
	if (pass_) {
		acl_myfree(pass_);
	}
}

redis_client_pool& redis_client_pool::set_ssl_conf(sslbase_conf* ssl_conf)
{
	ssl_conf_ = ssl_conf;
	return *this;
}

redis_client_pool& redis_client_pool::set_password(const char* pass)
{
	if (pass_) {
		acl_myfree(pass_);
	}
	if (pass && *pass) {
		pass_ = acl_mystrdup(pass);
	} else {
		pass_ = NULL;
	}
	return *this;
}

redis_client_pool& redis_client_pool::set_db(int dbnum)
{
	if (dbnum > 0) {
		dbnum_ = dbnum;
	}
	return *this;
}

connect_client* redis_client_pool::create_connect()
{
	redis_client* conn = NEW redis_client(addr_, conn_timeout_,
		rw_timeout_);
	if (ssl_conf_) {
		conn->set_ssl_conf(ssl_conf_);
	}
	if (pass_) {
		conn->set_password(pass_);
	}
	if (dbnum_ > 0) {
		conn->set_db(dbnum_);
	}
	return conn;
}

} // namespace acl

#endif // ACL_CLIENT_ONLY