Function db_do_init

db/db.c:294–366

* Initialize database module * No function should be called before this */

 * No function should be called before this
 */
db_con_t* db_do_init(const str* url, void* (*new_connection)(const struct db_id *))
{
	struct db_id *id = NULL;
	struct pool_con *con = NULL;
	db_con_t *res = NULL;
	int con_size = 0;

	if (!url || !url->s || !new_connection) {
		LM_ERR("invalid parameter value\n");
		return 0;
	}

	con_size = sizeof(db_con_t) + sizeof(void *) + url->len;
	if (url->len > MAX_URL_LENGTH)
	{
		LM_ERR("SQL URL too long\n");
		return 0;
	}

	/* this is the root memory for this database connection. */
	res = (db_con_t*)pkg_malloc(con_size);
	if (!res) {
		LM_ERR("no private memory left\n");
		return 0;
	}

	memset(res, 0, con_size);

	/* fill in the URL info */
	res->url.s = (char *)res + sizeof(db_con_t) + sizeof(void *);
	res->url.len = url->len;
	memcpy(res->url.s,url->s,url->len);

	id = new_db_id(url);
	if (!id) {
		LM_ERR("cannot parse URL '%.*s'\n", url->len, url->s);
		goto err;
	}

	/* Find the connection in the pool */
	con = pool_get(id);
	if (!con) {
		LM_DBG("connection %p not found in pool\n", id);
		/* Not in the pool yet */
		con = (struct pool_con *)new_connection(id);
		if (!con) {
			LM_ERR("could not add connection to the pool\n");
			goto err;
		}
		pool_insert(con);
		LM_DBG("connection %p inserted in pool as %p\n", id,con);
	} else {
		LM_DBG("connection %p found in pool as %p\n", id,con);
		free_db_id(id);
	}

	if (!con->transfers) {
		con->transfers = pkg_malloc(db_max_async_connections *