rollback transaction to end transaction scope before releasing the shard (fixes #7216)
This commit is contained in:
parent
caf66486e7
commit
6c66f6f5cf
@ -453,6 +453,7 @@ run_aggregation (void *cls)
|
|||||||
au_active.payto_uri);
|
au_active.payto_uri);
|
||||||
global_ret = EXIT_FAILURE;
|
global_ret = EXIT_FAILURE;
|
||||||
GNUNET_SCHEDULER_shutdown ();
|
GNUNET_SCHEDULER_shutdown ();
|
||||||
|
db_plugin->rollback (db_plugin->cls);
|
||||||
release_shard (s);
|
release_shard (s);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@ -477,6 +478,7 @@ run_aggregation (void *cls)
|
|||||||
GNUNET_TIME_timestamp2s (au_active.execution_time));
|
GNUNET_TIME_timestamp2s (au_active.execution_time));
|
||||||
global_ret = EXIT_FAILURE;
|
global_ret = EXIT_FAILURE;
|
||||||
GNUNET_SCHEDULER_shutdown ();
|
GNUNET_SCHEDULER_shutdown ();
|
||||||
|
db_plugin->rollback (db_plugin->cls);
|
||||||
release_shard (s);
|
release_shard (s);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
@ -707,6 +709,7 @@ run_aggregation (void *cls)
|
|||||||
GNUNET_break (0);
|
GNUNET_break (0);
|
||||||
global_ret = EXIT_FAILURE;
|
global_ret = EXIT_FAILURE;
|
||||||
GNUNET_SCHEDULER_shutdown ();
|
GNUNET_SCHEDULER_shutdown ();
|
||||||
|
db_plugin->rollback (db_plugin->cls); /* just in case */
|
||||||
release_shard (s);
|
release_shard (s);
|
||||||
return;
|
return;
|
||||||
case GNUNET_DB_STATUS_SUCCESS_NO_RESULTS:
|
case GNUNET_DB_STATUS_SUCCESS_NO_RESULTS:
|
||||||
@ -720,6 +723,7 @@ run_aggregation (void *cls)
|
|||||||
GNUNET_break (0);
|
GNUNET_break (0);
|
||||||
global_ret = EXIT_FAILURE;
|
global_ret = EXIT_FAILURE;
|
||||||
GNUNET_SCHEDULER_shutdown ();
|
GNUNET_SCHEDULER_shutdown ();
|
||||||
|
db_plugin->rollback (db_plugin->cls); /* just in case */
|
||||||
release_shard (s);
|
release_shard (s);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user