From ec03f262b650638ff6dd8ec89c382b958b256c1b Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Sun, 16 Jul 2023 11:25:22 +0200 Subject: [PATCH] fix taler-aggregator-benchmark --- src/benchmark/taler-aggregator-benchmark.c | 16 ++++++++++++---- src/exchangedb/pg_insert_deposit.c | 2 -- src/exchangedb/pg_insert_refund.c | 11 +++++------ src/exchangedb/pg_insert_wire_fee.c | 1 + 4 files changed, 18 insertions(+), 12 deletions(-) diff --git a/src/benchmark/taler-aggregator-benchmark.c b/src/benchmark/taler-aggregator-benchmark.c index bf9a3f3ec..193a1ada7 100644 --- a/src/benchmark/taler-aggregator-benchmark.c +++ b/src/benchmark/taler-aggregator-benchmark.c @@ -251,7 +251,7 @@ add_refund (const struct Merchant *m, r.details.rtransaction_id = 42; make_amount (0, 5000000, &r.details.refund_amount); make_amount (0, 5, &r.details.refund_fee); - if (0 <= + if (0 >= plugin->insert_refund (plugin->cls, &r)) { @@ -307,8 +307,13 @@ add_deposit (const struct Merchant *m) deposit.wire_salt = m->wire_salt; deposit.receiver_wire_account = m->payto_uri; deposit.timestamp = random_time (); - deposit.refund_deadline = random_time (); - deposit.wire_deadline = random_time (); + do { + deposit.refund_deadline = random_time (); + deposit.wire_deadline = random_time (); + } while (GNUNET_TIME_timestamp_cmp (deposit.wire_deadline, + <, + deposit.refund_deadline)); + make_amount (1, 0, &deposit.amount_with_fee); make_amount (0, 5, &deposit.deposit_fee); if (0 >= @@ -446,6 +451,9 @@ run (void *cls, } GNUNET_SCHEDULER_add_shutdown (&do_shutdown, NULL); + memset (&issue, + 0, + sizeof (issue)); RANDOMIZE (&issue.signature); issue.start = start; @@ -478,6 +486,7 @@ run (void *cls, TALER_DENOMINATION_RSA, 1024)); alg_values.cipher = TALER_DENOMINATION_RSA; + denom_pub.age_mask = issue.age_mask; TALER_denom_pub_hash (&denom_pub, &h_denom_pub); make_amount (2, 0, &issue.value); @@ -497,7 +506,6 @@ run (void *cls, return; } - TALER_planchet_blinding_secret_create (&ps, &alg_values, &bks); diff --git a/src/exchangedb/pg_insert_deposit.c b/src/exchangedb/pg_insert_deposit.c index ec4d49bf9..a4d68fe19 100644 --- a/src/exchangedb/pg_insert_deposit.c +++ b/src/exchangedb/pg_insert_deposit.c @@ -97,8 +97,6 @@ TEH_PG_insert_deposit (void *cls, " FROM known_coins" " WHERE coin_pub=$1" " ON CONFLICT DO NOTHING;"); - - return GNUNET_PQ_eval_prepared_non_select (pg->conn, "insert_deposit", params); diff --git a/src/exchangedb/pg_insert_refund.c b/src/exchangedb/pg_insert_refund.c index 8f9466575..020750870 100644 --- a/src/exchangedb/pg_insert_refund.c +++ b/src/exchangedb/pg_insert_refund.c @@ -45,16 +45,15 @@ TEH_PG_insert_refund (void *cls, TALER_amount_cmp_currency (&refund->details.refund_amount, &refund->details.refund_fee)); - /* Used in #postgres_insert_refund() to store refund information */ PREPARE (pg, "insert_refund", "INSERT INTO refunds " - "(coin_pub " + "(coin_pub" ",deposit_serial_id" - ",merchant_sig " - ",rtransaction_id " - ",amount_with_fee_val " - ",amount_with_fee_frac " + ",merchant_sig" + ",rtransaction_id" + ",amount_with_fee_val" + ",amount_with_fee_frac" ") SELECT $1, deposit_serial_id, $3, $5, $6, $7" " FROM deposits" " WHERE coin_pub=$1" diff --git a/src/exchangedb/pg_insert_wire_fee.c b/src/exchangedb/pg_insert_wire_fee.c index ac14a8cbb..6d94e3d56 100644 --- a/src/exchangedb/pg_insert_wire_fee.c +++ b/src/exchangedb/pg_insert_wire_fee.c @@ -26,6 +26,7 @@ #include "pg_helper.h" #include "pg_get_wire_fee.h" + enum GNUNET_DB_QueryStatus TEH_PG_insert_wire_fee (void *cls, const char *type,