Function ql_init

db/db_insertq.c:329–406

initializez a new query entry */

/* initializez a new query entry */
query_list_t *ql_init(db_con_t *con,db_key_t *cols,int col_no)
{
	int key_size,row_q_size,size,i;
	char *pos;
	query_list_t *entry;

	key_size = col_no * sizeof(db_key_t) + col_no * sizeof(str);
	for (i=0;i<col_no;i++)
		key_size += cols[i]->len;

	row_q_size = sizeof(db_val_t *) * query_buffer_size;
	size = sizeof(query_list_t) +
		counted_max_processes * sizeof(db_con_t *) +
		con->table->len + key_size + row_q_size + con->url.len;

	entry = shm_malloc(size);
	if (entry == NULL)
	{
		LM_ERR("no more shm\n");
		return NULL;
	}

	memset(entry,0,size);
	LM_DBG("alloced %p for %d bytes\n",entry,size);

	entry->lock = lock_alloc();
	if (entry->lock == 0)
	{
		LM_ERR("failed to alloc lock\n");
		shm_free(entry);
		return NULL;
	}

	if (lock_init(entry->lock) == 0)
	{
		LM_ERR("failed to init lock\n");
		lock_dealloc(entry->lock);
		shm_free(entry);
		return NULL;
	}

	/* deal with the table name */
	entry->table.s = (char *)entry+sizeof(query_list_t);
	entry->table.len = con->table->len;
	memcpy(entry->table.s,con->table->s,con->table->len);

	/* deal with the columns */
	entry->cols = (db_key_t *)(void *)((char *)entry+sizeof(query_list_t)+
								con->table->len);
	entry->col_no = col_no;

	pos = (char *)(entry->cols + col_no) + col_no * sizeof(str);
	for (i=0;i<col_no;i++)
	{
		entry->cols[i] = (str *)(entry->cols + col_no) + i;
		entry->cols[i]->len = cols[i]->len;
		entry->cols[i]->s = pos;
		memcpy(pos,cols[i]->s,cols[i]->len);