aboutsummaryrefslogtreecommitdiff
path: root/src/exchangedb/pg_abort_shard.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2023-01-06 15:26:10 +0100
committerChristian Grothoff <christian@grothoff.org>2023-01-06 15:26:10 +0100
commitade221f9741aba5c8b3efdf022fd95b9f363b1d8 (patch)
tree23d65dfc7dd8cb7a05b80150e316a8b96a821284 /src/exchangedb/pg_abort_shard.c
parent62a6142a8d69984cf852af3e0ef402d23c07ac85 (diff)
downloadexchange-ade221f9741aba5c8b3efdf022fd95b9f363b1d8.tar.xz
-fix crash in wirewatch if badly configured
Diffstat (limited to 'src/exchangedb/pg_abort_shard.c')
-rw-r--r--src/exchangedb/pg_abort_shard.c13
1 files changed, 6 insertions, 7 deletions
diff --git a/src/exchangedb/pg_abort_shard.c b/src/exchangedb/pg_abort_shard.c
index de10f7d3f..d04680a81 100644
--- a/src/exchangedb/pg_abort_shard.c
+++ b/src/exchangedb/pg_abort_shard.c
@@ -28,9 +28,9 @@
enum GNUNET_DB_QueryStatus
TEH_PG_abort_shard (void *cls,
- const char *job_name,
- uint64_t start_row,
- uint64_t end_row)
+ const char *job_name,
+ uint64_t start_row,
+ uint64_t end_row)
{
struct PostgresClosure *pg = cls;
struct GNUNET_PQ_QueryParam params[] = {
@@ -40,14 +40,13 @@ TEH_PG_abort_shard (void *cls,
GNUNET_PQ_query_param_end
};
-
PREPARE (pg,
"abort_shard",
"UPDATE work_shards"
" SET last_attempt=0"
- " WHERE job_name = $1 "
- " AND start_row = $2 "
- " AND end_row = $3;");
+ " WHERE job_name=$1"
+ " AND start_row=$2"
+ " AND end_row=$3;");
return GNUNET_PQ_eval_prepared_non_select (pg->conn,
"abort_shard",
params);