diff options
| author | Christian Grothoff <christian@grothoff.org> | 2022-12-06 13:29:23 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2022-12-06 13:29:23 +0100 |
| commit | 87198f124c989d014adc9a2bae5098cf80555d62 (patch) | |
| tree | 666ea877e53cebbe2ff9260f3efcdfff4a0b7c08 /src/exchangedb/pg_batch_reserves_in_insert.c | |
| parent | 21959eebd2256a3fb72173488cf366868179ee13 (diff) | |
| download | exchange-87198f124c989d014adc9a2bae5098cf80555d62.tar.xz | |
refactor procedures.sql
Diffstat (limited to 'src/exchangedb/pg_batch_reserves_in_insert.c')
| -rw-r--r-- | src/exchangedb/pg_batch_reserves_in_insert.c | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/src/exchangedb/pg_batch_reserves_in_insert.c b/src/exchangedb/pg_batch_reserves_in_insert.c index 4a1a2792e..455f080dd 100644 --- a/src/exchangedb/pg_batch_reserves_in_insert.c +++ b/src/exchangedb/pg_batch_reserves_in_insert.c @@ -62,7 +62,8 @@ notify_on_reserve (struct PostgresClosure *pg, enum GNUNET_DB_QueryStatus TEH_PG_batch_reserves_in_insert (void *cls, - const struct TALER_EXCHANGEDB_ReserveInInfo *reserves, + const struct + TALER_EXCHANGEDB_ReserveInInfo *reserves, unsigned int reserves_length, enum GNUNET_DB_QueryStatus *results) { @@ -83,7 +84,7 @@ TEH_PG_batch_reserves_in_insert (void *cls, "out_reserve_found AS conflicted" ",transaction_duplicate" ",ruuid AS reserve_uuid" - " FROM batch_reserves_in" + " FROM exchange_do_batch_reserves_in" " ($1,$2,$3,$4,$5,$6,$7,$8,$9,$10,$11);"); expiry = GNUNET_TIME_absolute_to_timestamp ( GNUNET_TIME_absolute_add (reserves->execution_time.abs_time, @@ -101,7 +102,7 @@ TEH_PG_batch_reserves_in_insert (void *cls, time; we do this before adding the actual transaction to "reserves_in", as for a new reserve it can't be a duplicate 'add' operation, and as the 'add' operation needs the reserve entry as a foreign key. */ - for (unsigned int i=0;i<reserves_length;i++) + for (unsigned int i = 0; i<reserves_length; i++) { const struct TALER_EXCHANGEDB_ReserveInInfo *reserve = &reserves[i]; struct GNUNET_PQ_QueryParam params[] = { @@ -136,7 +137,7 @@ TEH_PG_batch_reserves_in_insert (void *cls, params, rs); if (qs1 < 0) - return qs1; + return qs1; notify_on_reserve (pg, &reserve->reserve_pub); GNUNET_assert (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS != qs1); @@ -144,7 +145,7 @@ TEH_PG_batch_reserves_in_insert (void *cls, ? GNUNET_DB_STATUS_SUCCESS_NO_RESULTS : GNUNET_DB_STATUS_SUCCESS_ONE_RESULT; if ( (! conflicted) && transaction_duplicate) - TEH_PG_rollback(pg); + TEH_PG_rollback (pg); } return reserves_length; } |