summaryrefslogtreecommitdiff
path: root/src/exchangedb/lrbt_callbacks.c
diff options
context:
space:
mode:
authorChristian Grothoff <grothoff@gnunet.org>2022-03-18 01:57:39 +0100
committerChristian Grothoff <grothoff@gnunet.org>2022-03-18 01:57:39 +0100
commit23af6c3c41f458fa47abaf613c095aac71b8c200 (patch)
treeb0c7971052b41ef2db7d4b7f258ab4dc5862c834 /src/exchangedb/lrbt_callbacks.c
parenta59d39f699c79a09e3ca33eb082d895444784751 (diff)
downloadexchange-23af6c3c41f458fa47abaf613c095aac71b8c200.tar.gz
exchange-23af6c3c41f458fa47abaf613c095aac71b8c200.tar.bz2
exchange-23af6c3c41f458fa47abaf613c095aac71b8c200.zip
change table structures again to shard better by coin_pub and not use known_coin_id so much
Diffstat (limited to 'src/exchangedb/lrbt_callbacks.c')
-rw-r--r--src/exchangedb/lrbt_callbacks.c11
1 files changed, 9 insertions, 2 deletions
diff --git a/src/exchangedb/lrbt_callbacks.c b/src/exchangedb/lrbt_callbacks.c
index 9e9f37780..a5b30c765 100644
--- a/src/exchangedb/lrbt_callbacks.c
+++ b/src/exchangedb/lrbt_callbacks.c
@@ -920,6 +920,9 @@ lrbt_cb_table_deposits (void *cls,
GNUNET_PQ_result_spec_uint64 (
"known_coin_id",
&td.details.deposits.known_coin_id),
+ GNUNET_PQ_result_spec_auto_from_type (
+ "coin_pub",
+ &td.details.deposits.coin_pub),
TALER_PQ_RESULT_SPEC_AMOUNT (
"amount_with_fee",
&td.details.deposits.amount_with_fee),
@@ -1306,8 +1309,9 @@ lrbt_cb_table_recoup (void *cls,
&td.details.recoup.amount),
GNUNET_PQ_result_spec_timestamp ("recoup_timestamp",
&td.details.recoup.timestamp),
- GNUNET_PQ_result_spec_uint64 ("known_coin_id",
- &td.details.recoup.known_coin_id),
+ GNUNET_PQ_result_spec_auto_from_type (
+ "coin_pub",
+ &td.details.recoup.coin_pub),
GNUNET_PQ_result_spec_uint64 ("reserve_out_serial_id",
&td.details.recoup.reserve_out_serial_id),
GNUNET_PQ_result_spec_end
@@ -1363,6 +1367,9 @@ lrbt_cb_table_recoup_refresh (void *cls,
&td.details.recoup_refresh.timestamp),
GNUNET_PQ_result_spec_uint64 ("known_coin_id",
&td.details.recoup_refresh.known_coin_id),
+ GNUNET_PQ_result_spec_auto_from_type (
+ "coin_pub",
+ &td.details.recoup_refresh.coin_pub),
GNUNET_PQ_result_spec_uint64 ("rrc_serial",
&td.details.recoup_refresh.rrc_serial),
GNUNET_PQ_result_spec_end