summaryrefslogtreecommitdiff
path: root/src/exchange/taler-exchange-closer.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2022-10-13 19:07:25 +0200
committerChristian Grothoff <christian@grothoff.org>2022-10-13 19:07:25 +0200
commit09310cc66ebbdf083c4b4fa86a368b3ea52c0c16 (patch)
treeb87132659d9d27e5e7d84e4f76b4d836b6689f9d /src/exchange/taler-exchange-closer.c
parent4fc77b9dbfee88dff2d366d7dbb2d91797f8b9a0 (diff)
downloadexchange-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.c19
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: