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

allow double-rollback, warn on rollback+commit

Browse Source
This commit is contained in:
Christian Grothoff 2022-06-07 15:59:35 +02:00
parent b9a30d29cb
commit f0bcbf6586
No known key found for this signature in database
GPG Key ID: 939E6BE1E29FC3CC
1 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/exchangedb/plugin_exchangedb_postgres.c
View File

@ -4165,6 +4165,7 @@ postgres_start (void *cls,
GNUNET_PQ_EXECUTE_STATEMENT_END GNUNET_PQ_EXECUTE_STATEMENT_END
}; };
GNUNET_assert (NULL != name);
if (GNUNET_SYSERR == if (GNUNET_SYSERR ==
postgres_preflight (pg)) postgres_preflight (pg))
return GNUNET_SYSERR; return GNUNET_SYSERR;
@ -4202,6 +4203,7 @@ postgres_start_read_committed (void *cls,
GNUNET_PQ_EXECUTE_STATEMENT_END GNUNET_PQ_EXECUTE_STATEMENT_END
}; };
GNUNET_assert (NULL != name);
if (GNUNET_SYSERR == if (GNUNET_SYSERR ==
postgres_preflight (pg)) postgres_preflight (pg))
return GNUNET_SYSERR; return GNUNET_SYSERR;
@ -4235,9 +4237,14 @@ postgres_rollback (void *cls)
GNUNET_PQ_EXECUTE_STATEMENT_END GNUNET_PQ_EXECUTE_STATEMENT_END
}; };
if (NULL == pg->transaction_name)
{
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG, GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Rolling back transaction on %p\n", "Skipping rollback, no transaction active\n");
pg->conn); return;
}
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Rolling back transaction\n");
GNUNET_break (GNUNET_OK == GNUNET_break (GNUNET_OK ==
GNUNET_PQ_exec_statements (pg->conn, GNUNET_PQ_exec_statements (pg->conn,
es)); es));
@ -4260,6 +4267,10 @@ postgres_commit (void *cls)
}; };
enum GNUNET_DB_QueryStatus qs; enum GNUNET_DB_QueryStatus qs;
GNUNET_break (NULL != pg->transaction_name);
GNUNET_log (GNUNET_ERROR_TYPE_DEBUG,
"Committing transaction `%s'\n",
pg->transaction_name);
qs = GNUNET_PQ_eval_prepared_non_select (pg->conn, qs = GNUNET_PQ_eval_prepared_non_select (pg->conn,
"do_commit", "do_commit",
params); params);