exchange/src/mintdb/perf_taler_mintdb_interpreter.c

1700 lines
58 KiB
C
Raw Normal View History

2015-06-09 17:35:33 +02:00
/*
This file is part of TALER
Copyright (C) 2014, 2015 Christian Grothoff (and other contributing authors)
2015-06-09 17:35:33 +02:00
TALER is free software; you can redistribute it and/or modify it under the
terms of the GNU General Public License as published by the Free Software
Foundation; either version 3, or (at your option) any later version.
TALER is distributed in the hope that it will be useful, but WITHOUT ANY
WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
A PARTICULAR PURPOSE. See the GNU General Public License for more details.
2015-06-09 17:35:33 +02:00
You should have received a copy of the GNU General Public License along with
TALER; see the file COPYING. If not, If not, see <http://www.gnu.org/licenses/>
*/
/**
* @file mintdb/perf_taler_mintdb_interpreter.c
* @brief Interpreter library for mint database performance analysis
* @author Nicolas Fournier
*/
2015-06-12 11:14:32 +02:00
#include "platform.h"
2015-06-09 17:35:33 +02:00
#include "perf_taler_mintdb_interpreter.h"
#include "perf_taler_mintdb_init.h"
2015-06-12 11:14:32 +02:00
#include "gauger.h"
2015-06-11 15:55:46 +02:00
/**
* Represents the state of the interpreter
*/
struct PERF_TALER_MINTDB_interpreter_state
{
/**
* State of the commands
*/
struct PERF_TALER_MINTDB_Cmd *cmd;
/**
* Database plugin
*/
struct TALER_MINTDB_Plugin *plugin;
/**
* Current database session
*/
struct TALER_MINTDB_Session *session;
/**
* The current index of the interpreter
*/
unsigned int i;
2015-06-11 15:55:46 +02:00
};
2015-06-11 15:55:46 +02:00
/**
2015-07-01 10:14:51 +02:00
* Free the memory of @a data
2015-06-11 15:55:46 +02:00
*/
static void
2015-07-01 10:14:51 +02:00
data_free (struct PERF_TALER_MINTDB_Data *data)
{
2015-07-01 10:14:51 +02:00
switch (data->type)
2015-06-11 15:55:46 +02:00
{
2015-07-17 16:23:12 +02:00
case PERF_TALER_MINTDB_TIME:
if (NULL == data->data.time)
break;
2015-08-06 14:56:24 +02:00
GNUNET_free (data->data.time);
data->data.time = NULL;
break;
2015-07-17 16:23:12 +02:00
2015-06-11 15:55:46 +02:00
case PERF_TALER_MINTDB_DEPOSIT:
2015-07-09 10:46:33 +02:00
if (NULL == data->data.deposit)
break;
2015-07-01 10:14:51 +02:00
PERF_TALER_MINTDB_deposit_free (data->data.deposit);
data->data.deposit = NULL;
break;
2015-06-11 15:55:46 +02:00
2015-07-15 17:46:49 +02:00
case PERF_TALER_MINTDB_COIN:
if (NULL == data->data.coin)
break;
2015-07-15 17:46:49 +02:00
PERF_TALER_MINTDB_coin_free (data->data.coin);
data->data.coin = NULL;
break;
case PERF_TALER_MINTDB_RESERVE:
2015-07-09 10:46:33 +02:00
if (NULL == data->data.reserve)
break;
2015-07-01 10:14:51 +02:00
PERF_TALER_MINTDB_reserve_free (data->data.reserve);
data->data.reserve = NULL;
break;
case PERF_TALER_MINTDB_DENOMINATION_INFO:
2015-07-09 10:46:33 +02:00
if (NULL == data->data.dki)
break;
2015-07-01 10:14:51 +02:00
PERF_TALER_MINTDB_denomination_free (data->data.dki);
data->data.dki = NULL;
break;
2015-08-10 18:12:27 +02:00
case PERF_TALER_MINTDB_REFRESH_HASH:
if (NULL == data->data.session_hash)
break;
GNUNET_free (data->data.session_hash);
data->data.session_hash = NULL;
break;
case PERF_TALER_MINTDB_REFRESH_MELT:
if (NULL == data->data.refresh_melt)
break;
PERF_TALER_MINTDB_refresh_melt_free (data->data.refresh_melt);
data->data.refresh_melt = NULL;
break;
case PERF_TALER_MINTDB_NONE:
break;
2015-06-11 15:55:46 +02:00
}
2015-06-25 15:31:15 +02:00
}
2015-06-11 15:55:46 +02:00
2015-07-01 10:14:51 +02:00
/**
2015-07-01 18:14:28 +02:00
* Copies @a data into @a copy
2015-07-01 10:14:51 +02:00
*
2015-07-01 18:14:28 +02:00
* @param data the data to be copied
* @param[out] copy the copy made
2015-07-01 10:14:51 +02:00
*/
static void
data_copy (const struct PERF_TALER_MINTDB_Data *data,
struct PERF_TALER_MINTDB_Data *copy)
2015-07-01 10:14:51 +02:00
{
copy->type = data->type;
switch (data->type)
{
case PERF_TALER_MINTDB_TIME:
2015-07-17 16:23:12 +02:00
copy->data.time = GNUNET_new (struct GNUNET_TIME_Absolute);
*copy->data.time = *data->data.time;
2015-07-01 10:14:51 +02:00
return;
case PERF_TALER_MINTDB_DEPOSIT:
2015-08-07 10:51:27 +02:00
copy->data.deposit
= PERF_TALER_MINTDB_deposit_copy (data->data.deposit);
2015-07-01 10:14:51 +02:00
return;
2015-07-15 17:46:49 +02:00
case PERF_TALER_MINTDB_COIN:
2015-08-06 12:46:15 +02:00
copy->data.coin
= PERF_TALER_MINTDB_coin_copy (data->data.coin);
2015-07-01 10:14:51 +02:00
return;
case PERF_TALER_MINTDB_RESERVE:
2015-08-07 10:51:27 +02:00
copy->data.reserve
= PERF_TALER_MINTDB_reserve_copy (data->data.reserve);
2015-07-01 10:14:51 +02:00
return;
case PERF_TALER_MINTDB_DENOMINATION_INFO:
2015-08-07 10:51:27 +02:00
copy->data.dki
= PERF_TALER_MINTDB_denomination_copy (data->data.dki);
2015-07-01 10:14:51 +02:00
return;
2015-08-10 18:12:27 +02:00
case PERF_TALER_MINTDB_REFRESH_HASH:
copy-> data.session_hash = GNUNET_new (struct GNUNET_HashCode);
*copy->data.session_hash
= *data->data.session_hash;
break;
case PERF_TALER_MINTDB_REFRESH_MELT:
copy->data.refresh_melt
= PERF_TALER_MINTDB_refresh_melt_copy (data->data.refresh_melt);
break;
case PERF_TALER_MINTDB_NONE:
break;
2015-07-01 10:14:51 +02:00
}
}
2015-07-01 18:14:28 +02:00
/**
* Finds the first command in cmd with the name search
*
2015-06-09 17:35:33 +02:00
* @return the index of the first command with name search
2015-07-01 14:31:48 +02:00
* #GNUNET_SYSERR if none found
*/
2015-06-09 17:35:33 +02:00
static int
cmd_find (const struct PERF_TALER_MINTDB_Cmd *cmd,
const char *search)
{
unsigned int i;
for (i=0; PERF_TALER_MINTDB_CMD_END != cmd[i].command; i++)
if (0 == strcmp (cmd[i].label, search))
return i;
2015-06-09 13:55:05 +02:00
return GNUNET_SYSERR;
}
2015-06-11 15:55:46 +02:00
/**
2015-06-25 15:31:15 +02:00
* Initialization of a command array
2015-07-28 14:07:12 +02:00
* and check for the type of the label
*
2015-07-01 18:14:28 +02:00
* @param cmd the comand array initialized
2015-07-28 14:07:12 +02:00
* @return #GNUNET_OK if the initialization was sucessful
* #GNUNET_SYSERR if there was a probleb. See the log for details
2015-06-11 15:55:46 +02:00
*/
2015-06-09 17:35:33 +02:00
static int
2015-06-11 15:55:46 +02:00
cmd_init (struct PERF_TALER_MINTDB_Cmd cmd[])
{
2015-07-01 14:31:48 +02:00
unsigned int i;
2015-06-19 10:55:13 +02:00
2015-06-09 17:35:33 +02:00
for (i=0; PERF_TALER_MINTDB_CMD_END != cmd[i].command; i++)
{
switch (cmd[i].command)
{
2015-07-28 14:07:12 +02:00
case PERF_TALER_MINTDB_CMD_END_LOOP:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.end_loop.label_loop);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.end_loop.label_loop);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_CMD_LOOP != cmd[ret].command)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.end_loop.label_loop);
return GNUNET_SYSERR;
}
cmd[i].details.end_loop.index_loop = ret;
}
break;
2015-06-09 17:35:33 +02:00
case PERF_TALER_MINTDB_CMD_SAVE_ARRAY:
{
2015-07-28 14:07:12 +02:00
int ret;
ret = cmd_find (cmd,
cmd[i].details.save_array.label_save);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.save_array.label_save);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_NONE == cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.save_array.label_save);
return GNUNET_SYSERR;
}
cmd[i].details.save_array.index_save = ret;
ret = cmd_find (cmd,
cmd[i].details.save_array.label_loop);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.save_array.label_loop);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_CMD_LOOP != cmd[ret].command)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.save_array.label_loop);
return GNUNET_SYSERR;
}
cmd[i].details.save_array.index_loop = ret;
2015-07-01 14:31:48 +02:00
GNUNET_assert (NULL == cmd[i].details.save_array.data_saved);
2015-07-01 14:31:48 +02:00
cmd[i].details.save_array.data_saved =
GNUNET_new_array (cmd[i].details.save_array.nb_saved,
struct PERF_TALER_MINTDB_Data);
cmd[i].details.save_array.type_saved =
2015-07-28 14:07:12 +02:00
cmd[cmd[i].details.save_array.index_save].exposed.type;
}
break;
2015-06-09 17:35:33 +02:00
case PERF_TALER_MINTDB_CMD_LOAD_ARRAY:
{
2015-07-28 14:07:12 +02:00
int ret;
2015-07-28 14:07:12 +02:00
ret = cmd_find (cmd,
cmd[i].details.load_array.label_save);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.load_array.label_save);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_CMD_SAVE_ARRAY != cmd[ret].command)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.load_array.label_save);
return GNUNET_SYSERR;
}
cmd[i].details.load_array.index_save = ret;
ret = cmd_find (cmd,
cmd[i].details.load_array.label_loop);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.load_array.label_loop);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_CMD_LOOP != cmd[ret].command)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.load_array.label_loop);
return GNUNET_SYSERR;
}
cmd[i].details.load_array.index_loop = ret;
cmd[i].details.load_array.permutation =
GNUNET_CRYPTO_random_permute (
GNUNET_CRYPTO_QUALITY_WEAK,
2015-07-28 15:52:58 +02:00
cmd[cmd[i].details.load_array.index_save].details.save_array.nb_saved);
2015-07-28 14:07:12 +02:00
GNUNET_assert (NULL != cmd[i].details.load_array.permutation);
cmd[i].exposed.type = cmd[cmd[i].details.load_array.index_save].details.save_array.type_saved;
2015-07-28 14:07:12 +02:00
}
break;
case PERF_TALER_MINTDB_CMD_LOAD_RANDOM:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.load_random.label_save);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.load_random.label_save);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_CMD_SAVE_ARRAY != cmd[ret].command)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.load_random.label_save);
return GNUNET_SYSERR;
}
cmd[i].details.load_random.index_save = ret;
}
break;
case PERF_TALER_MINTDB_CMD_GAUGER:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.gauger.label_start);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.gauger.label_start);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_TIME != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.gauger.label_start);
return GNUNET_SYSERR;
}
cmd[i].details.gauger.index_start = ret;
ret = cmd_find (cmd,
cmd[i].details.gauger.label_stop);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.gauger.label_stop);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_TIME != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.gauger.label_stop);
return GNUNET_SYSERR;
}
cmd[i].details.gauger.index_stop = ret;
}
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_INSERT_DENOMINATION:
2015-07-28 14:07:12 +02:00
{
int ret;
2015-08-10 15:11:02 +02:00
ret = cmd_find (cmd,
cmd[i].details.insert_denomination.label_denom);
2015-07-28 14:07:12 +02:00
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.insert_denomination.label_denom);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
if (PERF_TALER_MINTDB_DENOMINATION_INFO != cmd[ret].exposed.type)
2015-07-28 14:07:12 +02:00
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.insert_denomination.label_denom);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
cmd[i].details.insert_denomination.index_denom = ret;
2015-07-28 14:07:12 +02:00
}
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_GET_DENOMINATION:
2015-07-28 14:07:12 +02:00
{
int ret;
ret = cmd_find (cmd,
2015-08-10 15:11:02 +02:00
cmd[i].details.get_denomination.label_denom);
2015-07-28 14:07:12 +02:00
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.get_denomination.label_denom);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
if (PERF_TALER_MINTDB_DENOMINATION_INFO != cmd[ret].exposed.type)
2015-07-28 14:07:12 +02:00
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.get_denomination.label_denom);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
cmd[i].details.get_denomination.index_denom = ret;
}
break;
case PERF_TALER_MINTDB_CMD_INSERT_RESERVE:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.insert_reserve.label_reserve);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Undefined reference to %s\n",
i,
cmd[i].details.insert_reserve.label_reserve);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_RESERVE != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Wrong type reference to %s\n",
i,
cmd[i].details.insert_reserve.label_reserve);
return GNUNET_SYSERR;
}
cmd[i].details.insert_reserve.index_reserve = ret;
2015-07-28 14:07:12 +02:00
}
break;
case PERF_TALER_MINTDB_CMD_GET_RESERVE:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.get_reserve.label_reserve);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.get_reserve.label_reserve);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_RESERVE != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.get_reserve.label_reserve);
return GNUNET_SYSERR;
}
cmd[i].details.get_reserve.index_reserve = ret;
}
break;
case PERF_TALER_MINTDB_CMD_GET_RESERVE_HISTORY:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.get_reserve_history.label_reserve);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.get_reserve_history.label_reserve);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_RESERVE != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
cmd[i].details.get_reserve_history.label_reserve);
return GNUNET_SYSERR;
}
cmd[i].details.get_reserve_history.index_reserve = ret;
}
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_CREATE_WITHDRAW:
2015-07-28 14:07:12 +02:00
{
int ret;
ret = cmd_find (cmd,
2015-08-10 15:11:02 +02:00
cmd[i].details.create_withdraw.label_dki);
{
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Undefined reference to %s\n",
i,
cmd[i].details.create_withdraw.label_dki);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_DENOMINATION_INFO != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Wrong type reference to %s\n",
i,
cmd[i].details.create_withdraw.label_dki);
return GNUNET_SYSERR;
}
}
cmd[i].details.create_withdraw.index_dki = ret;
ret = cmd_find (cmd,
cmd[i].details.create_withdraw.label_reserve);
{
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Undefined reference to %s\n",
i,
cmd[i].details.create_withdraw.label_reserve);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_RESERVE != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Wrong type reference to %s\n",
i,
cmd[i].details.create_withdraw.label_reserve);
return GNUNET_SYSERR;
}
}
cmd[i].details.create_withdraw.index_reserve = ret;
}
break;
case PERF_TALER_MINTDB_CMD_INSERT_WITHDRAW:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.insert_withdraw.label_coin);
2015-07-28 14:07:12 +02:00
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.insert_withdraw.label_coin);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
if (PERF_TALER_MINTDB_COIN != cmd[ret].exposed.type)
2015-07-28 14:07:12 +02:00
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.insert_withdraw.label_coin);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
cmd[i].details.insert_withdraw.index_coin = ret;
2015-07-28 14:07:12 +02:00
}
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_GET_WITHDRAW:
2015-07-28 14:07:12 +02:00
{
int ret;
ret = cmd_find (cmd,
2015-08-10 15:11:02 +02:00
cmd[i].details.get_withdraw.label_coin);
2015-07-28 14:07:12 +02:00
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.get_withdraw.label_coin);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
if (PERF_TALER_MINTDB_COIN != cmd[ret].exposed.type)
2015-07-28 14:07:12 +02:00
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.get_withdraw.label_coin);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
cmd[i].details.get_withdraw.index_coin = ret;
}
break;
2015-07-28 14:07:12 +02:00
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_GET_COIN_TRANSACTION:
{
int ret;
2015-07-28 14:07:12 +02:00
ret = cmd_find (cmd,
2015-08-10 15:11:02 +02:00
cmd[i].details.get_coin_transaction.label_coin);
2015-07-28 14:07:12 +02:00
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.get_coin_transaction.label_coin);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
if (PERF_TALER_MINTDB_COIN != cmd[ret].exposed.type)
2015-07-28 14:07:12 +02:00
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.get_coin_transaction.label_coin);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
cmd[i].details.get_coin_transaction.index_coin = ret;
2015-07-28 14:07:12 +02:00
}
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_CREATE_DEPOSIT:
2015-07-28 14:07:12 +02:00
{
int ret;
ret = cmd_find (cmd,
2015-08-10 15:11:02 +02:00
cmd[i].details.create_deposit.label_coin);
2015-07-28 14:07:12 +02:00
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Undefined reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.create_deposit.label_coin);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_COIN != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-03 10:26:52 +02:00
"%d:Wrong type reference to %s\n",
2015-07-28 14:07:12 +02:00
i,
2015-08-10 15:11:02 +02:00
cmd[i].details.create_deposit.label_coin);
2015-07-28 14:07:12 +02:00
return GNUNET_SYSERR;
}
2015-08-10 15:11:02 +02:00
cmd[i].details.create_deposit.index_coin = ret;
}
break;
2015-06-09 17:35:33 +02:00
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_INSERT_DEPOSIT:
{
int ret;
ret = cmd_find( cmd,
cmd[i].details.insert_deposit.label_deposit);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Undefined reference to %s\n",
i,
cmd[i].details.insert_deposit.label_deposit);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_DEPOSIT != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Wrong type reference to %s\n",
i,
cmd[i].details.insert_deposit.label_deposit);
return GNUNET_SYSERR;
}
cmd[i].details.insert_deposit.index_deposit = ret;
}
break;
case PERF_TALER_MINTDB_CMD_GET_DEPOSIT:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.get_deposit.label_deposit);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Undefined reference to %s\n",
i,
cmd[i].details.get_deposit.label_deposit);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_DEPOSIT != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Wrong type reference to %s\n",
i,
cmd[i].details.get_deposit.label_deposit);
return GNUNET_SYSERR;
}
cmd[i].details.get_deposit.index_deposit = ret;
}
break;
2015-08-10 18:12:27 +02:00
case PERF_TALER_MINTDB_CMD_GET_REFRESH_SESSION:
{
int ret;
2015-08-11 15:52:40 +02:00
2015-08-10 18:12:27 +02:00
ret = cmd_find (cmd,
cmd[i].details.get_refresh_session.label_hash);
2015-08-11 15:52:40 +02:00
if (GNUNET_SYSERR == ret)
2015-08-10 18:12:27 +02:00
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Undefined reference to %s\n",
i,
cmd[i].details.get_refresh_session.label_hash);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_REFRESH_HASH != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Wrong type reference to %s\n",
i,
cmd[i].details.get_refresh_session.label_hash);
return GNUNET_SYSERR;
}
cmd[i].details.get_refresh_session.index_hash = ret;
}
break;
2015-08-11 15:52:40 +02:00
case PERF_TALER_MINTDB_CMD_INSERT_REFRESH_MELT:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.insert_refresh_melt.label_hash);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Undefined reference to %s\n",
i,
cmd[i].details.insert_refresh_melt.label_hash);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_REFRESH_HASH != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Wrong type reference to %s\n",
i,
cmd[i].details.insert_refresh_melt.label_hash);
return GNUNET_SYSERR;
}
cmd[i].details.insert_refresh_melt.index_hash = ret;
ret = cmd_find (cmd,
cmd[i].details.insert_refresh_melt.label_coin);
if (GNUNET_SYSERR == ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Undefined reference to %s\n",
i,
cmd[i].details.insert_refresh_melt.label_coin);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_COIN != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Wrong type reference to %s\n",
i,
cmd[i].details.insert_refresh_melt.label_coin);
return GNUNET_SYSERR;
}
cmd[i].details.insert_refresh_melt.index_coin = ret; }
break;
2015-08-10 18:12:27 +02:00
case PERF_TALER_MINTDB_CMD_GET_REFRESH_MELT:
{
int ret;
ret = cmd_find (cmd,
cmd[i].details.get_refresh_melt.label_hash);
2015-08-11 15:52:40 +02:00
if (GNUNET_SYSERR == ret)
2015-08-10 18:12:27 +02:00
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Undefined reference to %s\n",
i,
cmd[i].details.get_refresh_melt.label_hash);
return GNUNET_SYSERR;
}
if (PERF_TALER_MINTDB_REFRESH_HASH != cmd[ret].exposed.type)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
"%d:Wrong type reference to %s\n",
i,
cmd[i].details.get_refresh_melt.label_hash);
return GNUNET_SYSERR;
}
cmd[i].details.get_refresh_melt.index_hash = ret;
}
break;
2015-08-10 15:11:02 +02:00
2015-08-05 16:07:34 +02:00
case PERF_TALER_MINTDB_CMD_END:
case PERF_TALER_MINTDB_CMD_DEBUG:
case PERF_TALER_MINTDB_CMD_LOOP:
case PERF_TALER_MINTDB_CMD_START_TRANSACTION:
case PERF_TALER_MINTDB_CMD_COMMIT_TRANSACTION:
case PERF_TALER_MINTDB_CMD_ABORT_TRANSACTION:
case PERF_TALER_MINTDB_CMD_GET_TIME:
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_CREATE_DENOMINATION:
case PERF_TALER_MINTDB_CMD_CREATE_RESERVE:
2015-08-05 16:07:34 +02:00
break;
default:
break;
2015-08-10 18:12:27 +02:00
}
}
return GNUNET_OK;
}
/**
* Free the memory of the command chain
*/
static int
cmd_clean (struct PERF_TALER_MINTDB_Cmd cmd[])
{
2015-07-01 14:31:48 +02:00
unsigned int i;
2015-06-19 10:55:13 +02:00
2015-07-01 14:31:48 +02:00
for (i=0; PERF_TALER_MINTDB_CMD_END != cmd[i].command; i++)
{
switch (cmd[i].command)
{
case PERF_TALER_MINTDB_CMD_SAVE_ARRAY:
{
unsigned int j;
2015-07-01 14:31:48 +02:00
2015-06-11 15:55:46 +02:00
for (j = 0; j < cmd[i].details.save_array.nb_saved; j++)
{
2015-07-01 10:14:51 +02:00
data_free (&cmd[i].details.save_array.data_saved[j]);
}
2015-06-11 15:55:46 +02:00
GNUNET_free (cmd[i].details.save_array.data_saved);
cmd[i].details.save_array.data_saved = NULL;
}
2015-06-19 10:55:13 +02:00
break;
case PERF_TALER_MINTDB_CMD_LOAD_ARRAY:
GNUNET_free (cmd[i].details.load_array.permutation);
2015-06-19 10:55:13 +02:00
cmd[i].details.load_array.permutation = NULL;
break;
default:
break;
}
2015-08-06 14:56:24 +02:00
data_free (&cmd[i].exposed);
}
return GNUNET_OK;
2015-07-01 14:31:48 +02:00
}
2015-06-11 15:55:46 +02:00
/**
2015-07-01 18:14:28 +02:00
* Handles the command #PERF_TALER_MINTDB_CMD_END_LOOP for the interpreter
* Cleans the memory at the end of the loop
2015-06-11 15:55:46 +02:00
*/
static void
interpret_end_loop (struct PERF_TALER_MINTDB_interpreter_state *state)
{
unsigned int i;
2015-06-30 09:23:04 +02:00
int jump;
2015-07-01 14:31:48 +02:00
2015-07-28 14:07:12 +02:00
jump = state->cmd[state->i].details.end_loop.index_loop;
2015-06-17 17:24:08 +02:00
// Cleaning up the memory in the loop
for (i = jump; i < state->i; i++)
2015-07-01 10:14:51 +02:00
data_free (&state->cmd[i].exposed);
2015-06-17 17:24:08 +02:00
state->cmd[jump].details.loop.curr_iteration++;
/* If the loop is not finished */
2015-06-25 15:31:15 +02:00
if (state->cmd[jump].details.loop.max_iterations >
2015-06-12 11:14:32 +02:00
state->cmd[jump].details.loop.curr_iteration)
2015-06-11 15:55:46 +02:00
{
/* jump back to the start */
state->i = jump;
2015-07-01 14:31:48 +02:00
}
else
{
/* Reset the loop counter and continue running */
state->cmd[jump].details.loop.curr_iteration = 0;
2015-06-11 15:55:46 +02:00
}
}
2015-06-19 10:55:13 +02:00
/**
2015-07-28 14:07:12 +02:00
* Part of the interpreter specific to
2015-07-01 18:14:28 +02:00
* #PERF_TALER_MINTDB_CMD_SAVE_ARRAY
* Saves the data exposed by another command into
* an array in the command specific struct.
*/
static void
interpret_save_array (struct PERF_TALER_MINTDB_interpreter_state *state)
{
2015-07-01 14:31:48 +02:00
struct PERF_TALER_MINTDB_Cmd *cmd = &state->cmd[state->i];
struct PERF_TALER_MINTDB_Cmd *save_ref;
struct PERF_TALER_MINTDB_Cmd *loop_ref;
int loop_index;
int save_index;
unsigned int selection_chance;
2015-06-19 10:55:13 +02:00
2015-07-28 14:07:12 +02:00
loop_index = cmd->details.save_array.index_loop;
save_index = cmd->details.save_array.index_save;
2015-07-01 18:14:28 +02:00
loop_ref = &state->cmd[loop_index];
2015-07-01 14:31:48 +02:00
save_ref = &state->cmd[save_index];
/* Array initialization on first loop iteration
Alows for nested loops */
2015-07-01 14:31:48 +02:00
if (0 == cmd->details.loop.curr_iteration)
{
2015-07-01 14:31:48 +02:00
cmd->details.save_array.index = 0;
}
/* The probability distribution of the saved items will be a little biased
against the few last items but it should not be a big problem. */
2015-07-01 14:31:48 +02:00
selection_chance = loop_ref->details.loop.max_iterations /
2015-07-01 18:14:28 +02:00
cmd->details.save_array.nb_saved;
/*
* If the remaining space is equal to the remaining number of
* iterations, the item is automaticly saved.
*
* Else it is saved only if the random numbre generated is 0
*/
2015-07-01 18:14:28 +02:00
if ( (0 < (cmd->details.save_array.nb_saved -
cmd->details.save_array.index) ) &&
( ((loop_ref->details.loop.max_iterations -
loop_ref->details.loop.curr_iteration) ==
(cmd->details.save_array.nb_saved -
cmd->details.save_array.index)) ||
2015-07-01 14:31:48 +02:00
(0 == GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
selection_chance)) ) )
{
2015-07-01 10:14:51 +02:00
struct PERF_TALER_MINTDB_Data *save_location;
struct PERF_TALER_MINTDB_Data *item_saved;
2015-07-01 18:14:28 +02:00
save_location = &cmd->details.save_array.data_saved[cmd->details.save_array.index];
item_saved = &save_ref->exposed;
2015-07-01 10:14:51 +02:00
data_copy (item_saved, save_location);
2015-07-01 18:14:28 +02:00
cmd->details.save_array.index++;
}
}
2015-06-11 15:55:46 +02:00
2015-06-19 10:55:13 +02:00
/**
2015-07-01 18:14:28 +02:00
* Part of the interpreter specific to
2015-07-28 14:07:12 +02:00
* #PERF_TALER_MINTDB_CMD_LOAD_ARRAY
2015-07-01 18:14:28 +02:00
* Gets data from a #PERF_TALER_MINTDB_CMD_SAVE_ARRAY and exposes a copy
*/
static void
interpret_load_array (struct PERF_TALER_MINTDB_interpreter_state *state)
{
2015-07-28 14:07:12 +02:00
struct PERF_TALER_MINTDB_Cmd *cmd = &state->cmd[state->i];
2015-06-30 09:23:04 +02:00
unsigned int loop_iter;
2015-07-01 14:31:48 +02:00
int loop_index;
int save_index;
2015-07-01 10:14:51 +02:00
struct PERF_TALER_MINTDB_Data *loaded_data;
2015-07-28 14:07:12 +02:00
loop_index = cmd->details.load_array.index_loop;
save_index = cmd->details.load_array.index_save;
loop_iter = state->cmd[loop_index].details.loop.curr_iteration;
2015-06-30 09:23:04 +02:00
{
int i, quotient;
2015-07-01 18:14:28 +02:00
/* In case the iteration number is higher than the amount saved,
* the number is run several times in the permutation array */
2015-06-30 09:23:04 +02:00
quotient = loop_iter / state->cmd[save_index].details.save_array.nb_saved;
loop_iter = loop_iter % state->cmd[save_index].details.save_array.nb_saved;
for (i=0; i<=quotient; i++)
2015-07-28 14:07:12 +02:00
loop_iter = cmd->details.load_array.permutation[loop_iter];
2015-06-30 09:23:04 +02:00
}
/* Extracting the data from the loop_indexth indice in save_index
* array.
*/
loaded_data = &state->cmd[save_index].details.save_array.data_saved[loop_iter];
data_copy (loaded_data,
&cmd->exposed);
}
2015-07-01 14:31:48 +02:00
2015-07-06 11:10:47 +02:00
/**
2015-07-28 14:07:12 +02:00
* Part of the interpreter specific to
2015-07-06 11:10:47 +02:00
* #PERF_TALER_MINTDB_CMD_LOAD_RANDOM
* Get a random element from a #PERF_TALER_MINTDB_CMD_SAVE_ARRAY and exposes it
*/
static void
2015-07-06 11:32:40 +02:00
interprete_load_random (struct PERF_TALER_MINTDB_interpreter_state *state)
2015-07-06 11:10:47 +02:00
{
2015-07-28 14:07:12 +02:00
struct PERF_TALER_MINTDB_Cmd *cmd = &state->cmd[state->i];
2015-07-06 11:10:47 +02:00
unsigned int index;
int save_index;
2015-07-28 14:07:12 +02:00
save_index = cmd->details.load_random.index_save;
index = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
state->cmd[save_index].details.save_array.nb_saved);
data_copy (&state->cmd[save_index].details.save_array.data_saved[index],
&cmd->exposed);
2015-07-06 11:10:47 +02:00
}
/**
2015-07-01 18:14:28 +02:00
* Iterate over the commands, acting accordingly at each step
2015-06-25 15:31:15 +02:00
*
2015-07-01 18:14:28 +02:00
* @param state the current state of the interpreter
*/
2015-06-09 17:35:33 +02:00
static int
2015-06-11 15:55:46 +02:00
interpret (struct PERF_TALER_MINTDB_interpreter_state *state)
{
2015-06-11 15:55:46 +02:00
for (state->i=0; PERF_TALER_MINTDB_CMD_END != state->cmd[state->i].command; state->i++)
2015-06-09 17:35:33 +02:00
{
2015-06-11 15:55:46 +02:00
switch (state->cmd[state->i].command)
{
2015-06-09 17:35:33 +02:00
case PERF_TALER_MINTDB_CMD_END:
return GNUNET_YES;
case PERF_TALER_MINTDB_CMD_DEBUG:
2015-07-01 14:31:48 +02:00
GNUNET_log (GNUNET_ERROR_TYPE_INFO,
"%s\n",
state->cmd[state->i].label);
break;
2015-06-09 17:35:33 +02:00
case PERF_TALER_MINTDB_CMD_LOOP:
break;
2015-06-09 17:35:33 +02:00
case PERF_TALER_MINTDB_CMD_END_LOOP:
2015-06-11 15:55:46 +02:00
interpret_end_loop (state);
break;
2015-06-09 17:35:33 +02:00
case PERF_TALER_MINTDB_CMD_GET_TIME:
2015-07-28 14:07:12 +02:00
state->cmd[state->i].exposed.data.time =
2015-07-17 16:23:12 +02:00
GNUNET_new (struct GNUNET_TIME_Absolute);
2015-07-28 14:07:12 +02:00
*state->cmd[state->i].exposed.data.time =
2015-07-17 16:23:12 +02:00
GNUNET_TIME_absolute_get ();
break;
2015-06-09 17:35:33 +02:00
case PERF_TALER_MINTDB_CMD_GAUGER:
{
2015-06-30 09:23:04 +02:00
int start_index, stop_index;
2015-07-17 16:23:12 +02:00
float ips;
struct GNUNET_TIME_Absolute start, stop;
struct GNUNET_TIME_Relative elapsed;
2015-07-28 14:07:12 +02:00
start_index = state->cmd[state->i].details.gauger.index_start;
stop_index = state->cmd[state->i].details.gauger.index_stop;
2015-07-17 16:23:12 +02:00
start = *state->cmd[start_index].exposed.data.time;
stop = *state->cmd[stop_index].exposed.data.time;
elapsed = GNUNET_TIME_absolute_get_difference (start,
2015-07-28 14:07:12 +02:00
stop);
2015-07-17 16:23:12 +02:00
ips = (1.0 * state->cmd[state->i].details.gauger.divide) / (elapsed.rel_value_us/1000000.0);
2015-07-27 15:56:01 +02:00
GAUGER (state->cmd[state->i].details.gauger.category,
2015-06-25 15:31:15 +02:00
state->cmd[state->i].details.gauger.description,
2015-07-28 14:07:12 +02:00
ips,
2015-07-07 12:57:14 +02:00
state->cmd[state->i].details.gauger.unit);
}
break;
2015-06-11 15:55:46 +02:00
case PERF_TALER_MINTDB_CMD_NEW_SESSION:
state->session = state->plugin->get_session (state->plugin->cls, GNUNET_YES);
break;
2015-06-11 15:55:46 +02:00
case PERF_TALER_MINTDB_CMD_START_TRANSACTION:
state->plugin->start (state->plugin->cls, state->session);
break;
2015-06-11 15:55:46 +02:00
case PERF_TALER_MINTDB_CMD_COMMIT_TRANSACTION:
state->plugin->commit (state->plugin->cls, state->session);
break;
2015-06-11 15:55:46 +02:00
case PERF_TALER_MINTDB_CMD_ABORT_TRANSACTION:
2015-07-01 14:31:48 +02:00
state->plugin->rollback (state->plugin->cls,
state->session);
2015-07-06 11:10:47 +02:00
break;
2015-06-09 17:35:33 +02:00
case PERF_TALER_MINTDB_CMD_SAVE_ARRAY:
interpret_save_array (state);
break;
2015-06-09 17:35:33 +02:00
case PERF_TALER_MINTDB_CMD_LOAD_ARRAY:
interpret_load_array (state);
2015-06-11 15:55:46 +02:00
break;
2015-07-06 11:10:47 +02:00
case PERF_TALER_MINTDB_CMD_LOAD_RANDOM:
2015-07-06 11:32:40 +02:00
interprete_load_random (state);
2015-07-06 11:10:47 +02:00
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_CREATE_DEPOSIT:
2015-06-11 15:55:46 +02:00
{
2015-07-15 18:06:50 +02:00
int coin_index;
struct TALER_MINTDB_Deposit *deposit;
2015-07-01 14:31:48 +02:00
2015-08-10 15:11:02 +02:00
coin_index = state->cmd[state->i].details.create_deposit.index_coin;
2015-07-28 14:07:12 +02:00
deposit = PERF_TALER_MINTDB_deposit_init (state->cmd[coin_index].exposed.data.coin);
GNUNET_assert (NULL != deposit);
2015-08-10 15:11:02 +02:00
state->cmd[state->i].exposed.data.deposit = deposit;
}
break;
case PERF_TALER_MINTDB_CMD_INSERT_DEPOSIT:
{
int deposit_index;
struct TALER_MINTDB_Deposit *deposit;
deposit_index = state->cmd[state->i].details.insert_deposit.index_deposit;
deposit = state->cmd[deposit_index].exposed.data.deposit;
2015-07-16 17:21:25 +02:00
GNUNET_assert (GNUNET_OK ==
2015-08-10 15:11:02 +02:00
state->plugin->insert_deposit (state->plugin->cls,
state->session,
deposit));
2015-07-01 10:14:51 +02:00
state->cmd[state->i].exposed.data.deposit = deposit;
2015-06-11 15:55:46 +02:00
}
break;
case PERF_TALER_MINTDB_CMD_GET_DEPOSIT:
{
2015-08-10 15:11:02 +02:00
unsigned int source_index;
2015-08-05 16:07:34 +02:00
struct PERF_TALER_MINTDB_Data *data;
2015-08-10 15:11:02 +02:00
source_index = state->cmd[state->i].details.get_deposit.index_deposit;
2015-08-05 16:07:34 +02:00
data = &state->cmd[source_index].exposed;
2015-06-25 15:31:15 +02:00
state->plugin->have_deposit (state->plugin->cls,
state->session,
2015-08-05 16:07:34 +02:00
data->data.deposit);
}
break;
2015-06-25 15:31:15 +02:00
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_CREATE_RESERVE:
{
struct PERF_TALER_MINTDB_Reserve *reserve;
reserve = PERF_TALER_MINTDB_reserve_init ();
state->cmd[state->i].exposed.data.reserve = reserve;
}
break;
case PERF_TALER_MINTDB_CMD_INSERT_RESERVE:
{
2015-08-10 15:11:02 +02:00
unsigned int reserve_index;
2015-07-15 16:28:12 +02:00
struct PERF_TALER_MINTDB_Reserve *reserve;
json_t *details = NULL;
2015-08-10 15:11:02 +02:00
reserve_index = state->cmd[state->i].details.insert_reserve.index_reserve;
reserve = state->cmd[reserve_index].exposed.data.reserve;
details = json_pack ("{s:i}","justification",
GNUNET_CRYPTO_random_u32 (
GNUNET_CRYPTO_QUALITY_WEAK,
UINT32_MAX));
GNUNET_assert (NULL != details);
state->plugin->reserves_in_insert (
state->plugin->cls,
state->session,
2015-07-15 16:28:12 +02:00
&reserve->reserve.pub,
&reserve->reserve.balance,
2015-07-06 11:10:47 +02:00
GNUNET_TIME_absolute_get (),
details
2015-06-25 15:31:15 +02:00
);
json_decref (details);
}
break;
case PERF_TALER_MINTDB_CMD_GET_RESERVE:
{
2015-07-07 11:59:55 +02:00
int reserve_index;
2015-08-10 15:11:02 +02:00
int ret;
2015-08-05 16:07:34 +02:00
struct PERF_TALER_MINTDB_Data *data;
2015-08-05 16:07:34 +02:00
2015-08-10 15:11:02 +02:00
reserve_index = state->cmd[state->i].details.get_reserve.index_reserve;
2015-08-05 16:07:34 +02:00
data = &state->cmd[reserve_index].exposed;
2015-08-10 15:11:02 +02:00
ret = state->plugin->reserve_get (state->plugin->cls,
state->session,
&data->data.reserve->reserve);
GNUNET_assert (GNUNET_OK == ret);
}
2015-06-25 15:31:15 +02:00
break;
2015-07-07 11:59:55 +02:00
case PERF_TALER_MINTDB_CMD_GET_RESERVE_HISTORY:
{
2015-08-10 15:11:02 +02:00
int reserve_index;
struct TALER_MINTDB_ReserveHistory *history;
struct PERF_TALER_MINTDB_Data *data;
reserve_index = state->cmd[state->i].details.get_reserve_history.index_reserve;
data = &state->cmd[reserve_index].exposed;
history = state->plugin->get_reserve_history (state->plugin->cls,
state->session,
&data->data.reserve->reserve.pub);
GNUNET_assert (NULL != history);
state->plugin->free_reserve_history (state->plugin->cls,
history);
2015-07-07 11:59:55 +02:00
}
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_CREATE_DENOMINATION:
{
struct TALER_MINTDB_DenominationKeyIssueInformation *dki =
PERF_TALER_MINTDB_denomination_init ();
2015-07-01 10:14:51 +02:00
state->cmd[state->i].exposed.data.dki = dki;
}
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_INSERT_DENOMINATION:
{
unsigned int denom_index;
int ret;
struct TALER_MINTDB_DenominationKeyIssueInformation *dki ;
denom_index = state->cmd[state->i].details.insert_denomination.index_denom;
dki = state->cmd[denom_index].exposed.data.dki;
ret = state->plugin->insert_denomination_info (state->plugin->cls,
state->session,
&dki->denom_pub,
&dki->issue);
GNUNET_assert (GNUNET_SYSERR != ret);
}
break;
case PERF_TALER_MINTDB_CMD_GET_DENOMINATION:
{
2015-08-10 15:11:02 +02:00
unsigned int denom_index;
int ret;
2015-08-05 16:07:34 +02:00
struct PERF_TALER_MINTDB_Data *data;
2015-08-10 15:11:02 +02:00
denom_index = state->cmd[state->i].details.get_denomination.index_denom;
data = &state->cmd[denom_index].exposed;
ret = state->plugin->get_denomination_info (state->plugin->cls,
state->session,
&data->data.dki->denom_pub,
&data->data.dki->issue);
GNUNET_assert (GNUNET_SYSERR != ret);
}
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_CREATE_WITHDRAW:
{
int dki_index, reserve_index;
2015-07-15 17:46:49 +02:00
struct PERF_TALER_MINTDB_Coin *coin ;
2015-08-10 15:11:02 +02:00
dki_index = state->cmd[state->i].details.create_withdraw.index_dki;
reserve_index = state->cmd[state->i].details.create_withdraw.index_reserve;
coin = PERF_TALER_MINTDB_coin_init (state->cmd[dki_index].exposed.data.dki,
state->cmd[reserve_index].exposed.data.reserve);
GNUNET_assert (NULL != coin);
2015-07-15 17:46:49 +02:00
state->cmd[state->i].exposed.data.coin = coin;
}
break;
2015-08-10 15:11:02 +02:00
case PERF_TALER_MINTDB_CMD_INSERT_WITHDRAW:
{
unsigned int coin_index;
int ret;
struct PERF_TALER_MINTDB_Coin *coin ;
coin_index = state->cmd[state->i].details.insert_withdraw.index_coin;
coin = state->cmd[coin_index].exposed.data.coin;
ret = state->plugin->insert_withdraw_info (state->plugin->cls,
state->session,
&coin->blind);
GNUNET_assert (GNUNET_SYSERR != ret);
}
break;
case PERF_TALER_MINTDB_CMD_GET_WITHDRAW:
{
2015-08-10 15:11:02 +02:00
unsigned int source_index;
int ret;
2015-08-05 16:07:34 +02:00
struct PERF_TALER_MINTDB_Data *data;
2015-08-10 15:11:02 +02:00
source_index = state->cmd[state->i].details.get_denomination.index_denom;
2015-08-05 16:07:34 +02:00
data = &state->cmd[source_index].exposed;
2015-08-10 15:11:02 +02:00
ret = state->plugin->get_withdraw_info (state->plugin->cls,
state->session,
&data->data.coin->blind.h_coin_envelope,
&data->data.coin->blind);
GNUNET_assert (GNUNET_SYSERR != ret);
2015-06-11 15:55:46 +02:00
}
break;
2015-07-20 10:24:09 +02:00
case PERF_TALER_MINTDB_CMD_GET_COIN_TRANSACTION:
{
2015-08-10 15:11:02 +02:00
unsigned int coin_index;
2015-07-20 10:24:09 +02:00
struct PERF_TALER_MINTDB_Coin *coin;
struct TALER_MINTDB_TransactionList *transactions;
2015-07-28 14:07:12 +02:00
2015-08-10 15:11:02 +02:00
coin_index = state->cmd[state->i].details.get_coin_transaction.index_coin;
2015-07-20 10:24:09 +02:00
coin = state->cmd[coin_index].exposed.data.coin;
transactions = state->plugin->get_coin_transactions (state->plugin->cls,
state->session,
&coin->public_info.coin_pub);
2015-08-10 15:11:02 +02:00
GNUNET_assert (transactions != NULL);
2015-07-20 10:24:09 +02:00
state->plugin->free_coin_transaction_list (state->plugin->cls,
transactions);
}
break;
case PERF_TALER_MINTDB_CMD_CREATE_REFRESH_SESSION:
{
2015-08-10 18:12:27 +02:00
struct GNUNET_HashCode *hash;
2015-07-20 10:24:09 +02:00
struct TALER_MINTDB_RefreshSession *refresh_session;
2015-08-10 18:12:27 +02:00
hash = GNUNET_new (struct GNUNET_HashCode);
2015-07-20 10:24:09 +02:00
refresh_session = PERF_TALER_MINTDB_refresh_session_init ();
GNUNET_CRYPTO_hash_create_random (GNUNET_CRYPTO_QUALITY_WEAK,
2015-08-10 18:12:27 +02:00
hash);
2015-07-20 10:24:09 +02:00
state->plugin->create_refresh_session (state->session,
state->session,
2015-08-10 18:12:27 +02:00
hash,
2015-07-20 10:24:09 +02:00
refresh_session);
state->cmd[state->i].exposed.data.session_hash = hash;
PERF_TALER_MINTDB_refresh_session_free (refresh_session);
GNUNET_free (refresh_session);
}
break;
case PERF_TALER_MINTDB_CMD_GET_REFRESH_SESSION:
{
2015-08-10 18:12:27 +02:00
unsigned int hash_index;
struct GNUNET_HashCode *hash;
2015-07-20 10:24:09 +02:00
struct TALER_MINTDB_RefreshSession refresh;
2015-08-10 18:12:27 +02:00
hash_index = state->cmd[state->i].details.get_refresh_session.index_hash;
2015-07-20 10:24:09 +02:00
hash = state->cmd[hash_index].exposed.data.session_hash;
state->plugin->get_refresh_session (state->session,
state->session,
2015-08-10 18:12:27 +02:00
hash,
2015-07-20 10:24:09 +02:00
&refresh);
}
break;
case PERF_TALER_MINTDB_CMD_INSERT_REFRESH_MELT:
{
int hash_index;
int coin_index;
2015-08-11 15:52:40 +02:00
int ret;
2015-08-10 18:12:27 +02:00
struct GNUNET_HashCode *hash;
2015-07-20 10:24:09 +02:00
struct TALER_MINTDB_RefreshMelt *melt;
struct PERF_TALER_MINTDB_Coin *coin;
2015-08-10 18:12:27 +02:00
hash_index = state->cmd[state->i].details.insert_refresh_melt.index_hash;
coin_index = state->cmd[state->i].details.insert_refresh_melt.index_coin;
2015-07-20 10:24:09 +02:00
hash = state->cmd[hash_index].exposed.data.session_hash;
coin = state->cmd[coin_index].exposed.data.coin;
2015-08-10 18:12:27 +02:00
melt = PERF_TALER_MINTDB_refresh_melt_init (hash,
2015-07-20 10:24:09 +02:00
coin);
2015-08-11 15:52:40 +02:00
ret = state->plugin->insert_refresh_melt (state->plugin->cls,
2015-07-20 10:24:09 +02:00
state->session,
1,
melt);
2015-08-11 15:52:40 +02:00
GNUNET_assert (GNUNET_SYSERR != ret);
2015-07-20 10:24:09 +02:00
}
break;
case PERF_TALER_MINTDB_CMD_GET_REFRESH_MELT:
{
int hash_index;
2015-08-10 18:12:27 +02:00
struct GNUNET_HashCode *hash;
2015-07-20 10:24:09 +02:00
struct TALER_MINTDB_RefreshMelt melt;
2015-07-28 14:07:12 +02:00
2015-07-20 10:24:09 +02:00
hash_index = cmd_find (state->cmd,
state->cmd[state->i].details.get_refresh_melt.label_hash);
hash = state->cmd[hash_index].exposed.data.session_hash;
state->plugin->get_refresh_melt (state->plugin->cls,
state->session,
2015-08-10 18:12:27 +02:00
hash,
2015-07-20 10:24:09 +02:00
1,
&melt);
}
break;
2015-07-23 16:10:49 +02:00
case PERF_TALER_MINTDB_CMD_INSERT_REFRESH_ORDER:
{
int hash_index;
int denom_index;
2015-08-10 18:12:27 +02:00
struct GNUNET_HashCode *session_hash;
2015-07-23 16:10:49 +02:00
struct TALER_MINTDB_DenominationKeyIssueInformation *denom;
2015-08-10 18:12:27 +02:00
hash_index = state->cmd[state->i].details.insert_refresh_order.index_hash;
denom_index = state->cmd[state->i].details.insert_refresh_order.index_denom;
2015-07-23 16:10:49 +02:00
GNUNET_assert (GNUNET_SYSERR != denom_index);
session_hash = state->cmd[hash_index].exposed.data.session_hash;
denom = state->cmd[denom_index].exposed.data.dki;
state->plugin->insert_refresh_order (state->plugin->cls,
state->session,
2015-08-10 18:12:27 +02:00
session_hash,
2015-07-23 16:10:49 +02:00
1,
&denom->denom_pub);
}
break;
case PERF_TALER_MINTDB_CMD_GET_REFRESH_ORDER:
{
int hash_index;
2015-08-10 18:12:27 +02:00
struct GNUNET_HashCode *hash;
2015-07-23 16:10:49 +02:00
struct TALER_DenominationPublicKey denom_pub;
2015-08-10 18:12:27 +02:00
hash_index = state->cmd[state->i].details.get_refresh_order.index_hash;
2015-07-23 16:10:49 +02:00
hash = state->cmd[hash_index].exposed.data.session_hash;
state->plugin->get_refresh_order (state->plugin->cls,
state->session,
2015-08-10 18:12:27 +02:00
hash,
2015-07-23 16:10:49 +02:00
1,
&denom_pub);
}
break;
case PERF_TALER_MINTDB_CMD_INSERT_REFRESH_COMMIT_COIN:
{
int hash_index;
hash_index = cmd_find (state->cmd,
state->cmd[state->i].details.insert_refresh_commit_coin.label_hash);
GNUNET_assert (GNUNET_SYSERR != hash_index);
}
break;
2015-07-28 14:07:12 +02:00
2015-07-23 16:10:49 +02:00
case PERF_TALER_MINTDB_CMD_GET_REFRESH_COMMIT_COIN:
{
int hash_index;
hash_index = cmd_find (state->cmd,
state->cmd[state->i].details.insert_refresh_commit_coin.label_hash);
GNUNET_assert (GNUNET_SYSERR != hash_index);
}
break;
2015-07-28 14:07:12 +02:00
2015-07-23 16:10:49 +02:00
case PERF_TALER_MINTDB_CMD_INSERT_REFRESH_COMMIT_LINK:
{
int hash_index;
hash_index = cmd_find (state->cmd,
state->cmd[state->i].details.insert_refresh_commit_link.label_hash);
GNUNET_assert (GNUNET_SYSERR != hash_index);
}
break;
case PERF_TALER_MINTDB_CMD_GET_REFRESH_COMMIT_LINK:
break;
case PERF_TALER_MINTDB_CMD_GET_MELT_COMMITMENT:
break;
case PERF_TALER_MINTDB_CMD_INSERT_REFRESH_OUT:
break;
case PERF_TALER_MINTDB_CMD_GET_LINK_DATA_LIST:
break;
case PERF_TALER_MINTDB_CMD_GET_TRANSFER:
break;
2015-07-20 10:24:09 +02:00
default:
2015-06-09 17:35:33 +02:00
break;
}
}
return GNUNET_OK;
}
2015-06-11 15:55:46 +02:00
/**
2015-06-09 13:55:05 +02:00
* Runs the commands given in @a cmd, working with
* the database referenced by @a db_plugin
2015-07-28 14:07:12 +02:00
*
2015-07-01 18:14:28 +02:00
* @param db_plugin the connection to the database
* @param cmd the commands to run
*/
int
2015-06-11 15:55:46 +02:00
PERF_TALER_MINTDB_interpret (struct TALER_MINTDB_Plugin *db_plugin,
2015-06-12 11:14:32 +02:00
struct PERF_TALER_MINTDB_Cmd cmd[])
{
2015-08-03 10:26:52 +02:00
int ret;
2015-06-25 15:31:15 +02:00
struct PERF_TALER_MINTDB_interpreter_state state =
{.i = 0, .cmd = cmd, .plugin = db_plugin};
ret = cmd_init (cmd);
2015-08-03 10:26:52 +02:00
if (GNUNET_SYSERR == ret)
return ret;
state.session = db_plugin->get_session (db_plugin->cls,
GNUNET_YES);
GNUNET_assert (NULL != state.session);
ret = interpret (&state);
2015-06-11 15:55:46 +02:00
cmd_clean (cmd);
return ret;
2015-07-01 18:14:28 +02:00
}
/**
2015-07-06 11:10:47 +02:00
* Initialize the database and run the benchmark
2015-07-01 18:14:28 +02:00
*
* @param benchmark_name the name of the benchmark, displayed in the logs
* @param configuration_file path to the taler configuration file to use
2015-07-28 14:07:12 +02:00
* @param init the commands to use for the database initialisation,
2015-07-01 18:14:28 +02:00
* if #NULL the standard initialization is used
* @param benchmark the commands for the benchmark
* @return #GNUNET_OK upon success; #GNUNET_SYSERR upon failure
2015-07-01 18:14:28 +02:00
*/
int
PERF_TALER_MINTDB_run_benchmark (const char *benchmark_name,
const char *configuration_file,
struct PERF_TALER_MINTDB_Cmd *init,
struct PERF_TALER_MINTDB_Cmd *benchmark)
{
struct TALER_MINTDB_Plugin *plugin;
struct GNUNET_CONFIGURATION_Handle *config;
int ret = 0;
2015-07-28 14:07:12 +02:00
struct PERF_TALER_MINTDB_Cmd init_def[] =
2015-07-01 18:14:28 +02:00
{
// Denomination used to create coins
PERF_TALER_MINTDB_INIT_CMD_DEBUG ("00 - Start of interpreter"),
PERF_TALER_MINTDB_INIT_CMD_LOOP ("01 - denomination loop",
PERF_TALER_MINTDB_NB_DENOMINATION_INIT),
2015-07-16 17:21:25 +02:00
PERF_TALER_MINTDB_INIT_CMD_START_TRANSACTION (""),
2015-08-10 15:11:02 +02:00
PERF_TALER_MINTDB_INIT_CMD_CREATE_DENOMINATION ("01 - denomination"),
PERF_TALER_MINTDB_INIT_CMD_INSERT_DENOMINATION ("01 - insert",
"01 - denomination"),
2015-07-16 17:21:25 +02:00
PERF_TALER_MINTDB_INIT_CMD_COMMIT_TRANSACTION (""),
2015-07-01 18:14:28 +02:00
PERF_TALER_MINTDB_INIT_CMD_SAVE_ARRAY ("01 - save denomination",
"01 - denomination loop",
"01 - denomination",
PERF_TALER_MINTDB_NB_DENOMINATION_SAVE),
2015-07-16 17:21:25 +02:00
PERF_TALER_MINTDB_INIT_CMD_END_LOOP ("",
2015-07-01 18:14:28 +02:00
"01 - denomination loop"),
PERF_TALER_MINTDB_INIT_CMD_DEBUG ("01 - init denomination complete"),
// End of initialization
// Reserve initialization
PERF_TALER_MINTDB_INIT_CMD_LOOP ("02 - init reserve loop",
PERF_TALER_MINTDB_NB_RESERVE_INIT),
2015-08-10 15:11:02 +02:00
PERF_TALER_MINTDB_INIT_CMD_CREATE_RESERVE ("02 - reserve"),
PERF_TALER_MINTDB_INIT_CMD_INSERT_RESERVE ("02 - insert",
"02 - reserve"),
2015-07-01 18:14:28 +02:00
PERF_TALER_MINTDB_INIT_CMD_SAVE_ARRAY ("02 - save reserve",
"02 - init reserve loop",
"02 - reserve",
PERF_TALER_MINTDB_NB_RESERVE_SAVE),
2015-07-16 17:21:25 +02:00
PERF_TALER_MINTDB_INIT_CMD_END_LOOP ("",
2015-07-01 18:14:28 +02:00
"02 - init reserve loop"),
PERF_TALER_MINTDB_INIT_CMD_DEBUG ("02 - reserve init complete"),
// End reserve init
// Withdrawal initialization
PERF_TALER_MINTDB_INIT_CMD_LOOP ("03 - init withdraw loop",
PERF_TALER_MINTDB_NB_WITHDRAW_INIT),
2015-07-16 17:21:25 +02:00
PERF_TALER_MINTDB_INIT_CMD_START_TRANSACTION (""),
2015-07-01 18:14:28 +02:00
PERF_TALER_MINTDB_INIT_CMD_LOAD_ARRAY ("03 - denomination load",
"03 - init withdraw loop",
"01 - save denomination"),
PERF_TALER_MINTDB_INIT_CMD_LOAD_ARRAY ("03 - reserve load",
"03 - init withdraw loop",
"02 - save reserve"),
2015-08-10 15:11:02 +02:00
PERF_TALER_MINTDB_INIT_CMD_CREATE_WITHDRAW ("03 - withdraw",
2015-07-01 18:14:28 +02:00
"03 - denomination load",
"03 - reserve load"),
2015-08-10 15:11:02 +02:00
PERF_TALER_MINTDB_INIT_CMD_INSERT_WITHDRAW ("03 - insert",
"03 - withdraw"),
2015-07-16 17:21:25 +02:00
PERF_TALER_MINTDB_INIT_CMD_COMMIT_TRANSACTION (""),
PERF_TALER_MINTDB_INIT_CMD_SAVE_ARRAY ("03 - save coin",
2015-07-01 18:14:28 +02:00
"03 - init withdraw loop",
"03 - withdraw",
PERF_TALER_MINTDB_NB_WITHDRAW_SAVE),
2015-07-16 17:21:25 +02:00
PERF_TALER_MINTDB_INIT_CMD_END_LOOP ("",
2015-07-01 18:14:28 +02:00
"03 - init withdraw loop"),
PERF_TALER_MINTDB_INIT_CMD_DEBUG ("03 - withdraw init complete"),
//End of withdrawal initialization
//Deposit initialization
PERF_TALER_MINTDB_INIT_CMD_LOOP ("04 - deposit init loop",
PERF_TALER_MINTDB_NB_DEPOSIT_INIT),
PERF_TALER_MINTDB_INIT_CMD_START_TRANSACTION ("04 - start transaction"),
PERF_TALER_MINTDB_INIT_CMD_LOAD_ARRAY ("04 - denomination load",
"04 - deposit init loop",
2015-07-16 17:21:25 +02:00
"03 - save coin"),
2015-07-01 18:14:28 +02:00
PERF_TALER_MINTDB_INIT_CMD_INSERT_DEPOSIT ("04 - deposit",
"04 - denomination load"),
PERF_TALER_MINTDB_INIT_CMD_COMMIT_TRANSACTION ("04 - commit transaction"),
PERF_TALER_MINTDB_INIT_CMD_SAVE_ARRAY ("04 - deposit array",
"04 - deposit init loop",
"04 - deposit",
PERF_TALER_MINTDB_NB_DEPOSIT_SAVE),
PERF_TALER_MINTDB_INIT_CMD_END_LOOP ("04 - deposit init loop end",
"04 - deposit init loop"),
PERF_TALER_MINTDB_INIT_CMD_DEBUG ("04 - deposit init complete"),
// End of deposit initialization
PERF_TALER_MINTDB_INIT_CMD_END ("end")
};
GNUNET_log_setup (benchmark_name,
"INFO",
NULL);
config = GNUNET_CONFIGURATION_create ();
2015-07-28 14:07:12 +02:00
ret = GNUNET_CONFIGURATION_load (config,
2015-07-01 18:14:28 +02:00
configuration_file);
if (GNUNET_OK != ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-11 15:52:40 +02:00
"Error parsing configuration file\n");
2015-07-01 18:14:28 +02:00
return GNUNET_SYSERR;
}
plugin = TALER_MINTDB_plugin_load (config);
if (NULL == plugin)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-11 15:52:40 +02:00
"Error connectiong to the database\n");
2015-07-01 18:14:28 +02:00
return ret;
}
2015-07-28 14:07:12 +02:00
ret = plugin->create_tables (plugin->cls,
2015-07-01 18:14:28 +02:00
GNUNET_YES);
if (GNUNET_OK != ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-11 15:52:40 +02:00
"Error while creating the database architecture\n");
2015-07-01 18:14:28 +02:00
return ret;
}
2015-07-28 14:07:12 +02:00
/*
2015-07-01 18:14:28 +02:00
* Running the initialization
*/
if (NULL == init)
{
2015-07-28 14:07:12 +02:00
init = init_def;
2015-07-01 18:14:28 +02:00
}
2015-07-28 14:07:12 +02:00
ret = PERF_TALER_MINTDB_interpret (plugin,
2015-07-01 18:14:28 +02:00
init);
if (GNUNET_OK != ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-11 15:52:40 +02:00
"Error during database initialization\n");
2015-07-01 18:14:28 +02:00
return ret;
}
/*
* Running the benchmark
*/
2015-07-28 14:07:12 +02:00
ret = PERF_TALER_MINTDB_interpret (plugin,
2015-07-01 18:14:28 +02:00
benchmark);
if (GNUNET_OK != ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-11 15:52:40 +02:00
"Error while runing the benchmark\n");
2015-07-01 18:14:28 +02:00
return ret;
}
/* Drop tables */
{
struct TALER_MINTDB_Session *session;
2015-07-28 14:07:12 +02:00
session = plugin->get_session (plugin->cls,
2015-07-01 18:14:28 +02:00
GNUNET_YES);
2015-07-28 14:07:12 +02:00
ret = plugin->drop_temporary (plugin->cls,
2015-07-01 18:14:28 +02:00
session);
if (GNUNET_OK != ret)
{
GNUNET_log (GNUNET_ERROR_TYPE_ERROR,
2015-08-11 15:52:40 +02:00
"Error cleaning the database\n");
2015-07-01 18:14:28 +02:00
return ret;
}
}
TALER_MINTDB_plugin_unload (plugin);
GNUNET_CONFIGURATION_destroy (config);
return ret;
}