Function db_cachedb_init

modules/db_cachedb/dbase.c:38–102

extern struct cachedb_url *db_cachedb_script_urls;

db_con_t* db_cachedb_init(const str* _url)
{
	char *p;
	int len;
	struct cachedb_url *it;
	cachedb_funcs cdbf;
	cachedb_con *cdbc = NULL;
	struct db_cachedb_con* ptr;
	db_con_t *res;

	if (!_url) {
		LM_ERR("invalid parameter value\n");
		return 0;
	}

	res = pkg_malloc(sizeof(db_con_t));
	if (!res) {
		LM_ERR("No more pkg mem\n");
		return NULL;
	}

	memset(res,0,sizeof(db_con_t));

	p=_url->s+sizeof("cachedb:/");
	len=_url->len-sizeof("cachedb:/");

	for (it=db_cachedb_script_urls;it;it=it->next) {
		if (memcmp(it->url.s,p,len) == 0) {
			LM_DBG("Found matching URL : [%s]\n", db_url_escape(&it->url));

			if (cachedb_bind_mod(&it->url,&cdbf) < 0) {
				LM_ERR("Cannot bind cachedb functions for URL [%s]\n",
						db_url_escape(&it->url));
				return NULL;
			}

			cdbc = cdbf.init(&it->url);
			if (cdbc == NULL) {
				LM_ERR("Failed to connect to the cachedb back-end\n");
				return NULL;
			}

			ptr = pkg_malloc(sizeof(struct db_cachedb_con));
			if (!ptr) {
				LM_ERR("no private memory left\n");
				pkg_free(res);
				return 0;
			}

			memset(ptr, 0, sizeof(struct db_cachedb_con));
			ptr->ref = 1;

			ptr->cdbc = cdbc;
			ptr->cdbf = cdbf;

			res->tail = (unsigned long)ptr;
			LM_DBG("Successfully initiated connection to [%.*s] \n",len,p);