diff options
author | Christian Grothoff <christian@grothoff.org> | 2022-10-13 19:07:25 +0200 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2022-10-13 19:07:25 +0200 |
commit | 09310cc66ebbdf083c4b4fa86a368b3ea52c0c16 (patch) | |
tree | b87132659d9d27e5e7d84e4f76b4d836b6689f9d /src/exchange/taler-exchange-closer.c | |
parent | 4fc77b9dbfee88dff2d366d7dbb2d91797f8b9a0 (diff) | |
download | exchange-09310cc66ebbdf083c4b4fa86a368b3ea52c0c16.tar.gz exchange-09310cc66ebbdf083c4b4fa86a368b3ea52c0c16.tar.bz2 exchange-09310cc66ebbdf083c4b4fa86a368b3ea52c0c16.zip |
-implement reserve closure in test
Diffstat (limited to 'src/exchange/taler-exchange-closer.c')
-rw-r--r-- | src/exchange/taler-exchange-closer.c | 19 |
1 files changed, 13 insertions, 6 deletions
diff --git a/src/exchange/taler-exchange-closer.c b/src/exchange/taler-exchange-closer.c index 0e203f0fe..eacfa5d50 100644 --- a/src/exchange/taler-exchange-closer.c +++ b/src/exchange/taler-exchange-closer.c @@ -1,6 +1,6 @@ /* This file is part of TALER - Copyright (C) 2016-2021 Taler Systems SA + Copyright (C) 2016-2022 Taler Systems SA TALER is free software; you can redistribute it and/or modify it under the terms of the GNU Affero General Public License as published by the Free Software @@ -431,11 +431,18 @@ run_reserve_closures (void *cls) GNUNET_log (GNUNET_ERROR_TYPE_INFO, "Checking for reserves to close by date %s\n", GNUNET_TIME_timestamp2s (now)); - qs = db_plugin->get_expired_reserves (db_plugin->cls, - now, - &expired_reserve_cb, - NULL); - GNUNET_assert (1 >= qs); + qs = db_plugin->get_unfinished_close_requests (db_plugin->cls, + &expired_reserve_cb, + NULL); + if (GNUNET_DB_STATUS_SUCCESS_NO_RESULTS == qs) + { + /* Try expired reserves as well */ + qs = db_plugin->get_expired_reserves ( + db_plugin->cls, + now, + &expired_reserve_cb, + NULL); + } switch (qs) { case GNUNET_DB_STATUS_HARD_ERROR: |