Function con_set_inslist

db/db_insertq.c:470–533

set's the query_list that will be used for inserts * on the provided db connection * * also takes care of initialisation of this is the first process * attempting to execute this type of query */

 * also takes care of initialisation of this is the first process
 * attempting to execute this type of query */
int con_set_inslist(db_func_t *dbf,db_con_t *con,query_list_t **list,
							db_key_t *cols,int col_no)
{
	query_list_t *entry;

	/* if buffering not enabled, ignore */
	if (query_buffer_size <= 1)
		return 0;

	/* if buffering is enabled, but user is using a module
	 * that does not support multiple inserts,
	 * also ignore */
	if (!DB_CAPABILITY(*dbf,DB_CAP_MULTIPLE_INSERT))
		return 0;

	if (list == NULL)
		return 0;

	/* first time we are being called from this process */
	if (*list == NULL)
	{
		LM_DBG("first inslist call. searching for query list \n");
		lock_get(ql_lock);
		entry = find_query_list_unsafe(con->table,cols,col_no);
		if (entry == NULL)
		{
			LM_DBG("couldn't find entry for this query\n");
			/* first query of this type is done from this process,
			 * it's my job to initialize the query list
			 * and save for later use */
			entry = ql_init(con,cols,col_no);
			if (entry == NULL)
			{
				LM_ERR("failed to initialize ins queue\n");
				lock_release(ql_lock);
				return -1;
			}

			ql_add_unsafe(entry);
			con->ins_list = entry;
			*list = entry;
		}
		else
		{
			LM_DBG("query list already exists - attaching\n");
			/* another process has done a query of this type,
			 * just attach to the con and save for later use */
			con->ins_list = entry;
			*list = entry;
		}

		lock_release(ql_lock);
		return 0;
	}
	else
	{
		/* we've previously found our query list */
		LM_DBG("process already found it's query list\n");