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

Remove preflight checks where redundant.

Browse Source
This commit is contained in:
Marcello Stanisci 2020-01-15 14:34:13 +01:00
parent 0c37bb0f90
commit d822035216
No known key found for this signature in database
GPG Key ID: 8D526861953F4C0F
3 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/auditor/taler-auditor.c
View File

@ -1120,6 +1120,7 @@ handle_reserve_out (void *cls,
(void) denom_sig; /* FIXME: checked elsewhere? If so, potential for (void) denom_sig; /* FIXME: checked elsewhere? If so, potential for
optimization to simply not fetch this value from DB! */ optimization to simply not fetch this value from DB! */
/* should be monotonically increasing */ /* should be monotonically increasing */
GNUNET_assert (rowid >= ppr.last_reserve_out_serial_id); GNUNET_assert (rowid >= ppr.last_reserve_out_serial_id);
ppr.last_reserve_out_serial_id = rowid + 1; ppr.last_reserve_out_serial_id = rowid + 1;

5
src/exchange/taler-exchange-aggregator.c
View File

@ -1247,8 +1247,7 @@ run_reserve_closures (void *cls)
GNUNET_SCHEDULER_shutdown (); GNUNET_SCHEDULER_shutdown ();
return; return;
} }
db_plugin->preflight (db_plugin->cls,
session);
if (GNUNET_OK != if (GNUNET_OK !=
db_plugin->start (db_plugin->cls, db_plugin->start (db_plugin->cls,
session, session,
@ -1798,8 +1797,6 @@ run_transfers (void *cls)
GNUNET_SCHEDULER_shutdown (); GNUNET_SCHEDULER_shutdown ();
return; return;
} }
db_plugin->preflight (db_plugin->cls,
session);
if (GNUNET_OK != if (GNUNET_OK !=
db_plugin->start (db_plugin->cls, db_plugin->start (db_plugin->cls,
session, session,

2
src/exchange/taler-exchange-httpd_db.c
View File

@ -108,8 +108,6 @@ TEH_DB_run_transaction (struct MHD_Connection *connection,
"could not establish database session"); "could not establish database session");
return GNUNET_SYSERR; return GNUNET_SYSERR;
} }
TEH_plugin->preflight (TEH_plugin->cls,
session);
for (unsigned int retries = 0; retries < MAX_TRANSACTION_COMMIT_RETRIES; for (unsigned int retries = 0; retries < MAX_TRANSACTION_COMMIT_RETRIES;
retries++) retries++)
{ {