diff options
| author | Christian Grothoff <christian@grothoff.org> | 2022-03-03 19:39:19 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2022-03-03 19:39:25 +0100 |
| commit | f951cdef8ced141326887c1a996e8546774514f6 (patch) | |
| tree | 6de32e119c3b074e81229cb9c7f4c7252a61bb31 /src/exchange/taler-exchange-aggregator.c | |
| parent | 4c53d42e44cbab55194b2f0fb71ffc3cb082b56a (diff) | |
include shard when marking deposits tiny/done to make better use of partitions/shards
Diffstat (limited to 'src/exchange/taler-exchange-aggregator.c')
| -rw-r--r-- | src/exchange/taler-exchange-aggregator.c | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/exchange/taler-exchange-aggregator.c b/src/exchange/taler-exchange-aggregator.c index c552610a..58bf2073 100644 --- a/src/exchange/taler-exchange-aggregator.c +++ b/src/exchange/taler-exchange-aggregator.c @@ -488,6 +488,7 @@ deposit_cb (void *cls, "Aggregator marks deposit %llu as done\n", (unsigned long long) row_id); qs = db_plugin->mark_deposit_done (db_plugin->cls, + merchant_pub, row_id); if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT != qs) { @@ -610,6 +611,7 @@ aggregate_cb (void *cls, return qs; } qs = db_plugin->mark_deposit_done (db_plugin->cls, + &au->merchant_pub, row_id); if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT != qs) { @@ -842,12 +844,14 @@ run_aggregation (void *cls) } /* Mark transactions by row_id as minor */ qs = db_plugin->mark_deposit_tiny (db_plugin->cls, + &au_active.merchant_pub, au_active.row_id); if (0 <= qs) { for (unsigned int i = 0; i<au_active.rows_offset; i++) { qs = db_plugin->mark_deposit_tiny (db_plugin->cls, + &au_active.merchant_pub, au_active.additional_rows[i]); if (0 > qs) break; |