69 moddata_clean(struct redis_moddata** moddata) {  in moddata_clean()  argument
70 	if(!moddata || !*moddata)  in moddata_clean()
72 	if((*moddata)->ctxs) {  in moddata_clean()
74 		for(i = 0; i < (*moddata)->numctxs; i++) {  in moddata_clean()
75 			if((*moddata)->ctxs[i])  in moddata_clean()
76 				redisFree((*moddata)->ctxs[i]);  in moddata_clean()
78 		free((*moddata)->ctxs);  in moddata_clean()
80 	free(*moddata);  in moddata_clean()
81 	*moddata = NULL;  in moddata_clean()
85 redis_connect(const struct redis_moddata* moddata)  in redis_connect()  argument
89 	if(moddata->server_path && moddata->server_path[0]!=0) {  in redis_connect()
90 		ctx = redisConnectUnixWithTimeout(moddata->server_path,  in redis_connect()
91 			moddata->timeout);  in redis_connect()
93 		ctx = redisConnectWithTimeout(moddata->server_host,  in redis_connect()
94 			moddata->server_port, moddata->timeout);  in redis_connect()
103 	if(redisSetTimeout(ctx, moddata->timeout) != REDIS_OK) {  in redis_connect()
107 	if(moddata->server_password && moddata->server_password[0]!=0) {  in redis_connect()
109 		rep = redisCommand(ctx, "AUTH %s", moddata->server_password);  in redis_connect()
117 	if(moddata->logical_db > 0) {  in redis_connect()
119 		rep = redisCommand(ctx, "SELECT %d", moddata->logical_db);  in redis_connect()
122 				moddata->logical_db);  in redis_connect()
141 	struct redis_moddata* moddata = NULL;  in redis_init()  local
145 	moddata = calloc(1, sizeof(struct redis_moddata));  in redis_init()
146 	if(!moddata) {  in redis_init()
150 	moddata->numctxs = env->cfg->num_threads;  in redis_init()
151 	moddata->ctxs = calloc(env->cfg->num_threads, sizeof(redisContext*));  in redis_init()
152 	if(!moddata->ctxs) {  in redis_init()
158 	moddata->server_host = env->cfg->redis_server_host;  in redis_init()
159 	moddata->server_port = env->cfg->redis_server_port;  in redis_init()
160 	moddata->server_path = env->cfg->redis_server_path;  in redis_init()
161 	moddata->server_password = env->cfg->redis_server_password;  in redis_init()
162 	moddata->timeout.tv_sec = env->cfg->redis_timeout / 1000;  in redis_init()
163 	moddata->timeout.tv_usec = (env->cfg->redis_timeout % 1000) * 1000;  in redis_init()
164 	moddata->logical_db = env->cfg->redis_logical_db;  in redis_init()
165 	for(i = 0; i < moddata->numctxs; i++) {  in redis_init()
166 		redisContext* ctx = redis_connect(moddata);  in redis_init()
171 		moddata->ctxs[i] = ctx;  in redis_init()
173 	cachedb_env->backend_data = moddata;  in redis_init()
203 	moddata_clean(&moddata);  in redis_init()
210 	struct redis_moddata* moddata = (struct redis_moddata*)  in redis_deinit()  local
215 	moddata_clean(&moddata);  in redis_deinit()