Lines Matching defs:moddata

70 moddata_clean(struct redis_moddata** moddata) {
71 	if(!moddata || !*moddata)
73 	if((*moddata)->ctxs) {
75 		for(i = 0; i < (*moddata)->numctxs; i++) {
76 			if((*moddata)->ctxs[i])
77 				redisFree((*moddata)->ctxs[i]);
79 		free((*moddata)->ctxs);
81 	free(*moddata);
82 	*moddata = NULL;
86 redis_connect(const struct redis_moddata* moddata)
90 	if(moddata->server_path && moddata->server_path[0]!=0) {
91 		ctx = redisConnectUnixWithTimeout(moddata->server_path,
92 			moddata->connect_timeout);
94 		ctx = redisConnectWithTimeout(moddata->server_host,
95 			moddata->server_port, moddata->connect_timeout);
104 	if(redisSetTimeout(ctx, moddata->command_timeout) != REDIS_OK) {
108 	if(moddata->server_password && moddata->server_password[0]!=0) {
110 		rep = redisCommand(ctx, "AUTH %s", moddata->server_password);
118 	if(moddata->logical_db > 0) {
120 		rep = redisCommand(ctx, "SELECT %d", moddata->logical_db);
123 				moddata->logical_db);
142 	struct redis_moddata* moddata = NULL;
146 	moddata = calloc(1, sizeof(struct redis_moddata));
147 	if(!moddata) {
151 	moddata->numctxs = env->cfg->num_threads;
152 	moddata->ctxs = calloc(env->cfg->num_threads, sizeof(redisContext*));
153 	if(!moddata->ctxs) {
159 	moddata->server_host = env->cfg->redis_server_host;
160 	moddata->server_port = env->cfg->redis_server_port;
161 	moddata->server_path = env->cfg->redis_server_path;
162 	moddata->server_password = env->cfg->redis_server_password;
163 	moddata->command_timeout.tv_sec = env->cfg->redis_timeout / 1000;
164 	moddata->command_timeout.tv_usec =
166 	moddata->connect_timeout.tv_sec = env->cfg->redis_timeout / 1000;
167 	moddata->connect_timeout.tv_usec =
170 		moddata->command_timeout.tv_sec =
172 		moddata->command_timeout.tv_usec =
176 		moddata->connect_timeout.tv_sec =
178 		moddata->connect_timeout.tv_usec =
181 	moddata->logical_db = env->cfg->redis_logical_db;
182 	for(i = 0; i < moddata->numctxs; i++) {
183 		redisContext* ctx = redis_connect(moddata);
188 		moddata->ctxs[i] = ctx;
190 	cachedb_env->backend_data = moddata;
220 	moddata_clean(&moddata);
227 	struct redis_moddata* moddata = (struct redis_moddata*)
232 	moddata_clean(&moddata);