summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2020-04-22 21:21:48 +0200
committerChristian Grothoff <christian@grothoff.org>2020-04-22 21:21:48 +0200
commita039bf4d81b4e2c01da6d21a7e36f209853f0c3f (patch)
treed980ad36ca35d0a59e9169fe521caca15bdbde87
parent092944819d2bf442282f0913c01bf1dc3adb2866 (diff)
downloadexchange-a039bf4d81b4e2c01da6d21a7e36f209853f0c3f.tar.gz
exchange-a039bf4d81b4e2c01da6d21a7e36f209853f0c3f.tar.bz2
exchange-a039bf4d81b4e2c01da6d21a7e36f209853f0c3f.zip
fix #6200
-rw-r--r--src/exchangedb/plugin_exchangedb_postgres.c23
1 files changed, 11 insertions, 12 deletions
diff --git a/src/exchangedb/plugin_exchangedb_postgres.c b/src/exchangedb/plugin_exchangedb_postgres.c
index 5ecefe5e..4f57f32f 100644
--- a/src/exchangedb/plugin_exchangedb_postgres.c
+++ b/src/exchangedb/plugin_exchangedb_postgres.c
@@ -4001,9 +4001,9 @@ struct CoinHistoryContext
struct PostgresClosure *pg;
/**
- * Set to transaction status.
+ * Set to 'true' if the transaction failed.
*/
- enum GNUNET_DB_QueryStatus status;
+ bool failed;
};
@@ -4064,7 +4064,7 @@ add_coin_deposit (void *cls,
{
GNUNET_break (0);
GNUNET_free (deposit);
- chc->status = GNUNET_DB_STATUS_HARD_ERROR;
+ chc->failed = true;
return;
}
}
@@ -4124,7 +4124,7 @@ add_coin_melt (void *cls,
{
GNUNET_break (0);
GNUNET_free (melt);
- chc->status = GNUNET_DB_STATUS_HARD_ERROR;
+ chc->failed = true;
return;
}
}
@@ -4187,7 +4187,7 @@ add_coin_refund (void *cls,
{
GNUNET_break (0);
GNUNET_free (refund);
- chc->status = GNUNET_DB_STATUS_HARD_ERROR;
+ chc->failed = true;
return;
}
}
@@ -4253,7 +4253,7 @@ add_old_coin_recoup (void *cls,
{
GNUNET_break (0);
GNUNET_free (recoup);
- chc->status = GNUNET_DB_STATUS_HARD_ERROR;
+ chc->failed = true;
return;
}
recoup->old_coin_pub = *chc->coin_pub;
@@ -4315,7 +4315,7 @@ add_coin_recoup (void *cls,
{
GNUNET_break (0);
GNUNET_free (recoup);
- chc->status = GNUNET_DB_STATUS_HARD_ERROR;
+ chc->failed = true;
return;
}
}
@@ -4381,7 +4381,7 @@ add_coin_recoup_refresh (void *cls,
{
GNUNET_break (0);
GNUNET_free (recoup);
- chc->status = GNUNET_DB_STATUS_HARD_ERROR;
+ chc->failed = true;
return;
}
recoup->coin.coin_pub = *chc->coin_pub;
@@ -4474,7 +4474,6 @@ postgres_get_coin_transactions (
const struct Work *work;
struct CoinHistoryContext chc = {
.head = NULL,
- .status = GNUNET_DB_STATUS_SUCCESS_ONE_RESULT,
.coin_pub = coin_pub,
.session = session,
.pg = pg,
@@ -4493,14 +4492,14 @@ postgres_get_coin_transactions (
work[i].cb,
&chc);
if ( (0 > qs) ||
- (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT != chc.status) )
+ (chc.failed) )
{
if (NULL != chc.head)
common_free_coin_transaction_list (cls,
chc.head);
*tlp = NULL;
- if (GNUNET_DB_STATUS_SUCCESS_ONE_RESULT != chc.status)
- qs = chc.status;
+ if (chc.failed)
+ qs = GNUNET_DB_STATUS_HARD_ERROR;
return qs;
}
}