diff options
| author | Christian Grothoff <christian@grothoff.org> | 2020-01-17 02:24:14 +0100 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2020-01-17 02:24:21 +0100 |
| commit | da0a2f39d0ae59036e9bb08f7ae9ef02cfacc3c9 (patch) | |
| tree | 0cf76d477e6c7eed8ae5c245f05cb67ee5b81aa5 | |
| parent | cc862fb2795aefed25b1a7b4d1dcac750f648f1b (diff) | |
GNUnet PQ API change
| -rw-r--r-- | src/auditordb/plugin_auditordb_postgres.c | 4 | ||||
| -rw-r--r-- | src/exchangedb/plugin_exchangedb_postgres.c | 5 |
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) |