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

-log origin of serialization errors

Browse Source
This commit is contained in:
Christian Grothoff 2023-01-06 13:12:18 +01:00
parent 865f3aca19
commit 4d00c34829
No known key found for this signature in database
GPG Key ID: 939E6BE1E29FC3CC
2 changed files with 18 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
contrib/gana

@ -1 +1 @@
Subproject commit 3e659ed54023230dd45dbec5664f176e1763d260 Subproject commit df1d198918cbdd03c18723d818979c8d09f8f231

28
src/exchangedb/pg_begin_shard.c
View File

@ -28,13 +28,14 @@
#include "pg_rollback.h" #include "pg_rollback.h"
#include "pg_commit.h" #include "pg_commit.h"
enum GNUNET_DB_QueryStatus enum GNUNET_DB_QueryStatus
TEH_PG_begin_shard (void *cls, TEH_PG_begin_shard (void *cls,
const char *job_name, const char *job_name,
struct GNUNET_TIME_Relative delay, struct GNUNET_TIME_Relative delay,
uint64_t shard_size, uint64_t shard_size,
uint64_t *start_row, uint64_t *start_row,
uint64_t *end_row) uint64_t *end_row)
{ {
struct PostgresClosure *pg = cls; struct PostgresClosure *pg = cls;
@ -42,7 +43,7 @@ TEH_PG_begin_shard (void *cls,
{ {
if (GNUNET_OK != if (GNUNET_OK !=
TEH_PG_start (pg, TEH_PG_start (pg,
"begin_shard")) "begin_shard"))
{ {
GNUNET_break (0); GNUNET_break (0);
return GNUNET_DB_STATUS_HARD_ERROR; return GNUNET_DB_STATUS_HARD_ERROR;
@ -65,7 +66,6 @@ TEH_PG_begin_shard (void *cls,
}; };
past = GNUNET_TIME_absolute_get (); past = GNUNET_TIME_absolute_get ();
PREPARE (pg, PREPARE (pg,
"get_open_shard", "get_open_shard",
"SELECT" "SELECT"
@ -77,7 +77,6 @@ TEH_PG_begin_shard (void *cls,
" AND last_attempt<$2" " AND last_attempt<$2"
" ORDER BY last_attempt ASC" " ORDER BY last_attempt ASC"
" LIMIT 1;"); " LIMIT 1;");
qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn, qs = GNUNET_PQ_eval_prepared_singleton_select (pg->conn,
"get_open_shard", "get_open_shard",
params, params,
@ -89,6 +88,8 @@ TEH_PG_begin_shard (void *cls,
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
return qs; return qs;
case GNUNET_DB_STATUS_SOFT_ERROR: case GNUNET_DB_STATUS_SOFT_ERROR:
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"Serialization error on getting open shard\n");
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
continue; continue;
case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT: case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT:
@ -104,8 +105,6 @@ TEH_PG_begin_shard (void *cls,
}; };
now = GNUNET_TIME_relative_to_absolute (delay); now = GNUNET_TIME_relative_to_absolute (delay);
PREPARE (pg, PREPARE (pg,
"reclaim_shard", "reclaim_shard",
"UPDATE work_shards" "UPDATE work_shards"
@ -113,7 +112,6 @@ TEH_PG_begin_shard (void *cls,
" WHERE job_name=$1" " WHERE job_name=$1"
" AND start_row=$3" " AND start_row=$3"
" AND end_row=$4"); " AND end_row=$4");
qs = GNUNET_PQ_eval_prepared_non_select (pg->conn, qs = GNUNET_PQ_eval_prepared_non_select (pg->conn,
"reclaim_shard", "reclaim_shard",
params); params);
@ -124,6 +122,8 @@ TEH_PG_begin_shard (void *cls,
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
return qs; return qs;
case GNUNET_DB_STATUS_SOFT_ERROR: case GNUNET_DB_STATUS_SOFT_ERROR:
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"Serialization error on claiming open shard\n");
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
continue; continue;
case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT: case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT:
@ -172,6 +172,8 @@ TEH_PG_begin_shard (void *cls,
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
return qs; return qs;
case GNUNET_DB_STATUS_SOFT_ERROR: case GNUNET_DB_STATUS_SOFT_ERROR:
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"Serialization error on getting last shard\n");
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
continue; continue;
case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT: case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT:
@ -220,6 +222,8 @@ TEH_PG_begin_shard (void *cls,
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
return qs; return qs;
case GNUNET_DB_STATUS_SOFT_ERROR: case GNUNET_DB_STATUS_SOFT_ERROR:
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"Serialization error on claiming next shard\n");
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
continue; continue;
case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT: case GNUNET_DB_STATUS_SUCCESS_ONE_RESULT:
@ -246,6 +250,8 @@ commit:
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
return qs; return qs;
case GNUNET_DB_STATUS_SOFT_ERROR: case GNUNET_DB_STATUS_SOFT_ERROR:
GNUNET_log (GNUNET_ERROR_TYPE_WARNING,
"Serialization error on commit for beginning shard\n");
TEH_PG_rollback (pg); TEH_PG_rollback (pg);
continue; continue;
case GNUNET_DB_STATUS_SUCCESS_NO_RESULTS: case GNUNET_DB_STATUS_SUCCESS_NO_RESULTS: