37 #include <sys/types.h>
45 #include <qb/qbloop.h>
46 #include <qb/qblist.h>
47 #include <qb/qbipcs.h>
48 #include <qb/qbipc_common.h>
64 #define MAX_REQ_EXEC_CMAP_MCAST_ITEMS 32
65 #define ICMAP_VALUETYPE_NOT_EXIST 0
153 static int cmap_exec_exit_fn(
void);
155 static int cmap_lib_init_fn (
void *conn);
156 static int cmap_lib_exit_fn (
void *conn);
158 static void message_handler_req_lib_cmap_set(
void *conn,
const void *message);
159 static void message_handler_req_lib_cmap_delete(
void *conn,
const void *message);
160 static void message_handler_req_lib_cmap_get(
void *conn,
const void *message);
161 static void message_handler_req_lib_cmap_adjust_int(
void *conn,
const void *message);
162 static void message_handler_req_lib_cmap_iter_init(
void *conn,
const void *message);
163 static void message_handler_req_lib_cmap_iter_next(
void *conn,
const void *message);
164 static void message_handler_req_lib_cmap_iter_finalize(
void *conn,
const void *message);
165 static void message_handler_req_lib_cmap_track_add(
void *conn,
const void *message);
166 static void message_handler_req_lib_cmap_track_delete(
void *conn,
const void *message);
167 static void message_handler_req_lib_cmap_set_current_map(
void *conn,
const void *message);
169 static void cmap_notify_fn(int32_t event,
170 const char *key_name,
175 static void message_handler_req_exec_cmap_mcast(
179 static void exec_cmap_mcast_endian_convert(
void *message);
190 static void cmap_sync_init (
191 const unsigned int *trans_list,
192 size_t trans_list_entries,
193 const unsigned int *member_list,
194 size_t member_list_entries,
197 static int cmap_sync_process (
void);
198 static void cmap_sync_activate (
void);
199 static void cmap_sync_abort (
void);
201 static void cmap_config_version_track_cb(
203 const char *key_name,
218 .lib_handler_fn = message_handler_req_lib_cmap_delete,
222 .lib_handler_fn = message_handler_req_lib_cmap_get,
226 .lib_handler_fn = message_handler_req_lib_cmap_adjust_int,
230 .lib_handler_fn = message_handler_req_lib_cmap_iter_init,
234 .lib_handler_fn = message_handler_req_lib_cmap_iter_next,
238 .lib_handler_fn = message_handler_req_lib_cmap_iter_finalize,
242 .lib_handler_fn = message_handler_req_lib_cmap_track_add,
246 .lib_handler_fn = message_handler_req_lib_cmap_track_delete,
250 .lib_handler_fn = message_handler_req_lib_cmap_set_current_map,
259 .exec_endian_convert_fn = exec_cmap_mcast_endian_convert
264 .
name =
"corosync configuration map access",
270 .lib_init_fn = cmap_lib_init_fn,
271 .lib_exit_fn = cmap_lib_exit_fn,
272 .lib_engine = cmap_lib_engine,
274 .exec_init_fn = cmap_exec_init_fn,
275 .exec_exit_fn = cmap_exec_exit_fn,
276 .exec_engine = cmap_exec_engine,
278 .sync_init = cmap_sync_init,
279 .sync_process = cmap_sync_process,
280 .sync_activate = cmap_sync_activate,
281 .sync_abort = cmap_sync_abort
307 static size_t cmap_sync_trans_list_entries = 0;
308 static size_t cmap_sync_member_list_entries = 0;
309 static uint64_t cmap_highest_config_version_received = 0;
310 static uint64_t cmap_my_config_version = 0;
311 static int cmap_first_sync = 1;
314 static void cmap_config_version_track_cb(
316 const char *key_name,
321 const char *key =
"totem.config_version";
327 cmap_my_config_version = 0;
339 static int cmap_exec_exit_fn(
void)
349 static char *cmap_exec_init_fn (
358 cmap_config_version_track_cb,
360 &cmap_config_version_track);
363 return ((
char *)
"Can't add config_version icmap tracker");
369 static int cmap_lib_init_fn (
void *conn)
377 memset(conn_info, 0,
sizeof(*conn_info));
379 hdb_create(&conn_info->
iter_db);
385 static int cmap_lib_exit_fn (
void *conn)
395 hdb_iterator_reset(&conn_info->
iter_db);
396 while (hdb_iterator_next(&conn_info->
iter_db,
397 (
void*)&iter, &iter_handle) == 0) {
401 (void)hdb_handle_put (&conn_info->
iter_db, iter_handle);
404 hdb_destroy(&conn_info->
iter_db);
406 hdb_iterator_reset(&conn_info->
track_db);
407 while (hdb_iterator_next(&conn_info->
track_db,
408 (
void*)&track, &track_handle) == 0) {
414 (void)hdb_handle_put (&conn_info->
track_db, track_handle);
423 static void cmap_sync_init (
424 const unsigned int *trans_list,
425 size_t trans_list_entries,
426 const unsigned int *member_list,
427 size_t member_list_entries,
431 cmap_sync_trans_list_entries = trans_list_entries;
432 cmap_sync_member_list_entries = member_list_entries;
435 cmap_my_config_version = 0;
438 cmap_highest_config_version_received = cmap_my_config_version;
441 static int cmap_sync_process (
void)
443 const char *key =
"totem.config_version";
448 return (ret ==
CS_OK ? 0 : -1);
451 static void cmap_sync_activate (
void)
454 if (cmap_sync_trans_list_entries == 0) {
460 if (cmap_first_sync == 1) {
468 if (cmap_my_config_version == 0) {
474 if (cmap_highest_config_version_received != cmap_my_config_version) {
476 "Received config version (%"PRIu64
") is different than my config version (%"PRIu64
")! Exiting",
477 cmap_highest_config_version_received, cmap_my_config_version);
483 static void cmap_sync_abort (
void)
489 static void message_handler_req_lib_cmap_set(
void *conn,
const void *message)
511 static void message_handler_req_lib_cmap_delete(
void *conn,
const void *message)
532 static void message_handler_req_lib_cmap_get(
void *conn,
const void *message)
540 size_t res_lib_cmap_get_size;
546 res_lib_cmap_get_size =
sizeof(*res_lib_cmap_get) + value_len;
583 memset(&error_res_lib_cmap_get, 0,
sizeof(error_res_lib_cmap_get));
584 error_res_lib_cmap_get.header.size =
sizeof(error_res_lib_cmap_get);
586 error_res_lib_cmap_get.header.error = ret;
588 api->
ipc_response_send(conn, &error_res_lib_cmap_get,
sizeof(error_res_lib_cmap_get));
591 static void message_handler_req_lib_cmap_adjust_int(
void *conn,
const void *message)
614 static void message_handler_req_lib_cmap_iter_init(
void *conn,
const void *message)
649 (void)hdb_handle_put (&conn_info->
iter_db, handle);
661 static void message_handler_req_lib_cmap_iter_next(
void *conn,
const void *message)
667 size_t value_len = 0;
669 const char *res = NULL;
702 static void message_handler_req_lib_cmap_iter_finalize(
void *conn,
const void *message)
731 static void cmap_notify_fn(int32_t event,
732 const char *key_name,
759 iov[1].iov_base = (
char *)new_val.
data;
760 iov[1].iov_len = new_val.
len;
761 iov[2].iov_base = (
char *)old_val.
data;
762 iov[2].iov_len = old_val.
len;
767 static void message_handler_req_lib_cmap_track_add(
void *conn,
const void *message)
776 const char *key_name;
824 (void)hdb_handle_put (&conn_info->
track_db, handle);
836 static void message_handler_req_lib_cmap_track_delete(
void *conn,
const void *message)
843 uint64_t track_inst_handle = 0;
872 static void message_handler_req_lib_cmap_set_current_map(
void *
conn,
const void *message)
875 struct qb_ipc_response_header res;
878 int handles_open = 0;
885 hdb_iterator_reset(&conn_info->
iter_db);
886 while (hdb_iterator_next(&conn_info->
iter_db,
887 (
void*)&iter, &iter_handle) == 0) {
891 hdb_iterator_reset(&conn_info->
track_db);
892 while (hdb_iterator_next(&conn_info->
track_db,
893 (
void*)&track, &track_handle) == 0) {
915 res.size =
sizeof(res);
940 memset(req_exec_cmap_iovec, 0,
sizeof(req_exec_cmap_iovec));
942 for (i = 0; i < argc; i++) {
943 err =
icmap_get(argv[i], NULL, &value_len, &value_type);
954 item = malloc(item_len);
958 memset(item, 0, item_len);
960 item->value_type = value_type;
961 item->value_len = value_len;
962 item->key_name.length = strlen(argv[i]);
963 strcpy((
char *)item->key_name.value, argv[i]);
966 err =
icmap_get(argv[i], item->value, &value_len, &value_type);
972 req_exec_cmap_iovec[i + 1].iov_base = item;
973 req_exec_cmap_iovec[i + 1].iov_len = item_len;
976 qb_log(LOG_TRACE,
"Item %u - type %u, len %zu", i, item->value_type, item->value_len);
988 qb_log(LOG_TRACE,
"Sending %u items (%u iovec) for reason %u", argc, argc + 1, reason);
992 for (i = 0; i < argc; i++) {
993 free(req_exec_cmap_iovec[i + 1].iov_base);
1003 const void *message,
1017 key_name_len = item->key_name.length;
1018 if (strlen(key) == key_name_len && strcmp((
char *)item->key_name.value, key) == 0) {
1028 static void message_handler_req_exec_cmap_mcast_reason_sync_nv(
1030 const void *message,
1034 uint64_t config_version = 0;
1040 item = cmap_mcast_item_find(message, (
char *)
"totem.config_version");
1042 value_len = item->value_len;
1049 memcpy(&config_version, item->value, value_len);
1053 qb_log(LOG_TRACE,
"Received config version %"PRIu64
" from node %x", config_version,
nodeid);
1056 config_version > cmap_highest_config_version_received) {
1057 cmap_highest_config_version_received = config_version;
1061 "runtime.members.%u.config_version",
nodeid);
1067 static void message_handler_req_exec_cmap_mcast(
1068 const void *message,
1093 static void exec_cmap_mcast_endian_convert(
void *message)
1112 swab_mar_uint16_t(&item->key_name.length);
1113 swab_mar_size_t(&item->value_len);
1115 switch (item->value_type) {
1118 memcpy(&u16, item->value,
sizeof(u16));
1120 memcpy(item->value, &u16,
sizeof(u16));
1124 memcpy(&u32, item->value,
sizeof(u32));
1126 memcpy(item->value, &u32,
sizeof(u32));
1130 memcpy(&u64, item->value,
sizeof(u64));
1132 memcpy(item->value, &u64,
sizeof(u64));
1135 memcpy(&flt, item->value,
sizeof(flt));
1137 memcpy(item->value, &flt,
sizeof(flt));
1140 memcpy(&dbl, item->value,
sizeof(dbl));
1142 memcpy(item->value, &dbl,
sizeof(dbl));