summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2019-10-11 23:20:13 +0200
committerChristian Grothoff <christian@grothoff.org>2019-10-11 23:36:09 +0200
commit195fd08b9f0f46efd63dd87fb8f5fdbaca8ca610 (patch)
treefa276199ebd059bd6a957e172b814b9aa2b922fd /src
parente3e21acb23283915c97e6ef1c167325f4592665c (diff)
downloadgnunet-195fd08b9f0f46efd63dd87fb8f5fdbaca8ca610.tar.gz
gnunet-195fd08b9f0f46efd63dd87fb8f5fdbaca8ca610.zip
add GNUNET_PQ_reconnect_if_down
Diffstat (limited to 'src')
-rw-r--r--src/include/gnunet_pq_lib.h9
-rw-r--r--src/pq/pq_connect.c14
2 files changed, 23 insertions, 0 deletions
diff --git a/src/include/gnunet_pq_lib.h b/src/include/gnunet_pq_lib.h
index a56df21fd..2aea77b7f 100644
--- a/src/include/gnunet_pq_lib.h
+++ b/src/include/gnunet_pq_lib.h
@@ -749,6 +749,15 @@ GNUNET_PQ_connect_with_cfg (const struct GNUNET_CONFIGURATION_Handle *cfg,
749 749
750 750
751/** 751/**
752 * Reinitialize the database @a db if the connection is down.
753 *
754 * @param db database connection to reinitialize
755 */
756void
757GNUNET_PQ_reconnect_if_down (struct GNUNET_PQ_Context *db);
758
759
760/**
752 * Reinitialize the database @a db. 761 * Reinitialize the database @a db.
753 * 762 *
754 * @param db database connection to reinitialize 763 * @param db database connection to reinitialize
diff --git a/src/pq/pq_connect.c b/src/pq/pq_connect.c
index 7599f4b15..882df4f89 100644
--- a/src/pq/pq_connect.c
+++ b/src/pq/pq_connect.c
@@ -128,6 +128,20 @@ GNUNET_PQ_connect (const char *config_str,
128 128
129 129
130/** 130/**
131 * Reinitialize the database @a db if the connection is down.
132 *
133 * @param db database connection to reinitialize
134 */
135void
136GNUNET_PQ_reconnect_if_down (struct GNUNET_PQ_Context *db)
137{
138 if (CONNECTION_BAD != PQstatus (db->conn))
139 return;
140 GNUNET_PQ_reconnect (db);
141}
142
143
144/**
131 * Reinitialize the database @a db. 145 * Reinitialize the database @a db.
132 * 146 *
133 * @param db database connection to reinitialize 147 * @param db database connection to reinitialize