summaryrefslogtreecommitdiff
path: root/src/backenddb/pg_expire_locks.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/backenddb/pg_expire_locks.c')
-rw-r--r--src/backenddb/pg_expire_locks.c10
1 files changed, 6 insertions, 4 deletions
diff --git a/src/backenddb/pg_expire_locks.c b/src/backenddb/pg_expire_locks.c
index 4b12ba04..7a3c3bac 100644
--- a/src/backenddb/pg_expire_locks.c
+++ b/src/backenddb/pg_expire_locks.c
@@ -25,7 +25,8 @@
#include "pg_expire_locks.h"
#include "pg_helper.h"
-void
+
+enum GNUNET_DB_QueryStatus
TMH_PG_expire_locks (void *cls)
{
struct PostgresClosure *pg = cls;
@@ -49,7 +50,7 @@ TMH_PG_expire_locks (void *cls)
if (qs1 < 0)
{
GNUNET_break (0);
- return;
+ return qs1;
}
PREPARE (pg,
"unlock_orders",
@@ -61,7 +62,7 @@ TMH_PG_expire_locks (void *cls)
if (qs2 < 0)
{
GNUNET_break (0);
- return;
+ return qs2;
}
PREPARE (pg,
"unlock_contracts",
@@ -74,11 +75,12 @@ TMH_PG_expire_locks (void *cls)
if (qs3 < 0)
{
GNUNET_break (0);
- return;
+ return qs3;
}
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Released %d+%d+%d locks\n",
qs1,
qs2,
qs3);
+ return qs1 + qs2 + qs3;
}