diff options
Diffstat (limited to 'src/pq/pq_connect.c')
-rw-r--r-- | src/pq/pq_connect.c | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/pq/pq_connect.c b/src/pq/pq_connect.c index fd73cf0d8..fa8ad86a0 100644 --- a/src/pq/pq_connect.c +++ b/src/pq/pq_connect.c | |||
@@ -312,6 +312,9 @@ GNUNET_PQ_run_sql (struct GNUNET_PQ_Context *db, | |||
312 | void | 312 | void |
313 | GNUNET_PQ_reconnect_if_down (struct GNUNET_PQ_Context *db) | 313 | GNUNET_PQ_reconnect_if_down (struct GNUNET_PQ_Context *db) |
314 | { | 314 | { |
315 | if (1 == | ||
316 | PQ_consumeInput (db->conn)) | ||
317 | return; | ||
315 | if (CONNECTION_BAD != PQstatus (db->conn)) | 318 | if (CONNECTION_BAD != PQstatus (db->conn)) |
316 | return; | 319 | return; |
317 | GNUNET_PQ_reconnect (db); | 320 | GNUNET_PQ_reconnect (db); |