Revert "List pagination locking for state-data changes"

This reverts commit eea6d549f6.
This commit is contained in:
Olof hagsand 2021-10-30 15:49:23 +02:00
parent eea6d549f6
commit 52744c9301
5 changed files with 19 additions and 25 deletions

View file

@ -592,16 +592,11 @@ get_list_pagination(clicon_handle h,
#endif #endif
} }
else {/* Check if running locked (by this session) */ else {/* Check if running locked (by this session) */
if ((iddb = xmldb_islocked(h, PAGINATE_STATE_LOCK)) != 0){ if ((iddb = xmldb_islocked(h, "running")) != 0 &&
if (iddb == ce->ce_id) iddb == ce->ce_id)
locked = 1;
else
locked = 0;
}
else {
xmldb_lock(h, PAGINATE_STATE_LOCK, ce->ce_id);
locked = 1; locked = 1;
} else
locked = 0;
if ((ret = clixon_pagination_cb_call(h, xpath, locked, if ((ret = clixon_pagination_cb_call(h, xpath, locked,
offset, limit, offset, limit,
xret)) < 0) xret)) < 0)

View file

@ -38,11 +38,6 @@
#ifndef _CLIXON_BACKEND_PLUGIN_H_ #ifndef _CLIXON_BACKEND_PLUGIN_H_
#define _CLIXON_BACKEND_PLUGIN_H_ #define _CLIXON_BACKEND_PLUGIN_H_
/*
* Constants
*/
#define PAGINATE_STATE_LOCK "paginate-state-lock"
/* /*
* Types * Types
*/ */

View file

@ -309,16 +309,15 @@ pagination_limit(pagination_data pd)
return ((pagination_data_t *)pd)->pd_limit; return ((pagination_data_t *)pd)->pd_limit;
} }
/*! Get pagination data: locked parameter for state data /*! Get pagination data: locked parameter
* *
* A "paginate" lock is set for a specific session when list-pagination is in progress. * Pagination can use a lock/transaction mechanism
* If locking is set, the pagination is part of a session transaction and the plugin may * If locking is not used, the plugin cannot expect more pagination calls, and no state or
* cache state (such as a cache) and can expect more pagination calls until the "paginate" * caching should be used
* db-lock is released. * If locking is used, the pagination is part of a session transaction and the plugin may cache
* * state (such as a cache) and can expect more pagination calls until the running db-lock is
* If you want to do the same for config data, it is recommended to use lock-db on * released, (see ca_lockdb)
* the appropriate database, but this risks of indefinite blocking, as long as the * The transaction is the regular lock/unlock db of running-db of a specific session.
* session endures.
* @param[in] pd Pagination userdata * @param[in] pd Pagination userdata
* @retval locked 0: unlocked/stateless 1: locked by this caller * @retval locked 0: unlocked/stateless 1: locked by this caller
*/ */

View file

@ -919,6 +919,7 @@ cli_pagination(clicon_handle h,
uint32_t limit = 0; uint32_t limit = 0;
cxobj **xvec = NULL; cxobj **xvec = NULL;
size_t xlen; size_t xlen;
int locked = 0;
if (cvec_len(argv) != 5){ if (cvec_len(argv) != 5){
clicon_err(OE_PLUGIN, 0, "Expected usage: <xpath> <prefix> <namespace> <format> <limit>"); clicon_err(OE_PLUGIN, 0, "Expected usage: <xpath> <prefix> <namespace> <format> <limit>");
@ -948,6 +949,9 @@ cli_pagination(clicon_handle h,
} }
if ((nsc = xml_nsctx_init(prefix, namespace)) == NULL) if ((nsc = xml_nsctx_init(prefix, namespace)) == NULL)
goto done; goto done;
if (clicon_rpc_lock(h, "running") < 0)
goto done;
locked++;
for (i = 0;; i++){ for (i = 0;; i++){
if (clicon_rpc_get_pageable_list(h, "running", xpath, nsc, if (clicon_rpc_get_pageable_list(h, "running", xpath, nsc,
CONTENT_ALL, CONTENT_ALL,
@ -1000,6 +1004,8 @@ cli_pagination(clicon_handle h,
} /* for i */ } /* for i */
retval = 0; retval = 0;
done: done:
if (locked)
clicon_rpc_unlock(h, "running");
if (xvec) if (xvec)
free(xvec); free(xvec);
if (xret) if (xret)

View file

@ -545,7 +545,6 @@ example_statefile(clicon_handle h,
* @param[in] xpath Registered XPath using canonical prefixes * @param[in] xpath Registered XPath using canonical prefixes
* @param[in] userargs Per-call user arguments * @param[in] userargs Per-call user arguments
* @param[in] arg Per-path user argument * @param[in] arg Per-path user argument
* @see example_lockdb
*/ */
int int
example_pagination(void *h0, example_pagination(void *h0,
@ -668,7 +667,7 @@ example_lockdb(clicon_handle h,
/* Part of cached pagination example /* Part of cached pagination example
*/ */
if (strcmp(db, PAGINATE_STATE_LOCK) == 0 && lock == 0 && if (strcmp(db, "running") == 0 && lock == 0 &&
_state && _state_file && _state_file_cached && _state_file_transaction){ _state && _state_file && _state_file_cached && _state_file_transaction){
if (_state_xml_cache){ if (_state_xml_cache){
xml_free(_state_xml_cache); xml_free(_state_xml_cache);