#include <config.h>
#include <sys/types.h>
#include <unistd.h>
#include <fcntl.h>
#include <stdlib.h>
#include <errno.h>
#include <poll.h>
#include <assert.h>
#include <qb/qbloop.h>
#include <qb/qblist.h>
#include <qb/qbipcs.h>
#include <qb/qbipc_common.h>
#include <corosync/corotypes.h>
#include <corosync/corodefs.h>
#include <corosync/mar_gen.h>
#include <corosync/ipc_cmap.h>
#include <corosync/logsys.h>
#include <corosync/coroapi.h>
#include <corosync/icmap.h>
#include "service.h"
#include "ipcs_stats.h"
#include "stats.h"
Go to the source code of this file.
◆ ICMAP_VALUETYPE_NOT_EXIST
#define ICMAP_VALUETYPE_NOT_EXIST 0 |
◆ MAX_REQ_EXEC_CMAP_MCAST_ITEMS
#define MAX_REQ_EXEC_CMAP_MCAST_ITEMS 32 |
◆ cmap_iter_handle_t
◆ cmap_track_handle_t
◆ cmap_mcast_reason
Enumerator |
---|
CMAP_MCAST_REASON_SYNC | |
CMAP_MCAST_REASON_NEW_CONFIG_VERSION | |
Definition at line 145 of file exec/cmap.c.
◆ cmap_message_req_types
Enumerator |
---|
MESSAGE_REQ_EXEC_CMAP_MCAST | |
Definition at line 141 of file exec/cmap.c.
◆ cmap_get_service_engine_ver0()
◆ LOGSYS_DECLARE_SUBSYS()
LOGSYS_DECLARE_SUBSYS |
( |
"CMAP" |
| ) |
|
◆ cmap_service_engine
Initial value:= {
.name = "corosync configuration map access",
.priority = 1,
.lib_init_fn = cmap_lib_init_fn,
.lib_exit_fn = cmap_lib_exit_fn,
.lib_engine = cmap_lib_engine,
.exec_init_fn = cmap_exec_init_fn,
.exec_exit_fn = cmap_exec_exit_fn,
.exec_engine = cmap_exec_engine,
.sync_init = cmap_sync_init,
.sync_process = cmap_sync_process,
.sync_activate = cmap_sync_activate,
.sync_abort = cmap_sync_abort
}
Definition at line 263 of file exec/cmap.c.
Referenced by cmap_get_service_engine_ver0().
◆ icmap_map
◆ stats_map
int stats_map_is_key_ro(const char *key_name)
cs_error_t stats_map_set(const char *key_name, const void *value, size_t value_len, icmap_value_types_t type)
The corosync_exec_handler struct.
void icmap_iter_finalize(icmap_iter_t iter)
Finalize iterator.
void stats_map_iter_finalize(icmap_iter_t iter)
cs_error_t icmap_track_delete(icmap_track_t icmap_track)
Remove previously added track.
cs_error_t icmap_get(const char *key_name, void *value, size_t *value_len, icmap_value_types_t *type)
Retrieve value of key key_name and store it in user preallocated value pointer.
The corosync_lib_handler struct.
cs_error_t stats_map_track_add(const char *key_name, int32_t track_type, icmap_notify_fn_t notify_fn, void *user_data, icmap_track_t *icmap_track)
cs_error_t icmap_delete(const char *key_name)
Delete key from map.
const char * icmap_iter_next(icmap_iter_t iter, size_t *value_len, icmap_value_types_t *type)
Return next item in iterator iter.
cs_error_t stats_map_track_delete(icmap_track_t icmap_track)
cs_error_t icmap_set(const char *key_name, const void *value, size_t value_len, icmap_value_types_t type)
Store value with value_len length and type as key_name name in global icmap.
cs_error_t icmap_adjust_int(const char *key_name, int32_t step)
icmap_adjust_int
cs_error_t stats_map_get(const char *key_name, void *value, size_t *value_len, icmap_value_types_t *type)
cs_error_t icmap_track_add(const char *key_name, int32_t track_type, icmap_notify_fn_t notify_fn, void *user_data, icmap_track_t *icmap_track)
Add tracking function for given key_name.
void * stats_map_track_get_user_data(icmap_track_t icmap_track)
icmap_iter_t icmap_iter_init(const char *prefix)
Initialize iterator with given prefix.
int icmap_is_key_ro(const char *key_name)
Check in given key is read only.
cs_error_t stats_map_delete(const char *key_name)
const char * stats_map_iter_next(icmap_iter_t iter, size_t *value_len, icmap_value_types_t *type)
icmap_iter_t stats_map_iter_init(const char *prefix)
cs_error_t stats_map_adjust_int(const char *key_name, int32_t step)
void * icmap_track_get_user_data(icmap_track_t icmap_track)
Return user data associated with given track.