summaryrefslogtreecommitdiff
path: root/src/mintdb/perf_taler_mintdb_interpreter.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/mintdb/perf_taler_mintdb_interpreter.c')
-rw-r--r--src/mintdb/perf_taler_mintdb_interpreter.c307
1 files changed, 307 insertions, 0 deletions
diff --git a/src/mintdb/perf_taler_mintdb_interpreter.c b/src/mintdb/perf_taler_mintdb_interpreter.c
new file mode 100644
index 000000000..93c49b9c0
--- /dev/null
+++ b/src/mintdb/perf_taler_mintdb_interpreter.c
@@ -0,0 +1,307 @@
+#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;
+
+}
generated by cgit v1.2.3 (git 2.39.1) at 2024-05-11 14:26:30 +0000