diff options
author | Christian Grothoff <christian@grothoff.org> | 2021-12-26 13:05:39 +0100 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2021-12-26 13:05:39 +0100 |
commit | 070f442a1182c7c2a09c42e94ce202509ade1b77 (patch) | |
tree | 980a953edd7e56b2624f1757a4b85c02d6bd613b /src/exchangedb | |
parent | e7d4183d1c82e600aa69fa48145115f4abc02aac (diff) | |
download | exchange-070f442a1182c7c2a09c42e94ce202509ade1b77.tar.xz |
resolve #7124: ensure -s also deletes work_shards
Diffstat (limited to 'src/exchangedb')
-rw-r--r-- | src/exchangedb/plugin_exchangedb_postgres.c | 22 |
1 files changed, 9 insertions, 13 deletions
diff --git a/src/exchangedb/plugin_exchangedb_postgres.c b/src/exchangedb/plugin_exchangedb_postgres.c index 6ef1bb030..97782bd17 100644 --- a/src/exchangedb/plugin_exchangedb_postgres.c +++ b/src/exchangedb/plugin_exchangedb_postgres.c @@ -2743,11 +2743,6 @@ prepare_statements (struct PostgresClosure *pg) " AND start_row=$2" " AND end_row=$3", 3), - /* Used in #postgres_delete_revolving_shards() */ - GNUNET_PQ_make_prepare ( - "delete_revolving_shards", - "DELETE FROM revolving_work_shards", - 0), GNUNET_PQ_PREPARED_STATEMENT_END }; @@ -11385,16 +11380,17 @@ postgres_release_revolving_shard (void *cls, * @return transaction status code */ enum GNUNET_DB_QueryStatus -postgres_delete_revolving_shards (void *cls) +postgres_delete_shard_locks (void *cls) { struct PostgresClosure *pg = cls; - struct GNUNET_PQ_QueryParam params[] = { - GNUNET_PQ_query_param_end + struct GNUNET_PQ_ExecuteStatement es[] = { + GNUNET_PQ_make_execute ("DELETE FROM work_shards;"), + GNUNET_PQ_make_execute ("DELETE FROM revolving_work_shards;"), + GNUNET_PQ_EXECUTE_STATEMENT_END }; - return GNUNET_PQ_eval_prepared_non_select (pg->conn, - "delete_revolving_shards", - params); + return GNUNET_PQ_exec_statements (pg->conn, + es); } @@ -11630,8 +11626,8 @@ libtaler_plugin_exchangedb_postgres_init (void *cls) = &postgres_begin_revolving_shard; plugin->release_revolving_shard = &postgres_release_revolving_shard; - plugin->delete_revolving_shards - = &postgres_delete_revolving_shards; + plugin->delete_shard_locks + = &postgres_delete_shard_locks; return plugin; } |