Function mqueue_db_save_queue

modules/mqueue/mqueue_db.c:261–323

}

int mqueue_db_save_queue(str *name)
{
	int ncols = 2;
	db_key_t db_cols[2] = {&mq_db_key_column, &mq_db_val_column};
	db_val_t db_vals[2];
	int i;
	int mqueue_sz = 0;
	int ret = 0;

	if(mqueue_db_open_con() != 0) {
		LM_ERR("no db connection\n");
		return -1;
	}

	if(mq_dbf.use_table(mqueue_db_con, name) < 0) {
		LM_ERR("failed to use_table\n");
		goto error;
	}

	if(name->len <= 0 || name->s == NULL) {
		LM_ERR("bad mqueue name\n");
		goto error;
	}

	mqueue_sz = _mq_get_csize(name);

	if(mqueue_sz < 0) {
		LM_ERR("no such mqueue\n");
		goto error;
	}
	for(i = 0; i < mqueue_sz; i++) {
		ret = mq_head_fetch(name);
		if(ret != 0)
			break;
		str *key = NULL;
		str *val = NULL;
		key = get_mqk(name);
		val = get_mqv(name);
		LM_DBG("inserting mqueue[%.*s] name[%.*s] value[%.*s]\n", name->len,
				name->s, key->len, key->s, val->len, val->s);
		db_vals[0].type = DB_STR;
		db_vals[0].nul = 0;
		db_vals[0].val.str_val.s = key->s;
		db_vals[0].val.str_val.len = key->len;
		db_vals[1].type = DB_STR;
		db_vals[1].nul = 0;
		db_vals[1].val.str_val.s = val->s;
		db_vals[1].val.str_val.len = val->len;
		LM_DBG("mq_dbf.insert()\n");
		if(mq_dbf.insert(mqueue_db_con, db_cols, db_vals, ncols) < 0) {
			LM_ERR("failed to store key [%.*s] val [%.*s]\n", key->len, key->s,
					val->len, val->s);
		LM_DBG("done mq_dbf.insert()\n");
		}
	}

	LM_INFO("queue [%.*s] saved in db\n", name->len, name->s);
	mqueue_db_close_con();