experiments/clixon
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

add commit failed cb (#550)

Browse source 
* add revert failed cb

* add revert failed cb

* add commit failed cb

* add commit failed cb
This commit is contained in:
EvgeniiVR 2024-09-18 21:51:09 +03:00 • committed by GitHub
parent c02630c83b
commit 7ea344c51f
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 18 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

16
apps/backend/backend_plugin.c
View file

@ -806,6 +806,20 @@ plugin_transaction_revert_all(clixon_handle h,
return retval; /* ignore errors */ return retval; /* ignore errors */
} }
/*! Revert a commit for failed plugin
* The commit failed is called for only failed plugin before revert all cb.
*/
static int
plugin_transaction_commit_failed(clixon_plugin_t *cp,
clixon_handle h,
transaction_data_t *td)
{
trans_cb_t *fn;
if ((fn = clixon_plugin_api_get(cp)->ca_trans_commit_failed) != NULL)
return plugin_transaction_call_one(h, cp, fn, __FUNCTION__, td);
return 0;
}
/*! Call single plugin transaction_commit() in a commit transaction /*! Call single plugin transaction_commit() in a commit transaction
* *
@ -848,6 +862,8 @@ plugin_transaction_commit_all(clixon_handle h,
while ((cp = clixon_plugin_each(h, cp)) != NULL) { while ((cp = clixon_plugin_each(h, cp)) != NULL) {
i++; i++;
if (plugin_transaction_commit_one(cp, h, td) < 0){ if (plugin_transaction_commit_one(cp, h, td) < 0){
/* First make an effort ro revert transaction for the failed plugin */
plugin_transaction_commit_failed(cp, h, td);
/* Make an effort to revert transaction */ /* Make an effort to revert transaction */
plugin_transaction_revert_all(h, td, i-1); plugin_transaction_revert_all(h, td, i-1);
goto done; goto done;

2
lib/clixon/clixon_plugin.h
View file

@ -402,6 +402,7 @@ struct clixon_plugin_api{
trans_cb_t *cb_trans_complete; /* Transaction validation complete */ trans_cb_t *cb_trans_complete; /* Transaction validation complete */
trans_cb_t *cb_trans_commit; /* Transaction commit */ trans_cb_t *cb_trans_commit; /* Transaction commit */
trans_cb_t *cb_trans_commit_done; /* Transaction when commit done */ trans_cb_t *cb_trans_commit_done; /* Transaction when commit done */
trans_cb_t *cb_trans_commit_failed; /* Transaction commit failed*/
trans_cb_t *cb_trans_revert; /* Transaction revert */ trans_cb_t *cb_trans_revert; /* Transaction revert */
trans_cb_t *cb_trans_end; /* Transaction completed */ trans_cb_t *cb_trans_end; /* Transaction completed */
trans_cb_t *cb_trans_abort; /* Transaction aborted */ trans_cb_t *cb_trans_abort; /* Transaction aborted */
@ -424,6 +425,7 @@ struct clixon_plugin_api{
#define ca_trans_complete u.cau_backend.cb_trans_complete #define ca_trans_complete u.cau_backend.cb_trans_complete
#define ca_trans_commit u.cau_backend.cb_trans_commit #define ca_trans_commit u.cau_backend.cb_trans_commit
#define ca_trans_commit_done u.cau_backend.cb_trans_commit_done #define ca_trans_commit_done u.cau_backend.cb_trans_commit_done
#define ca_trans_commit_failed u.cau_backend.cb_trans_commit_failed
#define ca_trans_revert u.cau_backend.cb_trans_revert #define ca_trans_revert u.cau_backend.cb_trans_revert
#define ca_trans_end u.cau_backend.cb_trans_end #define ca_trans_end u.cau_backend.cb_trans_end
#define ca_trans_abort u.cau_backend.cb_trans_abort #define ca_trans_abort u.cau_backend.cb_trans_abort