diff options
author | Christian Grothoff <christian@grothoff.org> | 2019-10-11 23:20:13 +0200 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2019-10-11 23:36:09 +0200 |
commit | 195fd08b9f0f46efd63dd87fb8f5fdbaca8ca610 (patch) | |
tree | fa276199ebd059bd6a957e172b814b9aa2b922fd | |
parent | e3e21acb23283915c97e6ef1c167325f4592665c (diff) | |
download | gnunet-195fd08b9f0f46efd63dd87fb8f5fdbaca8ca610.tar.gz gnunet-195fd08b9f0f46efd63dd87fb8f5fdbaca8ca610.zip |
add GNUNET_PQ_reconnect_if_down
-rw-r--r-- | src/include/gnunet_pq_lib.h | 9 | ||||
-rw-r--r-- | src/pq/pq_connect.c | 14 |
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 | */ | ||
756 | void | ||
757 | GNUNET_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 | */ | ||
135 | void | ||
136 | GNUNET_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 |