diff options
| author | Christian Grothoff <christian@grothoff.org> | 2021-08-23 00:17:58 +0200 |
|---|---|---|
| committer | Christian Grothoff <christian@grothoff.org> | 2021-08-23 00:18:03 +0200 |
| commit | 6dac69c96aaf84c32802ac8140101df3b8dea60d (patch) | |
| tree | 66be3d4b882d54117999fd96d89022c7c0f2d814 /src/stasis/plugin_anastasis_postgres.c | |
| parent | 7e4bfbf1c17a5faf04b94e7db04e5536617a4a92 (diff) | |
| download | anastasis-6dac69c96aaf84c32802ac8140101df3b8dea60d.tar.gz anastasis-6dac69c96aaf84c32802ac8140101df3b8dea60d.tar.bz2 anastasis-6dac69c96aaf84c32802ac8140101df3b8dea60d.zip | |
adjust to latest GNUnet API changes
Diffstat (limited to 'src/stasis/plugin_anastasis_postgres.c')
| -rw-r--r-- | src/stasis/plugin_anastasis_postgres.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/stasis/plugin_anastasis_postgres.c b/src/stasis/plugin_anastasis_postgres.c index 4271f53..b7fda3d 100644 --- a/src/stasis/plugin_anastasis_postgres.c +++ b/src/stasis/plugin_anastasis_postgres.c @@ -230,6 +230,7 @@ commit_transaction (void *cls) * * @param cls database context to use * @param es specification of the event to listen for + * @param timeout how long to wait for the event * @param cb function to call when the event happens, possibly * multiple times (until cancel is invoked) * @param cb_cls closure for @a cb @@ -238,6 +239,7 @@ commit_transaction (void *cls) static struct GNUNET_DB_EventHandler * postgres_event_listen (void *cls, const struct GNUNET_DB_EventHeaderP *es, + struct GNUNET_TIME_Relative timeout, GNUNET_DB_EventCallback cb, void *cb_cls) { @@ -245,6 +247,7 @@ postgres_event_listen (void *cls, return GNUNET_PQ_event_listen (pg->conn, es, + timeout, cb, cb_cls); } @@ -2635,7 +2638,6 @@ libanastasis_plugin_db_postgres_init (void *cls) GNUNET_free (pg); return NULL; } - GNUNET_PQ_event_scheduler_start (pg->conn); plugin = GNUNET_new (struct ANASTASIS_DatabasePlugin); plugin->cls = pg; plugin->drop_tables = &postgres_drop_tables; @@ -2694,7 +2696,6 @@ libanastasis_plugin_db_postgres_done (void *cls) struct ANASTASIS_DatabasePlugin *plugin = cls; struct PostgresClosure *pg = plugin->cls; - GNUNET_PQ_event_scheduler_stop (pg->conn); GNUNET_PQ_disconnect (pg->conn); GNUNET_free (pg->currency); GNUNET_free (pg); |