taler/exchange
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

GNUnet PQ API change

Browse Source
This commit is contained in:
Christian Grothoff 2020-01-17 02:24:14 +01:00
parent cc862fb279
commit da0a2f39d0
No known key found for this signature in database
GPG Key ID: 939E6BE1E29FC3CC
2 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/auditordb/plugin_auditordb_postgres.c
View File

@ -160,6 +160,7 @@ postgres_drop_tables (void *cls,
int ret; int ret;
conn = GNUNET_PQ_connect (pc->connection_cfg_str, conn = GNUNET_PQ_connect (pc->connection_cfg_str,
NULL,
es, es,
NULL); NULL);
if (NULL == conn) if (NULL == conn)
@ -407,6 +408,7 @@ postgres_create_tables (void *cls)
struct GNUNET_PQ_Context *conn; struct GNUNET_PQ_Context *conn;
conn = GNUNET_PQ_connect (pc->connection_cfg_str, conn = GNUNET_PQ_connect (pc->connection_cfg_str,
NULL,
es, es,
NULL); NULL);
if (NULL == conn) if (NULL == conn)
@ -991,6 +993,7 @@ postgres_get_session (void *cls)
return session; return session;
} }
db_conn = GNUNET_PQ_connect (pc->connection_cfg_str, db_conn = GNUNET_PQ_connect (pc->connection_cfg_str,
NULL,
NULL, NULL,
ps); ps);
if (NULL == db_conn) if (NULL == db_conn)
@ -1151,6 +1154,7 @@ postgres_gc (void *cls)
now = GNUNET_TIME_absolute_get (); now = GNUNET_TIME_absolute_get ();
conn = GNUNET_PQ_connect (pc->connection_cfg_str, conn = GNUNET_PQ_connect (pc->connection_cfg_str,
NULL,
NULL, NULL,
ps); ps);
if (NULL == conn) if (NULL == conn)

5
src/exchangedb/plugin_exchangedb_postgres.c
View File

@ -172,6 +172,7 @@ postgres_drop_tables (void *cls)
struct GNUNET_PQ_Context *conn; struct GNUNET_PQ_Context *conn;
conn = GNUNET_PQ_connect (pc->connection_cfg_str, conn = GNUNET_PQ_connect (pc->connection_cfg_str,
NULL,
es, es,
NULL); NULL);
if (NULL == conn) if (NULL == conn)
@ -494,7 +495,6 @@ postgres_create_tables (void *cls)
",buf BYTEA NOT NULL" ",buf BYTEA NOT NULL"
");"), ");"),
/* Index for wire_prepare_data_get and gc_prewire statement */ /* Index for wire_prepare_data_get and gc_prewire statement */
GNUNET_PQ_make_try_execute ("CREATE INDEX prepare_iteration_index " GNUNET_PQ_make_try_execute ("CREATE INDEX prepare_iteration_index "
"ON prewire(finished);"), "ON prewire(finished);"),
@ -503,6 +503,7 @@ postgres_create_tables (void *cls)
struct GNUNET_PQ_Context *conn; struct GNUNET_PQ_Context *conn;
conn = GNUNET_PQ_connect (pc->connection_cfg_str, conn = GNUNET_PQ_connect (pc->connection_cfg_str,
NULL,
es, es,
NULL); NULL);
if (NULL == conn) if (NULL == conn)
@ -1677,6 +1678,7 @@ postgres_get_session (void *cls)
}; };
db_conn = GNUNET_PQ_connect (pc->connection_cfg_str, db_conn = GNUNET_PQ_connect (pc->connection_cfg_str,
NULL,
es, es,
ps); ps);
} }
@ -5641,6 +5643,7 @@ postgres_gc (void *cls)
}; };
conn = GNUNET_PQ_connect (pg->connection_cfg_str, conn = GNUNET_PQ_connect (pg->connection_cfg_str,
NULL,
NULL, NULL,
ps); ps);
} }