summaryrefslogtreecommitdiff
path: root/src/mintdb/perf/perf_taler_mintdb_interpreter.c
diff options
context:
space:
mode:
authorFournier Nicolas <nicolas.fournier@ensta-paristech.fr>2015-06-09 17:34:41 +0200
committerFournier Nicolas <nicolas.fournier@ensta-paristech.fr>2015-06-09 17:34:41 +0200
commit3390717e33ea4fd44f5b100f34a06789bb0180ab (patch)
tree0e8bb4798fc9070be180600e3d26a650319f0409 /src/mintdb/perf/perf_taler_mintdb_interpreter.c
parent4544a21cfbc4a6cb13f5535accd50da17f3b5741 (diff)
downloadexchange-3390717e33ea4fd44f5b100f34a06789bb0180ab.tar.gz
exchange-3390717e33ea4fd44f5b100f34a06789bb0180ab.tar.bz2
exchange-3390717e33ea4fd44f5b100f34a06789bb0180ab.zip
moved mintdb perf filed to mintdb directory
Diffstat (limited to 'src/mintdb/perf/perf_taler_mintdb_interpreter.c')
-rw-r--r--src/mintdb/perf/perf_taler_mintdb_interpreter.c307
1 files changed, 0 insertions, 307 deletions
diff --git a/src/mintdb/perf/perf_taler_mintdb_interpreter.c b/src/mintdb/perf/perf_taler_mintdb_interpreter.c
deleted file mode 100644
index 93c49b9c0..000000000
--- a/src/mintdb/perf/perf_taler_mintdb_interpreter.c
+++ /dev/null
@@ -1,307 +0,0 @@
-#include "perf_taler_mintdb_interpreter.h"
-
-#include "perf_taler_mintdb_init.h"
-
-#include <gauger.h>
-
-
-/**
- * Finds the first command in cmd with the name search
- *
- * \return the index of the first command with name search
- * GNUNET_SYSERR if none found
- */
- static int
-cmd_find(const struct PERF_TALER_MINTDB_CMD *cmd, const char *search)
-{
- int i;
-
- for (i=0; CMD_END != cmd[i].command; i++)
- if (0 == strcmp (cmd[i].name, search))
- return i;
- return GNUNET_SYSERR;
-}
-
-
-// Initialization of a command array
- static int
-cmd_init(struct PERF_TALER_MINTDB_CMD cmd[])
-{
- int i = 0;
- while (CMD_END != cmd[i].command)
- {
- switch (cmd[i].command)
- {
- case CMD_SAVE_ARRAY:
- // Initialization is done differently depending of the type saved
- switch (cmd[i].details.save_array.saved_type)
- {
- case DEPOSIT:
- cmd[i].details.save_array.saved_data.deposit =
- GNUNET_malloc(cmd[i].details.save_array.nb*
- sizeof(*cmd[i].details.save_array.saved_data.deposit));
- break;
- case TIME:
- cmd[i].details.save_array.saved_data.time =
- GNUNET_malloc(cmd[i].details.save_array.nb*
- sizeof(*cmd[i].details.save_array.saved_data.time));
-
- default:
- break;
- }
- break;
-
- case CMD_LOAD_ARRAY:
- cmd[i].details.load_array.permutation =
- GNUNET_CRYPTO_random_permute(
- GNUNET_CRYPTO_QUALITY_WEAK,
- cmd[i].details.load_array.nb);
- break;
- default:
- break;
- }
-
- i++;
- }
-
- return GNUNET_OK;
-}
-
-
-/**
- * Free the memory of the command chain
- */
- static int
-cmd_clean(struct PERF_TALER_MINTDB_CMD cmd[])
-{
- int i = 0;
- while (cmd[i].command != CMD_END)
- {
- switch (cmd[i].command)
- {
- case CMD_SAVE_ARRAY:
- {
- int j;
- switch (cmd[i].details.save_array.saved_type)
- {
- case DEPOSIT:
- for (j = 0; j < cmd[i].details.save_array.nb; j++)
- {
- free_deposit(cmd[i].details.save_array.saved_data.deposit[j]);
- cmd[i].details.save_array.saved_data.deposit[j] = NULL;
- }
- GNUNET_free(cmd[i].details.save_array.saved_data.deposit);
- cmd[i].details.save_array.saved_data.deposit = NULL;
- break;
- case TIME:
- GNUNET_free(cmd[i].details.save_array.saved_data.time);
- break;
- default:
- break;
- }
- }
-
- case CMD_INSERT_DEPOSIT:
- free_deposit(cmd[i].exposed.deposit);
- break;
-
- case CMD_LOAD_ARRAY:
- GNUNET_free(cmd[i].details.load_array.permutation);
- break;
-
- default:
- break;
-
- }
- i++;
- }
- return GNUNET_OK;
-}
-
-
-/**
- *
- */
- static int
-interprete(struct TALER_MINTDB_Plugin *db_plugin,
- struct TALER_MINTDB_Session*session,
- struct PERF_TALER_MINTDB_CMD cmd[])
-{
- int i=0;
- while (0){
- switch (cmd[i].command)
- {
- case CMD_END:
- return GNUNET_YES;
-
- case CMD_LOOP:
- cmd[i].details.loop.curr_iteration++;
- break;
-
- case CMD_END_LOOP:
- {
- int jump = cmd_find(cmd, cmd[i].details.end_loop.loop_start);
- zf (cmd[jump].details.loop.max_iterations > cmd[jump].details.loop.curr_iteration)
- {
- i = jump -1;
- }else{
- int j;
- // For each command in the loop
- for (j = 0; j <i; j++){
- // If the exposed variable has not been copied
- if (!cmd[j].exposed_used)
- {
- cmd[j].exposed_used = 0;
- // It is freed
- switch (cmd[j].command){
- case CMD_INSERT_DEPOSIT:
- free_deposit(cmd[j].exposed.deposit);
- cmd[j].exposed.deposit = NULL;
- break;
-
- default:
- break;
- }
- }
- }
- }
- }
- break;
-
-
- case CMD_GET_TIME:
- clock_gettime(CLOCK_MONOTONIC, &cmd[i].exposed.time);
- break;
-
-
- case CMD_GAUGER:
- {
- int start_index = cmd_find(cmd, cmd[i].details.gauger.start_time);
- int stop_index = cmd_find(cmd, cmd[i].details.gauger.stop_time );
- struct timespec start= cmd[start_index].exposed.time;
- struct timespec stop = cmd[stop_index].exposed.time;
-
- unsigned long elapsed_ms = (start.tv_sec - stop.tv_sec)*1000 + (start.tv_nsec - stop.tv_nsec)/1000000;
-
- GAUGER("MINTDB", cmd[i].details.gauger.description, elapsed_ms, "milliseconds");
- }
- break;
-
- case CMD_START_TRANSACTION:
- db_plugin->start(db_plugin->cls, session);
- break;
-
-
- case CMD_COMMIT_TRANSACTION:
- db_plugin->commit(db_plugin->cls, session);
- break;
-
-
- case CMD_INSERT_DEPOSIT:
- {
- struct TALER_MINTDB_Deposit *deposit = init_deposit(0);
- db_plugin->insert_deposit(db_plugin->cls, session, deposit);
-
- cmd[i].exposed.deposit = deposit;
- }
- break;
-
-
- case CMD_GET_DEPOSIT:
- {
- int source_index = cmd_find(cmd, cmd[i].details.get_deposit.source); // Find the source location
- struct TALER_MINTDB_Deposit *deposit = cmd[source_index].exposed.deposit; // Get the deposit from the source
- db_plugin->have_deposit(db_plugin->cls, session, deposit);
- }
- break;
-
-
- case CMD_SAVE_ARRAY:
- {
- // Array initialization on first loop iteration
- if (cmd[cmd_find(cmd, cmd[i].details.save_array.loop)].details.loop.curr_iteration == 0)
- {
- cmd[i].details.save_array.index = 0;
- }
-
- int loop_index = cmd_find(cmd, cmd[i].details.save_array.loop);
- int proba = cmd[loop_index].details.loop.max_iterations / cmd[i].details.save_array.nb;
- int rnd = GNUNET_CRYPTO_random_u32(GNUNET_CRYPTO_QUALITY_WEAK, proba);
-
- // If there is a lesser or equal number of iteration next than room remain in the array
- if ((cmd[loop_index].details.loop.max_iterations - cmd[loop_index].details.loop.curr_iteration <=
- cmd[i].details.save_array.nb - cmd[i].details.save_array.index) ||
- (rnd == 0 && cmd[i].details.save_array.index < cmd[i].details.save_array.nb))
- {
-
- // We automaticly save the whatever we need to
- switch (cmd[i].details.save_array.saved_type){
- case DEPOSIT:
- cmd[i].details.save_array.saved_data.deposit[cmd[i].details.save_array.index] =
- cmd[cmd_find(cmd, cmd[i].details.save_array.saved)].exposed.deposit;
- break;
- case TIME:
- cmd[i].details.save_array.saved_data.deposit[cmd[i].details.save_array.index] =
- cmd[cmd_find(cmd, cmd[i].details.save_array.saved)].exposed.deposit;
- break;
- }
- cmd[i].details.save_array.index++;
- }
- }
- break;
-
-
- case CMD_LOAD_ARRAY:
- {
-
- int loop_index = cmd_find(cmd, cmd[i].details.load_array.loop);
- int save_index = cmd_find(cmd, cmd[i].details.load_array.saved);
- switch (cmd[i].details.load_array.loaded_type){
- case DEPOSIT:
- cmd[i].exposed.deposit = cmd[save_index].details.save_array.saved_data.deposit[
- cmd[i].details.load_array.permutation[
- cmd[loop_index].details.loop.curr_iteration
- ]
- ];
- break;
-
- case TIME:
- cmd[i].exposed.time = cmd[save_index].details.save_array.saved_data.time[
- cmd[i].details.load_array.permutation[
- cmd[loop_index].details.loop.curr_iteration
- ]
- ];
- break;
- default:
- break;
-
- }
- }
- }
- i++;
- }
- return GNUNET_OK;
-}
-
-/**
- * Runs the commands given in @a cmd, working with
- * the database referenced by @a db_plugin
- */
- int
-PERF_TALER_MINTDB_interprete(struct TALER_MINTDB_Plugin *db_plugin,
- struct TALER_MINTDB_Session *session,
- struct PERF_TALER_MINTDB_CMD cmd[])
-{
-
- // Initializing commands
- cmd_init(cmd);
-
- // Running the interpreter
- interprete(db_plugin, session, cmd);
-
- // Cleaning the memory
- cmd_clean(cmd);
-
- return GNUNET_YES;
-
-}