diff options
author | Christian Grothoff <christian@grothoff.org> | 2021-10-13 15:51:22 +0200 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2021-10-13 15:51:26 +0200 |
commit | 71c08423cf2aea30c4a4d06fa8f69ebb286fb050 (patch) | |
tree | ee106c7577ae059d292c9deef0c61aca155ce63e /src/stasis/plugin_anastasis_postgres.c | |
parent | b37e1bfd281140cd460c1cc300e9467c7f9adf44 (diff) | |
download | anastasis-71c08423cf2aea30c4a4d06fa8f69ebb286fb050.tar.gz anastasis-71c08423cf2aea30c4a4d06fa8f69ebb286fb050.tar.bz2 anastasis-71c08423cf2aea30c4a4d06fa8f69ebb286fb050.zip |
-more logging
Diffstat (limited to 'src/stasis/plugin_anastasis_postgres.c')
-rw-r--r-- | src/stasis/plugin_anastasis_postgres.c | 21 |
1 files changed, 14 insertions, 7 deletions
diff --git a/src/stasis/plugin_anastasis_postgres.c b/src/stasis/plugin_anastasis_postgres.c index b1be081..b0b8f96 100644 --- a/src/stasis/plugin_anastasis_postgres.c +++ b/src/stasis/plugin_anastasis_postgres.c @@ -646,7 +646,8 @@ begin_transaction (void *cls, }; check_connection (pg); - postgres_preflight (pg); + GNUNET_break (GNUNET_OK == + postgres_preflight (pg)); pg->transaction_name = name; if (GNUNET_OK != GNUNET_PQ_exec_statements (pg->conn, @@ -802,7 +803,8 @@ postgres_gc (void *cls, enum GNUNET_DB_QueryStatus qs; check_connection (pg); - postgres_preflight (pg); + GNUNET_break (GNUNET_OK == + postgres_preflight (pg)); qs = GNUNET_PQ_eval_prepared_non_select (pg->conn, "gc_accounts", params); @@ -843,7 +845,8 @@ postgres_store_recovery_document ( enum GNUNET_DB_QueryStatus qs; check_connection (pg); - postgres_preflight (pg); + GNUNET_break (GNUNET_OK == + postgres_preflight (pg)); for (unsigned int retry = 0; retry<MAX_RETRIES; retry++) { if (GNUNET_OK != @@ -1407,7 +1410,8 @@ postgres_record_recdoc_payment ( enum GNUNET_DB_QueryStatus qs; check_connection (pg); - postgres_preflight (pg); + GNUNET_break (GNUNET_OK == + postgres_preflight (pg)); /* because of constraint at user_id, first we have to verify if user exists, and if not, create one */ @@ -2057,7 +2061,8 @@ postgres_lookup_account ( enum GNUNET_DB_QueryStatus qs; check_connection (pg); - postgres_preflight (pg); + GNUNET_break (GNUNET_OK == + postgres_preflight (pg)); { struct GNUNET_PQ_ResultSpec rs[] = { GNUNET_PQ_result_spec_absolute_time ("expiration_date", @@ -2165,7 +2170,8 @@ postgres_get_latest_recovery_document ( }; check_connection (pg); - postgres_preflight (pg); + GNUNET_break (GNUNET_OK == + postgres_preflight (pg)); return GNUNET_PQ_eval_prepared_singleton_select (pg->conn, "latest_recoverydocument_select", params, @@ -2740,7 +2746,8 @@ postgres_challenge_gc (void *cls) }; check_connection (pg); - postgres_preflight (pg); + GNUNET_break (GNUNET_OK == + postgres_preflight (pg)); return GNUNET_PQ_eval_prepared_non_select (pg->conn, "gc_challengecodes", params); |