diff options
| author | Christian Grothoff <christian@grothoff.org> | 2018-04-02 21:12:18 +0200 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2018-04-02 21:12:18 +0200 |
| commit | aea82d3dcde94b68a70a65be8736cf7ad437b0c7 (patch) | |
| tree | afe52630b7b25f2ca5039183ca5ba616ffd1dff0 /src/auditor/taler-wire-auditor.c | |
| parent | 2b0f98dd4b875ed0f7f833c377197265fa11384e (diff) | |
| download | exchange-aea82d3dcde94b68a70a65be8736cf7ad437b0c7.tar.gz exchange-aea82d3dcde94b68a70a65be8736cf7ad437b0c7.tar.bz2 exchange-aea82d3dcde94b68a70a65be8736cf7ad437b0c7.zip | |
allow auditor to operate per-account
Diffstat (limited to 'src/auditor/taler-wire-auditor.c')
| -rw-r--r-- | src/auditor/taler-wire-auditor.c | 22 |
1 files changed, 12 insertions, 10 deletions
diff --git a/src/auditor/taler-wire-auditor.c b/src/auditor/taler-wire-auditor.c index d9c2d820b..6e66ea99c 100644 --- a/src/auditor/taler-wire-auditor.c +++ b/src/auditor/taler-wire-auditor.c @@ -861,11 +861,12 @@ check_exchange_wire_out () enum GNUNET_DB_QueryStatus qs; struct GNUNET_TIME_Absolute next_timestamp; - qs = edb->select_wire_out_above_serial_id (edb->cls, - esession, - pp.last_wire_out_serial_id, - &wire_out_cb, - NULL); + qs = edb->select_wire_out_above_serial_id_by_account (edb->cls, + esession, + wp_section_name, + pp.last_wire_out_serial_id, + &wire_out_cb, + NULL); if (0 > qs) { GNUNET_break (GNUNET_DB_STATUS_SOFT_ERROR == qs); @@ -1439,11 +1440,12 @@ process_next_account (void *cls) in_map = GNUNET_CONTAINER_multihashmap_create (1024, GNUNET_YES); - qs = edb->select_reserves_in_above_serial_id (edb->cls, - esession, - pp.last_reserve_in_serial_id, - &reserve_in_cb, - NULL); + qs = edb->select_reserves_in_above_serial_id_by_account (edb->cls, + esession, + wp_section_name, + pp.last_reserve_in_serial_id, + &reserve_in_cb, + NULL); if (0 > qs) { GNUNET_break (GNUNET_DB_STATUS_SOFT_ERROR == qs); |