aboutsummaryrefslogtreecommitdiff
path: root/src/exchangedb/pg_reserves_in_insert.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2023-06-23 11:41:52 +0200
committerChristian Grothoff <christian@grothoff.org>2023-06-23 11:41:52 +0200
commitd25dc8b0adb8fa606e8f97185984a623c52819cd (patch)
treed44d8c3f0c62544c653a7d299c029132913eb2c7 /src/exchangedb/pg_reserves_in_insert.c
parent720783b66a08a14624f30e8063daf64d25ce3e4c (diff)
downloadexchange-d25dc8b0adb8fa606e8f97185984a623c52819cd.tar.xz
fix #7870
Diffstat (limited to 'src/exchangedb/pg_reserves_in_insert.c')
-rw-r--r--src/exchangedb/pg_reserves_in_insert.c2
1 files changed, 2 insertions, 0 deletions
diff --git a/src/exchangedb/pg_reserves_in_insert.c b/src/exchangedb/pg_reserves_in_insert.c
index 72fde7499..7f59826c7 100644
--- a/src/exchangedb/pg_reserves_in_insert.c
+++ b/src/exchangedb/pg_reserves_in_insert.c
@@ -611,6 +611,7 @@ TEH_PG_reserves_in_insert (
reserves_length,
batch_size,
results);
+ GNUNET_PQ_event_do_poll (pg->conn);
for (unsigned int i = 0; i<reserves_length; i++)
GNUNET_free (rrs[i].notify_s);
return qs;
@@ -889,6 +890,7 @@ TEH_PG_reserves_in_insertN (
}
}
finished:
+ GNUNET_PQ_event_do_poll (pg->conn);
for (unsigned int i = 0; i<reserves_length; i++)
GNUNET_free (rrs[i].notify_s);
return qs;