diff options
| author | Christian Grothoff <christian@grothoff.org> | 2023-09-10 19:13:49 +0200 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2023-09-10 19:13:49 +0200 |
| commit | 852c46668f1c9f766de9473c50e787e32a0f8697 (patch) | |
| tree | 6106427e8da10610507b12cd4d663f3e66d8eae7 /src/auditor | |
| parent | cf595fa8480e87e1522710cd8ea7db9174aa028b (diff) | |
| download | exchange-852c46668f1c9f766de9473c50e787e32a0f8697.tar.xz | |
major exchange DB schema change: store common properties of batch deposit in batch_deposits table, and coin-specific ones in coin_deposits table; plus minor cleanups
Diffstat (limited to 'src/auditor')
| -rw-r--r-- | src/auditor/taler-auditor-sync.c | 3 | ||||
| -rw-r--r-- | src/auditor/taler-helper-auditor-coins.c | 2 | ||||
| -rw-r--r-- | src/auditor/taler-helper-auditor-wire.c | 10 |
3 files changed, 8 insertions, 7 deletions
diff --git a/src/auditor/taler-auditor-sync.c b/src/auditor/taler-auditor-sync.c index 2b4bf8558..e4022d325 100644 --- a/src/auditor/taler-auditor-sync.c +++ b/src/auditor/taler-auditor-sync.c @@ -108,7 +108,8 @@ static struct Table tables[] = { { .rt = TALER_EXCHANGEDB_RT_REFRESH_COMMITMENTS}, { .rt = TALER_EXCHANGEDB_RT_REFRESH_REVEALED_COINS}, { .rt = TALER_EXCHANGEDB_RT_REFRESH_TRANSFER_KEYS}, - { .rt = TALER_EXCHANGEDB_RT_DEPOSITS}, + { .rt = TALER_EXCHANGEDB_RT_BATCH_DEPOSITS}, + { .rt = TALER_EXCHANGEDB_RT_COIN_DEPOSITS}, { .rt = TALER_EXCHANGEDB_RT_REFUNDS}, { .rt = TALER_EXCHANGEDB_RT_WIRE_OUT}, { .rt = TALER_EXCHANGEDB_RT_AGGREGATION_TRACKING}, diff --git a/src/auditor/taler-helper-auditor-coins.c b/src/auditor/taler-helper-auditor-coins.c index 8edbcf29b..5ce7fcb46 100644 --- a/src/auditor/taler-helper-auditor-coins.c +++ b/src/auditor/taler-helper-auditor-coins.c @@ -2553,7 +2553,7 @@ analyze_coins (void *cls) /* process deposits */ if (0 > - (qs = TALER_ARL_edb->select_deposits_above_serial_id ( + (qs = TALER_ARL_edb->select_coin_deposits_above_serial_id ( TALER_ARL_edb->cls, ppc.last_deposit_serial_id, &deposit_cb, diff --git a/src/auditor/taler-helper-auditor-wire.c b/src/auditor/taler-helper-auditor-wire.c index 4e4d0ae22..edfdd5af1 100644 --- a/src/auditor/taler-helper-auditor-wire.c +++ b/src/auditor/taler-helper-auditor-wire.c @@ -914,11 +914,11 @@ check_for_required_transfers (void) GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Analyzing exchange's unfinished deposits (deadline: %s)\n", GNUNET_TIME_timestamp2s (next_timestamp)); - qs = TALER_ARL_edb->select_deposits_missing_wire (TALER_ARL_edb->cls, - pp.last_timestamp, - next_timestamp, - &wire_missing_cb, - &next_timestamp); + qs = TALER_ARL_edb->select_batch_deposits_missing_wire (TALER_ARL_edb->cls, + pp.last_timestamp, + next_timestamp, + &wire_missing_cb, + &next_timestamp); if (0 > qs) { GNUNET_break (0); |