summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2020-01-17 02:24:14 +0100
committerChristian Grothoff <christian@grothoff.org>2020-01-17 02:24:21 +0100
commitda0a2f39d0ae59036e9bb08f7ae9ef02cfacc3c9 (patch)
tree0cf76d477e6c7eed8ae5c245f05cb67ee5b81aa5
parentcc862fb2795aefed25b1a7b4d1dcac750f648f1b (diff)
downloadexchange-da0a2f39d0ae59036e9bb08f7ae9ef02cfacc3c9.tar.gz
exchange-da0a2f39d0ae59036e9bb08f7ae9ef02cfacc3c9.tar.bz2
exchange-da0a2f39d0ae59036e9bb08f7ae9ef02cfacc3c9.zip
GNUnet PQ API change
-rw-r--r--src/auditordb/plugin_auditordb_postgres.c4
-rw-r--r--src/exchangedb/plugin_exchangedb_postgres.c5
2 files changed, 8 insertions, 1 deletions
diff --git a/src/auditordb/plugin_auditordb_postgres.c b/src/auditordb/plugin_auditordb_postgres.c
index 25734facc..7e6b7bf09 100644
--- a/src/auditordb/plugin_auditordb_postgres.c
+++ b/src/auditordb/plugin_auditordb_postgres.c
@@ -160,6 +160,7 @@ postgres_drop_tables (void *cls,
int ret;
conn = GNUNET_PQ_connect (pc->connection_cfg_str,
+ NULL,
es,
NULL);
if (NULL == conn)
@@ -407,6 +408,7 @@ postgres_create_tables (void *cls)
struct GNUNET_PQ_Context *conn;
conn = GNUNET_PQ_connect (pc->connection_cfg_str,
+ NULL,
es,
NULL);
if (NULL == conn)
@@ -992,6 +994,7 @@ postgres_get_session (void *cls)
}
db_conn = GNUNET_PQ_connect (pc->connection_cfg_str,
NULL,
+ NULL,
ps);
if (NULL == db_conn)
return NULL;
@@ -1152,6 +1155,7 @@ postgres_gc (void *cls)
now = GNUNET_TIME_absolute_get ();
conn = GNUNET_PQ_connect (pc->connection_cfg_str,
NULL,
+ NULL,
ps);
if (NULL == conn)
return GNUNET_SYSERR;
diff --git a/src/exchangedb/plugin_exchangedb_postgres.c b/src/exchangedb/plugin_exchangedb_postgres.c
index 73db049eb..47ac8e7bf 100644
--- a/src/exchangedb/plugin_exchangedb_postgres.c
+++ b/src/exchangedb/plugin_exchangedb_postgres.c
@@ -172,6 +172,7 @@ postgres_drop_tables (void *cls)
struct GNUNET_PQ_Context *conn;
conn = GNUNET_PQ_connect (pc->connection_cfg_str,
+ NULL,
es,
NULL);
if (NULL == conn)
@@ -494,7 +495,6 @@ postgres_create_tables (void *cls)
",buf BYTEA NOT NULL"
");"),
-
/* Index for wire_prepare_data_get and gc_prewire statement */
GNUNET_PQ_make_try_execute ("CREATE INDEX prepare_iteration_index "
"ON prewire(finished);"),
@@ -503,6 +503,7 @@ postgres_create_tables (void *cls)
struct GNUNET_PQ_Context *conn;
conn = GNUNET_PQ_connect (pc->connection_cfg_str,
+ NULL,
es,
NULL);
if (NULL == conn)
@@ -1677,6 +1678,7 @@ postgres_get_session (void *cls)
};
db_conn = GNUNET_PQ_connect (pc->connection_cfg_str,
+ NULL,
es,
ps);
}
@@ -5642,6 +5644,7 @@ postgres_gc (void *cls)
conn = GNUNET_PQ_connect (pg->connection_cfg_str,
NULL,
+ NULL,
ps);
}
if (NULL == conn)