summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat
-rw-r--r--src/mintdb/perf_taler_mintdb.c24
-rw-r--r--src/mintdb/perf_taler_mintdb_interpreter.c64
-rw-r--r--src/mintdb/perf_taler_mintdb_interpreter.h2
3 files changed, 58 insertions, 32 deletions
diff --git a/src/mintdb/perf_taler_mintdb.c b/src/mintdb/perf_taler_mintdb.c
index 040a473f5..0b1e48075 100644
--- a/src/mintdb/perf_taler_mintdb.c
+++ b/src/mintdb/perf_taler_mintdb.c
@@ -33,13 +33,27 @@ main (int argc, char ** argv)
struct GNUNET_CONFIGURATION_Handle *config;
struct PERF_TALER_MINTDB_Cmd test[] =
{
- PERF_TALER_MINTDB_INIT_CMD_LOOP ("loop_db_init_deposit",10),
- PERF_TALER_MINTDB_INIT_CMD_START_TRANSACTION ("start_transaction_init"),
- PERF_TALER_MINTDB_INIT_CMD_INSERT_DEPOSIT ("init_deposit_insert"),
- PERF_TALER_MINTDB_INIT_CMD_COMMIT_TRANSACTION ("commit_transaction_init"),
- PERF_TALER_MINTDB_INIT_CMD_SAVE_ARRAY ("array_depo", "loop_db_init_deposit", "init_deposit_insert", 10, PERF_TALER_MINTDB_DEPOSIT),
+ PERF_TALER_MINTDB_INIT_CMD_LOOP ("loop_db_init_deposit",10000),
+ PERF_TALER_MINTDB_INIT_CMD_START_TRANSACTION ("start_transaction_init"),
+ PERF_TALER_MINTDB_INIT_CMD_INSERT_DEPOSIT ("init_deposit_insert"),
+ PERF_TALER_MINTDB_INIT_CMD_COMMIT_TRANSACTION ("commit_transaction_init"),
+ PERF_TALER_MINTDB_INIT_CMD_SAVE_ARRAY ("array_depo",
+ "loop_db_init_deposit",
+ "init_deposit_insert",
+ 100,
+ PERF_TALER_MINTDB_DEPOSIT),
PERF_TALER_MINTDB_INIT_CMD_END_LOOP ("endloop_init_deposit",
"loop_db_init_deposit"),
+ PERF_TALER_MINTDB_INIT_CMD_DEBUG("Fin loop 1"),
+ PERF_TALER_MINTDB_INIT_CMD_LOOP ("loop_deposit_get",100),
+ PERF_TALER_MINTDB_INIT_CMD_START_TRANSACTION ("start_transaction_get"),
+ PERF_TALER_MINTDB_INIT_CMD_LOAD_ARRAY("load deposit",
+ "loop_deposit_get",
+ "array_depo"),
+ PERF_TALER_MINTDB_INIT_CMD_GET_DEPOSIT("get_deposit",
+ "load_deposit"),
+ PERF_TALER_MINTDB_INIT_CMD_COMMIT_TRANSACTION ("commit_transaction_init"),
+ PERF_TALER_MINTDB_INIT_CMD_END_LOOP("stop2", "loop_deposit_get"),
PERF_TALER_MINTDB_INIT_CMD_END("end")
};
// Plugin init
diff --git a/src/mintdb/perf_taler_mintdb_interpreter.c b/src/mintdb/perf_taler_mintdb_interpreter.c
index 71972de2a..73c0669ea 100644
--- a/src/mintdb/perf_taler_mintdb_interpreter.c
+++ b/src/mintdb/perf_taler_mintdb_interpreter.c
@@ -115,6 +115,7 @@ static int
cmd_init (struct PERF_TALER_MINTDB_Cmd cmd[])
{
int i = 0;
+
for (i=0; PERF_TALER_MINTDB_CMD_END != cmd[i].command; i++)
{
switch (cmd[i].command)
@@ -128,13 +129,14 @@ cmd_init (struct PERF_TALER_MINTDB_Cmd cmd[])
case PERF_TALER_MINTDB_CMD_LOAD_ARRAY:
// Creating the permutation array to randomize the data order
- cmd[i].details.load_array.permutation =
- GNUNET_CRYPTO_random_permute (
- GNUNET_CRYPTO_QUALITY_WEAK,
- cmd[cmd_find (cmd,
- cmd[i].details
- .load_array.label_save)]
- .details.save_array.nb_saved);
+ GNUNET_assert (NULL !=
+ (cmd[i].details.load_array.permutation =
+ GNUNET_CRYPTO_random_permute (
+ GNUNET_CRYPTO_QUALITY_WEAK,
+ cmd[cmd_find (cmd,
+ cmd[i].details
+ .load_array.label_save)]
+ .details.save_array.nb_saved)));
// Initializing the type based on the type of the saved array
cmd[i].exposed_type = cmd[cmd_find (cmd,
@@ -157,6 +159,7 @@ static int
cmd_clean (struct PERF_TALER_MINTDB_Cmd cmd[])
{
int i = 0;
+
for (i = 0; PERF_TALER_MINTDB_CMD_END != cmd[i].command; i++)
{
switch (cmd[i].command)
@@ -169,13 +172,14 @@ cmd_clean (struct PERF_TALER_MINTDB_Cmd cmd[])
data_free (&cmd[i].details.save_array.data_saved[j],
cmd[i].details.save_array.type_saved);
}
-
GNUNET_free (cmd[i].details.save_array.data_saved);
cmd[i].details.save_array.data_saved = NULL;
}
+ break;
case PERF_TALER_MINTDB_CMD_LOAD_ARRAY:
GNUNET_free (cmd[i].details.load_array.permutation);
+ cmd[i].details.load_array.permutation = NULL;
break;
default:
@@ -183,7 +187,6 @@ cmd_clean (struct PERF_TALER_MINTDB_Cmd cmd[])
break;
}
- i++;
}
return GNUNET_OK;
};
@@ -196,6 +199,7 @@ static void
interpret_end_loop (struct PERF_TALER_MINTDB_interpreter_state *state)
{
int i;
+ union PERF_TALER_MINTDB_Data zero = {0};
int jump = cmd_find (state->cmd,
state->cmd[state->i].details.end_loop.label_loop);
// Cleaning up the memory in the loop
@@ -205,6 +209,8 @@ interpret_end_loop (struct PERF_TALER_MINTDB_interpreter_state *state)
if ( GNUNET_NO == state->cmd[i].exposed_saved)
data_free (&state->cmd[i].exposed, state->cmd[i].exposed_type);
state->cmd[i].exposed_saved = GNUNET_NO;
+ // Anyway we need to make the data zero.
+ state->cmd[i].exposed = zero;
}
state->cmd[jump].details.loop.curr_iteration++;
@@ -220,11 +226,13 @@ interpret_end_loop (struct PERF_TALER_MINTDB_interpreter_state *state)
}
}
+
static void
interpret_save_array (struct PERF_TALER_MINTDB_interpreter_state *state)
{
int loop_index;
int selection_chance;
+
// Array initialization on first loop iteration
// Alows for nested loops
if (0 == state->cmd[cmd_find (state->cmd,
@@ -246,12 +254,14 @@ interpret_save_array (struct PERF_TALER_MINTDB_interpreter_state *state)
*
* Else it is saved only if rdn is 0
*/
- if (((state->cmd[loop_index].details.loop.max_iterations -
- state->cmd[loop_index].details.loop.curr_iteration) ==
- (state->cmd[state->i].details.save_array.nb_saved -
- state->cmd[state->i].details.save_array.index))
- || (0 == GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
- selection_chance)))
+ if ((0 < (state->cmd[state->i].details.save_array.nb_saved -
+ state->cmd[state->i].details.save_array.index)) &&
+ (((state->cmd[loop_index].details.loop.max_iterations -
+ state->cmd[loop_index].details.loop.curr_iteration) ==
+ (state->cmd[state->i].details.save_array.nb_saved -
+ state->cmd[state->i].details.save_array.index))
+ || (0 == GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK,
+ selection_chance))))
{
union PERF_TALER_MINTDB_Data *save_location;
union PERF_TALER_MINTDB_Data *item_saved;
@@ -298,6 +308,7 @@ interpret_save_array (struct PERF_TALER_MINTDB_interpreter_state *state)
}
}
+
/**
* Main interpreter loop.
*
@@ -371,7 +382,7 @@ interpret (struct PERF_TALER_MINTDB_interpreter_state *state)
case PERF_TALER_MINTDB_CMD_LOAD_ARRAY:
{
int loop_index, save_index;
- union PERF_TALER_MINTDB_Data loaded_data;
+ union PERF_TALER_MINTDB_Data *loaded_data;
loop_index = cmd_find (state->cmd,
state->cmd[state->i].details.load_array.label_loop);
save_index = cmd_find (state->cmd,
@@ -379,18 +390,19 @@ interpret (struct PERF_TALER_MINTDB_interpreter_state *state)
/* Extracting the data from the loop_indexth indice in save_index
* array.
*/
- loaded_data = state->cmd[save_index].details.save_array.data_saved[
+ loaded_data = &state->cmd[save_index].details.save_array.data_saved[
state->cmd[state->i].details.load_array.permutation[
state->cmd[loop_index].details.loop.curr_iteration]];
switch (state->cmd[state->i].exposed_type)
{
- case PERF_TALER_MINTDB_DEPOSIT:
- state->cmd[state->i].exposed.deposit = loaded_data.deposit;
+ case PERF_TALER_MINTDB_TIME:
+ state->cmd[state->i].exposed.time = loaded_data->time;
break;
- case PERF_TALER_MINTDB_TIME:
- state->cmd[state->i].exposed.time = loaded_data.time;
+ case PERF_TALER_MINTDB_DEPOSIT:
+ state->cmd[state->i].exposed.deposit = loaded_data->deposit;
+ loaded_data->deposit = NULL;
break;
default:
@@ -405,9 +417,9 @@ interpret (struct PERF_TALER_MINTDB_interpreter_state *state)
PERF_TALER_MINTDB_deposit_init ();
GNUNET_assert (
- state->plugin->insert_deposit (state->plugin->cls,
- state->session,
- deposit));
+ state->plugin->insert_deposit (state->plugin->cls,
+ state->session,
+ deposit));
state->cmd[state->i].exposed.deposit = deposit;
}
break;
@@ -446,8 +458,8 @@ PERF_TALER_MINTDB_interpret (struct TALER_MINTDB_Plugin *db_plugin,
// Initializing commands
cmd_init (state.cmd);
// Running the interpreter
- GNUNET_assert(NULL !=
- (state.session = db_plugin->get_session (db_plugin->cls, GNUNET_YES)));
+ GNUNET_assert (NULL !=
+ (state.session = db_plugin->get_session (db_plugin->cls, GNUNET_YES)));
interpret (&state);
// Cleaning the memory
cmd_clean (cmd);
diff --git a/src/mintdb/perf_taler_mintdb_interpreter.h b/src/mintdb/perf_taler_mintdb_interpreter.h
index c56414730..367aaf295 100644
--- a/src/mintdb/perf_taler_mintdb_interpreter.h
+++ b/src/mintdb/perf_taler_mintdb_interpreter.h
@@ -137,7 +137,7 @@
.command = PERF_TALER_MINTDB_CMD_GET_DEPOSIT, \
.label = _label, \
.exposed_type = PERF_TALER_MINTDB_NONE, \
- .details.label_deposit.saved = _label_deposit \
+ .details.get_deposit.label_source = _label_deposit \
}
/**
generated by cgit v1.2.3 (git 2.39.1) at 2024-04-19 15:59:16 +0000