Function cachedb_do_init

cachedb/cachedb.c:635–691

}

cachedb_con* cachedb_do_init(str *url,void* (*new_connection)(struct cachedb_id *))
{
	struct cachedb_id* id;
	cachedb_con* res;
	void *con;

	if (url == NULL || url->s == NULL || new_connection == NULL) {
		LM_ERR("NULL parameter provided\n");
		return 0;
	}

	res = pkg_malloc(sizeof(cachedb_con) + url->len);
	if (res == NULL) {
		LM_ERR("no more pkg mem\n");
		return 0;
	}

	id = NULL;

	memset(res,0,sizeof(cachedb_con) + url->len);
	res->url.s = (char *)res + sizeof(cachedb_con);
	res->url.len = url->len;
	memcpy(res->url.s,url->s,url->len);

	id = new_cachedb_id(url);
	if (!id) {
		LM_ERR("cannot parse url [%s]\n", db_url_escape(url));
		pkg_free(res);
		return 0;
	}

	con = cachedb_pool_get(id);
	if (con == NULL) {
		LM_DBG("opening new connection\n");
		con = new_connection(id);
		if (con == NULL) {
			LM_ERR("failed to open connection\n");
			goto err;
		}

		cachedb_pool_insert((cachedb_pool_con *)con);
	} else {
		LM_DBG("connection already in pool\n");
		free_cachedb_id(id);
	}

	res->data = con;
	return res;

err:
	if (res)
		pkg_free(res);
	if (id)
		free_cachedb_id(id);

	return 0;
}