cib 38 cib/cibio.h extern int initializeCib(xmlNode * cib); cib 40 cib/cibio.h extern gboolean verifyCibXml(xmlNode * cib); cib 62 cib/cibmon.c cib_t *cib = NULL; cib 139 cib/cibmon.c cib = cib_new(); cib 143 cib/cibmon.c exit_code = cib->cmds->signon(cib, crm_system_name, cib_query); cib 153 cib/cibmon.c exit_code = cib->cmds->set_connection_dnotify(cib, cib_connection_destroy); cib 157 cib/cibmon.c exit_code = cib->cmds->add_notify_callback(cib, T_CIB_DIFF_NOTIFY, cibmon_diff); cib 245 cib/cibmon.c rc = cib->cmds->query(cib, NULL, &cib_copy, cib_scope_local | cib_sync_call); cib 556 cib/main.c xmlNode *cib = readCibXmlFile(cib_root, filename, !preserve_status); cib 558 cib/main.c CRM_ASSERT(cib != NULL); cib 560 cib/main.c if (activateCibXml(cib, TRUE, "start") == 0) { cib 566 cib/main.c cib_read_config(config_hash, cib); cib 568 cib/main.c port_s = crm_element_value(cib, "remote-tls-port"); cib 574 cib/main.c port_s = crm_element_value(cib, "remote-clear-port"); cib 172 crmd/election.c xmlNode *cib = NULL; cib 192 crmd/election.c cib = create_xml_node(NULL, XML_TAG_CIB); cib 193 crmd/election.c crm_xml_add(cib, XML_ATTR_CRM_VERSION, CRM_FEATURE_SET); cib 194 crmd/election.c fsa_cib_update(XML_TAG_CIB, cib, cib_quorum_override, rc, NULL); cib 221 crmd/election.c free_xml(cib); cib 86 include/crm/cib.h int (*signon) (cib_t * cib, const char *name, enum cib_conn_type type); cib 87 include/crm/cib.h int (*signon_raw) (cib_t * cib, const char *name, enum cib_conn_type type, int *event_fd); cib 88 include/crm/cib.h int (*signoff) (cib_t * cib); cib 89 include/crm/cib.h int (*free) (cib_t * cib); cib 91 include/crm/cib.h int (*set_op_callback) (cib_t * cib, void (*callback) (const xmlNode * msg, int callid, cib 94 include/crm/cib.h int (*add_notify_callback) (cib_t * cib, const char *event, cib 97 include/crm/cib.h int (*del_notify_callback) (cib_t * cib, const char *event, cib 100 include/crm/cib.h int (*set_connection_dnotify) (cib_t * cib, void (*dnotify) (gpointer user_data)); cib 102 include/crm/cib.h int (*inputfd) (cib_t * cib); cib 104 include/crm/cib.h int (*noop) (cib_t * cib, int call_options); cib 105 include/crm/cib.h int (*ping) (cib_t * cib, xmlNode ** output_data, int call_options); cib 107 include/crm/cib.h int (*query) (cib_t * cib, const char *section, xmlNode ** output_data, int call_options); cib 108 include/crm/cib.h int (*query_from) (cib_t * cib, const char *host, const char *section, cib 111 include/crm/cib.h int (*is_master) (cib_t * cib); cib 112 include/crm/cib.h int (*set_master) (cib_t * cib, int call_options); cib 113 include/crm/cib.h int (*set_slave) (cib_t * cib, int call_options); cib 114 include/crm/cib.h int (*set_slave_all) (cib_t * cib, int call_options); cib 116 include/crm/cib.h int (*sync) (cib_t * cib, const char *section, int call_options); cib 117 include/crm/cib.h int (*sync_from) (cib_t * cib, const char *host, const char *section, int call_options); cib 119 include/crm/cib.h int (*upgrade) (cib_t * cib, int call_options); cib 120 include/crm/cib.h int (*bump_epoch) (cib_t * cib, int call_options); cib 122 include/crm/cib.h int (*create) (cib_t * cib, const char *section, xmlNode * data, int call_options); cib 123 include/crm/cib.h int (*modify) (cib_t * cib, const char *section, xmlNode * data, int call_options); cib 124 include/crm/cib.h int (*update) (cib_t * cib, const char *section, xmlNode * data, int call_options); cib 125 include/crm/cib.h int (*replace) (cib_t * cib, const char *section, xmlNode * data, int call_options); cib 126 include/crm/cib.h int (*delete) (cib_t * cib, const char *section, xmlNode * data, int call_options); cib 128 include/crm/cib.h int (*erase) (cib_t * cib, xmlNode ** output_data, int call_options); cib 129 include/crm/cib.h int (*delete_absolute) (cib_t * cib, const char *section, xmlNode * data, int call_options); cib 131 include/crm/cib.h int (*quit) (cib_t * cib, int call_options); cib 133 include/crm/cib.h int (*register_notification) (cib_t * cib, const char *callback, int enabled); cib 135 include/crm/cib.h gboolean(*register_callback) (cib_t * cib, int call_id, int timeout, gboolean only_success, cib 139 include/crm/cib.h gboolean (*register_callback_full)(cib_t *cib, int call_id, int timeout, cib 175 include/crm/cib.h void cib_free_callbacks(cib_t *cib); cib 176 include/crm/cib.h void cib_delete(cib_t * cib); cib 183 include/crm/cib.h # define add_cib_op_callback(cib, id, flag, data, fn) do { \ cib 184 include/crm/cib.h cib->cmds->register_callback(cib, id, 120, flag, data, #fn, fn); \ cib 116 include/crm/cib/internal.h cib_t *cib; cib 134 include/crm/cib/internal.h void cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc); cib 136 include/crm/cib/internal.h int cib_native_register_notification(cib_t * cib, const char *callback, int enabled); cib 137 include/crm/cib/internal.h gboolean cib_client_register_callback(cib_t * cib, int call_id, int timeout, gboolean only_success, cib 140 include/crm/cib/internal.h gboolean cib_client_register_callback_full(cib_t *cib, int call_id, cib 211 include/crm/cib/internal.h int cib_internal_op(cib_t * cib, const char *op, const char *host, cib 28 include/crm/cib/util.h gboolean verifyCibXml(xmlNode * cib); cib 30 include/crm/cib/util.h gboolean cib_version_details(xmlNode * cib, int *admin_epoch, int *epoch, int *updates); cib 63 include/crm/cib/util.h xmlNode *get_cib_copy(cib_t * cib); cib 64 include/crm/cib/util.h xmlNode *cib_get_generation(cib_t * cib); cib 156 include/crm/cluster.h void crm_remote_peer_cache_refresh(xmlNode *cib); cib 186 include/crm/common/xml.h xmlNode *find_xml_node(xmlNode * cib, const char *node_path, gboolean must_find); cib 39 lib/cib/cib_client.c int cib_client_set_op_callback(cib_t * cib, void (*callback) (const xmlNode * msg, int call_id, cib 42 lib/cib/cib_client.c int cib_client_add_notify_callback(cib_t * cib, const char *event, cib 45 lib/cib/cib_client.c int cib_client_del_notify_callback(cib_t * cib, const char *event, cib 50 lib/cib/cib_client.c #define op_common(cib) do { \ cib 51 lib/cib/cib_client.c if(cib == NULL) { \ cib 53 lib/cib/cib_client.c } else if(cib->delegate_fn == NULL) { \ cib 59 lib/cib/cib_client.c cib_client_noop(cib_t * cib, int call_options) cib 61 lib/cib/cib_client.c op_common(cib); cib 62 lib/cib/cib_client.c return cib_internal_op(cib, CRM_OP_NOOP, NULL, NULL, NULL, NULL, call_options, NULL); cib 66 lib/cib/cib_client.c cib_client_ping(cib_t * cib, xmlNode ** output_data, int call_options) cib 68 lib/cib/cib_client.c op_common(cib); cib 69 lib/cib/cib_client.c return cib_internal_op(cib, CRM_OP_PING, NULL, NULL, NULL, output_data, call_options, NULL); cib 73 lib/cib/cib_client.c cib_client_query(cib_t * cib, const char *section, xmlNode ** output_data, int call_options) cib 75 lib/cib/cib_client.c return cib->cmds->query_from(cib, NULL, section, output_data, call_options); cib 79 lib/cib/cib_client.c cib_client_query_from(cib_t * cib, const char *host, const char *section, cib 82 lib/cib/cib_client.c op_common(cib); cib 83 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_QUERY, host, section, NULL, output_data, call_options, NULL); cib 87 lib/cib/cib_client.c cib_client_is_master(cib_t * cib) cib 89 lib/cib/cib_client.c op_common(cib); cib 90 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_ISMASTER, NULL, NULL, NULL, NULL, cib 95 lib/cib/cib_client.c cib_client_set_slave(cib_t * cib, int call_options) cib 97 lib/cib/cib_client.c op_common(cib); cib 98 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_SLAVE, NULL, NULL, NULL, NULL, call_options, NULL); cib 102 lib/cib/cib_client.c cib_client_set_slave_all(cib_t * cib, int call_options) cib 108 lib/cib/cib_client.c cib_client_set_master(cib_t * cib, int call_options) cib 110 lib/cib/cib_client.c op_common(cib); cib 112 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_MASTER, NULL, NULL, NULL, NULL, cib 117 lib/cib/cib_client.c cib_client_bump_epoch(cib_t * cib, int call_options) cib 119 lib/cib/cib_client.c op_common(cib); cib 120 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_BUMP, NULL, NULL, NULL, NULL, call_options, NULL); cib 124 lib/cib/cib_client.c cib_client_upgrade(cib_t * cib, int call_options) cib 126 lib/cib/cib_client.c op_common(cib); cib 127 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_UPGRADE, NULL, NULL, NULL, NULL, call_options, NULL); cib 131 lib/cib/cib_client.c cib_client_sync(cib_t * cib, const char *section, int call_options) cib 133 lib/cib/cib_client.c return cib->cmds->sync_from(cib, NULL, section, call_options); cib 137 lib/cib/cib_client.c cib_client_sync_from(cib_t * cib, const char *host, const char *section, int call_options) cib 139 lib/cib/cib_client.c op_common(cib); cib 140 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_SYNC, host, section, NULL, NULL, call_options, NULL); cib 144 lib/cib/cib_client.c cib_client_create(cib_t * cib, const char *section, xmlNode * data, int call_options) cib 146 lib/cib/cib_client.c op_common(cib); cib 147 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_CREATE, NULL, section, data, NULL, call_options, NULL); cib 151 lib/cib/cib_client.c cib_client_modify(cib_t * cib, const char *section, xmlNode * data, int call_options) cib 153 lib/cib/cib_client.c op_common(cib); cib 154 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_MODIFY, NULL, section, data, NULL, call_options, NULL); cib 158 lib/cib/cib_client.c cib_client_update(cib_t * cib, const char *section, xmlNode * data, int call_options) cib 160 lib/cib/cib_client.c op_common(cib); cib 161 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_MODIFY, NULL, section, data, NULL, call_options, NULL); cib 165 lib/cib/cib_client.c cib_client_replace(cib_t * cib, const char *section, xmlNode * data, int call_options) cib 167 lib/cib/cib_client.c op_common(cib); cib 168 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_REPLACE, NULL, section, data, NULL, call_options, NULL); cib 172 lib/cib/cib_client.c cib_client_delete(cib_t * cib, const char *section, xmlNode * data, int call_options) cib 174 lib/cib/cib_client.c op_common(cib); cib 175 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_DELETE, NULL, section, data, NULL, call_options, NULL); cib 179 lib/cib/cib_client.c cib_client_delete_absolute(cib_t * cib, const char *section, xmlNode * data, int call_options) cib 181 lib/cib/cib_client.c op_common(cib); cib 182 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_DELETE_ALT, NULL, section, data, NULL, call_options, NULL); cib 186 lib/cib/cib_client.c cib_client_erase(cib_t * cib, xmlNode ** output_data, int call_options) cib 188 lib/cib/cib_client.c op_common(cib); cib 189 lib/cib/cib_client.c return cib_internal_op(cib, CIB_OP_ERASE, NULL, NULL, NULL, output_data, call_options, NULL); cib 415 lib/cib/cib_client.c cib_free_callbacks(cib_t *cib) cib 417 lib/cib/cib_client.c if (cib) { cib 418 lib/cib/cib_client.c GList *list = cib->notify_list; cib 426 lib/cib/cib_client.c cib->notify_list = NULL; cib 437 lib/cib/cib_client.c cib_delete(cib_t *cib) cib 439 lib/cib/cib_client.c cib_free_callbacks(cib); cib 440 lib/cib/cib_client.c if (cib) { cib 441 lib/cib/cib_client.c cib->cmds->free(cib); cib 446 lib/cib/cib_client.c cib_client_set_op_callback(cib_t * cib, void (*callback) (const xmlNode * msg, int call_id, cib 455 lib/cib/cib_client.c cib->op_callback = callback; cib 460 lib/cib/cib_client.c cib_client_add_notify_callback(cib_t * cib, const char *event, cib 466 lib/cib/cib_client.c if (cib->variant != cib_native && cib->variant != cib_remote) { cib 470 lib/cib/cib_client.c crm_trace("Adding callback for %s events (%d)", event, g_list_length(cib->notify_list)); cib 476 lib/cib/cib_client.c list_item = g_list_find_custom(cib->notify_list, new_client, ciblib_GCompareFunc); cib 484 lib/cib/cib_client.c cib->notify_list = g_list_append(cib->notify_list, new_client); cib 486 lib/cib/cib_client.c cib->cmds->register_notification(cib, event, 1); cib 488 lib/cib/cib_client.c crm_trace("Callback added (%d)", g_list_length(cib->notify_list)); cib 494 lib/cib/cib_client.c get_notify_list_event_count(cib_t * cib, const char *event) cib 499 lib/cib/cib_client.c for (l = g_list_first(cib->notify_list); l; l = g_list_next(l)) { cib 511 lib/cib/cib_client.c cib_client_del_notify_callback(cib_t * cib, const char *event, cib 517 lib/cib/cib_client.c if (cib->variant != cib_native && cib->variant != cib_remote) { cib 521 lib/cib/cib_client.c if (get_notify_list_event_count(cib, event) == 0) { cib 532 lib/cib/cib_client.c list_item = g_list_find_custom(cib->notify_list, new_client, ciblib_GCompareFunc); cib 537 lib/cib/cib_client.c cib->notify_list = g_list_remove(cib->notify_list, list_client); cib 546 lib/cib/cib_client.c if (get_notify_list_event_count(cib, event) == 0) { cib 548 lib/cib/cib_client.c cib->cmds->register_notification(cib, event, 0); cib 585 lib/cib/cib_client.c cib_native_callback(timer->cib, NULL, timer->call_id, -ETIME); cib 594 lib/cib/cib_client.c cib_client_register_callback(cib_t * cib, int call_id, int timeout, gboolean only_success, cib 598 lib/cib/cib_client.c return cib_client_register_callback_full(cib, call_id, timeout, cib 604 lib/cib/cib_client.c cib_client_register_callback_full(cib_t *cib, int call_id, int timeout, cib 638 lib/cib/cib_client.c async_timer->cib = cib; cib 47 lib/cib/cib_file.c int cib_file_perform_op(cib_t * cib, const char *op, const char *host, const char *section, cib 50 lib/cib/cib_file.c int cib_file_perform_op_delegate(cib_t * cib, const char *op, const char *host, const char *section, cib 54 lib/cib/cib_file.c int cib_file_signon(cib_t * cib, const char *name, enum cib_conn_type type); cib 55 lib/cib/cib_file.c int cib_file_signoff(cib_t * cib); cib 56 lib/cib/cib_file.c int cib_file_free(cib_t * cib); cib 59 lib/cib/cib_file.c cib_file_inputfd(cib_t * cib) cib 65 lib/cib/cib_file.c cib_file_set_connection_dnotify(cib_t * cib, void (*dnotify) (gpointer user_data)) cib 71 lib/cib/cib_file.c cib_file_register_notification(cib_t * cib, const char *callback, int enabled) cib 480 lib/cib/cib_file.c cib_t *cib = cib_new_variant(); cib 483 lib/cib/cib_file.c CRM_ASSERT((cib != NULL) && (private != NULL)); cib 485 lib/cib/cib_file.c cib->variant = cib_file; cib 486 lib/cib/cib_file.c cib->variant_opaque = private; cib 499 lib/cib/cib_file.c cib->delegate_fn = cib_file_perform_op_delegate; cib 500 lib/cib/cib_file.c cib->cmds->signon = cib_file_signon; cib 501 lib/cib/cib_file.c cib->cmds->signoff = cib_file_signoff; cib 502 lib/cib/cib_file.c cib->cmds->free = cib_file_free; cib 503 lib/cib/cib_file.c cib->cmds->inputfd = cib_file_inputfd; cib 505 lib/cib/cib_file.c cib->cmds->register_notification = cib_file_register_notification; cib 506 lib/cib/cib_file.c cib->cmds->set_connection_dnotify = cib_file_set_connection_dnotify; cib 508 lib/cib/cib_file.c return cib; cib 564 lib/cib/cib_file.c cib_file_signon(cib_t * cib, const char *name, enum cib_conn_type type) cib 567 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; cib 577 lib/cib/cib_file.c cib->state = cib_connected_command; cib 578 lib/cib/cib_file.c cib->type = cib_command; cib 679 lib/cib/cib_file.c cib_file_signoff(cib_t * cib) cib 682 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; cib 685 lib/cib/cib_file.c cib->state = cib_disconnected; cib 686 lib/cib/cib_file.c cib->type = cib_no_connection; cib 721 lib/cib/cib_file.c cib_file_free(cib_t * cib) cib 725 lib/cib/cib_file.c if (cib->state != cib_disconnected) { cib 726 lib/cib/cib_file.c rc = cib_file_signoff(cib); cib 730 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; cib 733 lib/cib/cib_file.c free(cib->cmds); cib 735 lib/cib/cib_file.c free(cib); cib 765 lib/cib/cib_file.c cib_file_perform_op(cib_t * cib, const char *op, const char *host, const char *section, cib 768 lib/cib/cib_file.c return cib_file_perform_op_delegate(cib, op, host, section, data, output_data, call_options, cib 773 lib/cib/cib_file.c cib_file_perform_op_delegate(cib_t * cib, const char *op, const char *host, const char *section, cib 788 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; cib 793 lib/cib/cib_file.c if (cib->state == cib_disconnected) { cib 817 lib/cib/cib_file.c cib->call_id++; cib 818 lib/cib/cib_file.c request = cib_create_op(cib->call_id, "dummy-token", op, host, section, data, call_options, user_name); cib 852 lib/cib/cib_file.c if (cib->op_callback != NULL) { cib 853 lib/cib/cib_file.c cib->op_callback(NULL, cib->call_id, rc, output); cib 42 lib/cib/cib_native.c int cib_native_perform_op(cib_t * cib, const char *op, const char *host, const char *section, cib 45 lib/cib/cib_native.c int cib_native_perform_op_delegate(cib_t * cib, const char *op, const char *host, cib 49 lib/cib/cib_native.c int cib_native_free(cib_t * cib); cib 50 lib/cib/cib_native.c int cib_native_signoff(cib_t * cib); cib 51 lib/cib/cib_native.c int cib_native_signon(cib_t * cib, const char *name, enum cib_conn_type type); cib 52 lib/cib/cib_native.c int cib_native_signon_raw(cib_t * cib, const char *name, enum cib_conn_type type, int *event_fd); cib 54 lib/cib/cib_native.c bool cib_native_dispatch(cib_t * cib); cib 56 lib/cib/cib_native.c int cib_native_set_connection_dnotify(cib_t * cib, void (*dnotify) (gpointer user_data)); cib 62 lib/cib/cib_native.c cib_t *cib = cib_new_variant(); cib 66 lib/cib/cib_native.c cib->variant = cib_native; cib 67 lib/cib/cib_native.c cib->variant_opaque = native; cib 74 lib/cib/cib_native.c cib->delegate_fn = cib_native_perform_op_delegate; cib 75 lib/cib/cib_native.c cib->cmds->signon = cib_native_signon; cib 76 lib/cib/cib_native.c cib->cmds->signon_raw = cib_native_signon_raw; cib 77 lib/cib/cib_native.c cib->cmds->signoff = cib_native_signoff; cib 78 lib/cib/cib_native.c cib->cmds->free = cib_native_free; cib 80 lib/cib/cib_native.c cib->cmds->register_notification = cib_native_register_notification; cib 81 lib/cib/cib_native.c cib->cmds->set_connection_dnotify = cib_native_set_connection_dnotify; cib 83 lib/cib/cib_native.c return cib; cib 87 lib/cib/cib_native.c cib_native_signon(cib_t * cib, const char *name, enum cib_conn_type type) cib 89 lib/cib/cib_native.c return cib_native_signon_raw(cib, name, type, NULL); cib 98 lib/cib/cib_native.c cib_t *cib = userdata; cib 102 lib/cib/cib_native.c if (cib == NULL) { cib 120 lib/cib/cib_native.c cib_native_callback(cib, msg, 0, 0); cib 123 lib/cib/cib_native.c g_list_foreach(cib->notify_list, cib_native_notify, msg); cib 134 lib/cib/cib_native.c cib_native_dispatch(cib_t * cib) cib 139 lib/cib/cib_native.c if (cib == NULL) { cib 144 lib/cib/cib_native.c crm_trace("dispatching %p", cib); cib 145 lib/cib/cib_native.c native = cib->variant_opaque; cib 151 lib/cib/cib_native.c cib_native_dispatch_internal(msg, strlen(msg), cib); cib 166 lib/cib/cib_native.c cib_t *cib = userdata; cib 167 lib/cib/cib_native.c cib_native_opaque_t *native = cib->variant_opaque; cib 170 lib/cib/cib_native.c cib->state = cib_disconnected; cib 180 lib/cib/cib_native.c cib_native_signon_raw(cib_t * cib, const char *name, enum cib_conn_type type, int *async_fd) cib 184 lib/cib/cib_native.c cib_native_opaque_t *native = cib->variant_opaque; cib 191 lib/cib/cib_native.c cib->call_timeout = MAX_IPC_DELAY; cib 194 lib/cib/cib_native.c cib->state = cib_connected_command; cib 198 lib/cib/cib_native.c cib->state = cib_connected_command; cib 202 lib/cib/cib_native.c cib->state = cib_connected_query; cib 224 lib/cib/cib_native.c mainloop_add_ipc_client(channel, G_PRIORITY_HIGH, 512 * 1024 /* 512k */ , cib, cib 274 lib/cib/cib_native.c cib_native_signoff(cib); cib 279 lib/cib/cib_native.c cib_native_signoff(cib_t * cib) cib 281 lib/cib/cib_native.c cib_native_opaque_t *native = cib->variant_opaque; cib 300 lib/cib/cib_native.c cib->state = cib_disconnected; cib 301 lib/cib/cib_native.c cib->type = cib_no_connection; cib 307 lib/cib/cib_native.c cib_native_free(cib_t * cib) cib 311 lib/cib/cib_native.c if (cib->state != cib_disconnected) { cib 312 lib/cib/cib_native.c rc = cib_native_signoff(cib); cib 315 lib/cib/cib_native.c if (cib->state == cib_disconnected) { cib 316 lib/cib/cib_native.c cib_native_opaque_t *native = cib->variant_opaque; cib 319 lib/cib/cib_native.c free(cib->variant_opaque); cib 320 lib/cib/cib_native.c free(cib->cmds); cib 321 lib/cib/cib_native.c free(cib); cib 328 lib/cib/cib_native.c cib_native_perform_op(cib_t * cib, const char *op, const char *host, const char *section, cib 331 lib/cib/cib_native.c return cib_native_perform_op_delegate(cib, op, host, section, cib 336 lib/cib/cib_native.c cib_native_perform_op_delegate(cib_t * cib, const char *op, const char *host, const char *section, cib 347 lib/cib/cib_native.c cib_native_opaque_t *native = cib->variant_opaque; cib 349 lib/cib/cib_native.c if (cib->state == cib_disconnected) { cib 366 lib/cib/cib_native.c cib->call_id++; cib 371 lib/cib/cib_native.c if (cib->call_id < 1) { cib 372 lib/cib/cib_native.c cib->call_id = 1; cib 378 lib/cib/cib_native.c cib_create_op(cib->call_id, native->token, op, host, section, data, call_options, cib 384 lib/cib/cib_native.c crm_trace("Sending %s message to CIB service (timeout=%ds)", op, cib->call_timeout); cib 385 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, cib->call_timeout * 1000, &op_reply); cib 390 lib/cib/cib_native.c cib->call_timeout, pcmk_strerror(rc), rc); cib 398 lib/cib/cib_native.c crm_trace("Async call, returning %d", cib->call_id); cib 399 lib/cib/cib_native.c CRM_CHECK(cib->call_id != 0, return -ENOMSG); cib 401 lib/cib/cib_native.c return cib->call_id; cib 406 lib/cib/cib_native.c if (reply_id == cib->call_id) { cib 428 lib/cib/cib_native.c crm_err("Received bad reply: %d (wanted %d)", reply_id, cib->call_id); cib 434 lib/cib/cib_native.c if (op_reply == NULL && cib->state == cib_disconnected) { cib 469 lib/cib/cib_native.c cib->state = cib_disconnected; cib 477 lib/cib/cib_native.c cib_native_set_connection_dnotify(cib_t * cib, void (*dnotify) (gpointer user_data)) cib 481 lib/cib/cib_native.c if (cib == NULL) { cib 486 lib/cib/cib_native.c native = cib->variant_opaque; cib 493 lib/cib/cib_native.c cib_native_register_notification(cib_t * cib, const char *callback, int enabled) cib 497 lib/cib/cib_native.c cib_native_opaque_t *native = cib->variant_opaque; cib 499 lib/cib/cib_native.c if (cib->state != cib_disconnected) { cib 504 lib/cib/cib_native.c 1000 * cib->call_timeout, NULL); cib 78 lib/cib/cib_remote.c int cib_remote_signon(cib_t * cib, const char *name, enum cib_conn_type type); cib 79 lib/cib/cib_remote.c int cib_remote_signoff(cib_t * cib); cib 80 lib/cib/cib_remote.c int cib_remote_free(cib_t * cib); cib 82 lib/cib/cib_remote.c int cib_remote_perform_op(cib_t * cib, const char *op, const char *host, const char *section, cib 87 lib/cib/cib_remote.c cib_remote_inputfd(cib_t * cib) cib 89 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; cib 95 lib/cib/cib_remote.c cib_remote_set_connection_dnotify(cib_t * cib, void (*dnotify) (gpointer user_data)) cib 101 lib/cib/cib_remote.c cib_remote_register_notification(cib_t * cib, const char *callback, int enabled) cib 104 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; cib 119 lib/cib/cib_remote.c cib_t *cib = cib_new_variant(); cib 123 lib/cib/cib_remote.c cib->variant = cib_remote; cib 124 lib/cib/cib_remote.c cib->variant_opaque = private; cib 142 lib/cib/cib_remote.c cib->delegate_fn = cib_remote_perform_op; cib 143 lib/cib/cib_remote.c cib->cmds->signon = cib_remote_signon; cib 144 lib/cib/cib_remote.c cib->cmds->signoff = cib_remote_signoff; cib 145 lib/cib/cib_remote.c cib->cmds->free = cib_remote_free; cib 146 lib/cib/cib_remote.c cib->cmds->inputfd = cib_remote_inputfd; cib 148 lib/cib/cib_remote.c cib->cmds->register_notification = cib_remote_register_notification; cib 149 lib/cib/cib_remote.c cib->cmds->set_connection_dnotify = cib_remote_set_connection_dnotify; cib 151 lib/cib/cib_remote.c return cib; cib 155 lib/cib/cib_remote.c cib_tls_close(cib_t * cib) cib 157 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; cib 202 lib/cib/cib_remote.c cib_tls_signon(cib_t * cib, crm_remote_t * connection, gboolean event_channel) cib 205 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; cib 249 lib/cib/cib_remote.c cib_tls_close(cib); cib 299 lib/cib/cib_remote.c cib_tls_close(cib); cib 305 lib/cib/cib_remote.c mainloop_add_fd("cib-remote", G_PRIORITY_HIGH, sock, cib, cib 324 lib/cib/cib_remote.c cib_t *cib = user_data; cib 325 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; cib 342 lib/cib/cib_remote.c cib_t *cib = user_data; cib 343 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; cib 359 lib/cib/cib_remote.c cib_native_callback(cib, msg, 0, 0); cib 362 lib/cib/cib_remote.c g_list_foreach(cib->notify_list, cib_native_notify, msg); cib 380 lib/cib/cib_remote.c cib_remote_signon(cib_t * cib, const char *name, enum cib_conn_type type) cib 383 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; cib 415 lib/cib/cib_remote.c rc = cib_tls_signon(cib, &(private->command), FALSE); cib 419 lib/cib/cib_remote.c rc = cib_tls_signon(cib, &(private->callback), TRUE); cib 432 lib/cib/cib_remote.c cib->state = cib_connected_command; cib 433 lib/cib/cib_remote.c cib->type = cib_command; cib 444 lib/cib/cib_remote.c cib_remote_signoff(cib_t * cib) cib 452 lib/cib/cib_remote.c cib_tls_close(cib); cib 455 lib/cib/cib_remote.c cib->state = cib_disconnected; cib 456 lib/cib/cib_remote.c cib->type = cib_no_connection; cib 462 lib/cib/cib_remote.c cib_remote_free(cib_t * cib) cib 467 lib/cib/cib_remote.c if (cib->state != cib_disconnected) { cib 468 lib/cib/cib_remote.c rc = cib_remote_signoff(cib); cib 470 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; cib 475 lib/cib/cib_remote.c free(cib->cmds); cib 477 lib/cib/cib_remote.c free(cib); cib 485 lib/cib/cib_remote.c cib_remote_perform_op(cib_t * cib, const char *op, const char *host, const char *section, cib 496 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; cib 498 lib/cib/cib_remote.c if (cib->state == cib_disconnected) { cib 511 lib/cib/cib_remote.c cib->call_id++; cib 516 lib/cib/cib_remote.c if (cib->call_id < 1) { cib 517 lib/cib/cib_remote.c cib->call_id = 1; cib 521 lib/cib/cib_remote.c cib_create_op(cib->call_id, private->callback.token, op, host, section, data, call_options, cib 540 lib/cib/cib_remote.c return cib->call_id; cib 546 lib/cib/cib_remote.c remaining_time = cib->call_timeout ? cib->call_timeout : 60; cib 550 lib/cib/cib_remote.c int msg_id = cib->call_id; cib 625 lib/cib/cib_remote.c crm_trace("No output in reply to \"%s\" command %d", op, cib->call_id - 1); cib 111 lib/cib/cib_utils.c get_cib_copy(cib_t * cib) cib 117 lib/cib/cib_utils.c if (cib->state == cib_disconnected) { cib 121 lib/cib/cib_utils.c rc = cib->cmds->query(cib, NULL, &xml_cib, options); cib 144 lib/cib/cib_utils.c cib_get_generation(cib_t * cib) cib 149 lib/cib/cib_utils.c cib->cmds->query(cib, NULL, &the_cib, cib_scope_local | cib_sync_call); cib 159 lib/cib/cib_utils.c cib_version_details(xmlNode * cib, int *admin_epoch, int *epoch, int *updates) cib 165 lib/cib/cib_utils.c if (cib == NULL) { cib 169 lib/cib/cib_utils.c crm_element_value_int(cib, XML_ATTR_GENERATION, epoch); cib 170 lib/cib/cib_utils.c crm_element_value_int(cib, XML_ATTR_NUMUPDATES, updates); cib 171 lib/cib/cib_utils.c crm_element_value_int(cib, XML_ATTR_GENERATION_ADMIN, admin_epoch); cib 623 lib/cib/cib_utils.c cib_native_callback(cib_t * cib, xmlNode * msg, int call_id, int rc) cib 639 lib/cib/cib_utils.c if (cib == NULL) { cib 652 lib/cib/cib_utils.c } else if (cib && cib->op_callback == NULL && rc != pcmk_ok) { cib 662 lib/cib/cib_utils.c if (cib && cib->op_callback != NULL) { cib 664 lib/cib/cib_utils.c cib->op_callback(msg, call_id, rc, output); cib 835 lib/cib/cib_utils.c cib_internal_op(cib_t * cib, const char *op, const char *host, cib 839 lib/cib/cib_utils.c int (*delegate) (cib_t * cib, const char *op, const char *host, cib 842 lib/cib/cib_utils.c cib->delegate_fn; cib 850 lib/cib/cib_utils.c return delegate(cib, op, host, section, data, output_data, call_options, user_name); cib 257 lib/cluster/membership.c crm_remote_peer_cache_refresh(xmlNode *cib) cib 272 lib/cluster/membership.c crm_foreach_xpath_result(cib, XPATH_REMOTE_NODE_STATUS, cib 283 lib/cluster/membership.c crm_foreach_xpath_result(cib, XPATH_GUEST_NODE_CONFIG, cib 287 lib/cluster/membership.c crm_foreach_xpath_result(cib, XPATH_REMOTE_NODE_CONFIG, cib 1132 lib/common/xml.c xmlNode *cib = NULL; cib 1155 lib/common/xml.c cib = find_xml_node(diff_child, tag, FALSE); cib 1156 lib/common/xml.c if (cib == NULL) { cib 1157 lib/common/xml.c cib = create_xml_node(diff_child, tag); cib 1165 lib/common/xml.c crm_xml_add(cib, vfields[lpc], value); cib 1176 lib/common/xml.c cib = find_xml_node(diff_child, tag, FALSE); cib 1177 lib/common/xml.c if (cib == NULL) { cib 1178 lib/common/xml.c cib = create_xml_node(diff_child, tag); cib 1194 lib/common/xml.c xmlSetProp(cib, (const xmlChar *)p_name, (const xmlChar *)p_value); cib 121 tools/crm_mon.c cib_t *cib = NULL; cib 235 tools/crm_mon.c if (cib) { cib 236 tools/crm_mon.c cib->cmds->signoff(cib); cib 286 tools/crm_mon.c CRM_CHECK(cib != NULL, return -EINVAL); cib 305 tools/crm_mon.c if (cib->state != cib_connected_query && cib->state != cib_connected_command) { cib 307 tools/crm_mon.c if ((output_format == mon_output_console) && need_pass && (cib->variant == cib_remote)) { cib 312 tools/crm_mon.c rc = cib->cmds->signon(cib, crm_system_name, cib_query); cib 318 tools/crm_mon.c rc = cib->cmds->query(cib, NULL, ¤t_cib, cib_scope_local | cib_sync_call); cib 325 tools/crm_mon.c rc = cib->cmds->set_connection_dnotify(cib, mon_cib_connection_destroy); cib 338 tools/crm_mon.c cib->cmds->del_notify_callback(cib, T_CIB_DIFF_NOTIFY, crm_diff_update); cib 339 tools/crm_mon.c rc = cib->cmds->add_notify_callback(cib, T_CIB_DIFF_NOTIFY, crm_diff_update); cib 779 tools/crm_mon.c cib = cib_new(); cib 4078 tools/crm_mon.c cib->cmds->query(cib, NULL, ¤t_cib, cib_scope_local | cib_sync_call); cib 4134 tools/crm_mon.c if (cib) { cib 4135 tools/crm_mon.c cib->cmds->signoff(cib); cib 4233 tools/crm_mon.c if (cib != NULL) { cib 4234 tools/crm_mon.c cib->cmds->signoff(cib); cib 4235 tools/crm_mon.c cib_delete(cib); cib 4236 tools/crm_mon.c cib = NULL; cib 92 tools/crm_node.c cib_t *cib = NULL; cib 112 tools/crm_node.c cib = cib_new(); cib 113 tools/crm_node.c cib->cmds->signon(cib, crm_system_name, cib_command); cib 115 tools/crm_node.c rc = cib->cmds->delete(cib, XML_CIB_TAG_NODES, node, cib_sync_call); cib 119 tools/crm_node.c rc = cib->cmds->delete(cib, XML_CIB_TAG_STATUS, node_state, cib_sync_call); cib 124 tools/crm_node.c cib->cmds->signoff(cib); cib 125 tools/crm_node.c cib_delete(cib); cib 72 tools/crm_resource.h void cli_resource_check(cib_t * cib, resource_t *rsc); cib 79 tools/crm_resource.h int cli_resource_restart(resource_t * rsc, const char *host, int timeout_ms, cib_t * cib); cib 81 tools/crm_resource.h const char *host_name, cib_t *cib, cib 85 tools/crm_resource.h int timeout_ms, cib_t *cib, cib 91 tools/crm_resource.h bool recursive, cib_t *cib, cib 95 tools/crm_resource.h const char *attr_name, cib_t *cib, cib 99 tools/crm_resource.h int wait_till_stable(int timeout_ms, cib_t * cib); cib 169 tools/crm_resource_runtime.c const char * attr_name, cib_t * cib, const char * cmd) cib 188 tools/crm_resource_runtime.c rc = find_resource_attr(cib, XML_ATTR_ID, rsc_id, attr_set_type, attr_set, attr_id, attr_name, &local_attr_id); cib 210 tools/crm_resource_runtime.c rc = find_resource_attr(cib, XML_ATTR_ID, lookup_id, attr_set_type, attr_set, attr_id, attr_name, &local_attr_id); cib 231 tools/crm_resource_runtime.c bool recursive, cib_t *cib, cib 249 tools/crm_resource_runtime.c cib, XML_ATTR_ID, uber_parent(rsc)->id, NULL, NULL, NULL, attr_name, NULL)) { cib 255 tools/crm_resource_runtime.c rc = find_resource_attr(cib, XML_ATTR_ID, uber_parent(rsc)->id, cib 271 tools/crm_resource_runtime.c attr_id, attr_name, cib, "update"); cib 275 tools/crm_resource_runtime.c rc = find_resource_attr(cib, XML_ATTR_ID, lookup_id, attr_set_type, attr_set, attr_id, attr_name, cib 292 tools/crm_resource_runtime.c cib->cmds->query(cib, "/cib", &cib_top, cib 337 tools/crm_resource_runtime.c rc = cib->cmds->modify(cib, XML_CIB_TAG_RESOURCES, xml_top, cib_options); cib 378 tools/crm_resource_runtime.c cib, data_set); cib 389 tools/crm_resource_runtime.c const char *attr_name, cib_t *cib, cib 401 tools/crm_resource_runtime.c cib, XML_ATTR_ID, uber_parent(rsc)->id, NULL, NULL, NULL, attr_name, NULL) != pcmk_ok) { cib 407 tools/crm_resource_runtime.c attr_id, attr_name, cib, "delete"); cib 411 tools/crm_resource_runtime.c rc = find_resource_attr(cib, XML_ATTR_ID, lookup_id, attr_set_type, attr_set, attr_id, attr_name, cib 430 tools/crm_resource_runtime.c CRM_ASSERT(cib); cib 431 tools/crm_resource_runtime.c rc = cib->cmds->delete(cib, XML_CIB_TAG_RESOURCES, xml_obj, cib_options); cib 927 tools/crm_resource_runtime.c update_working_set_from_cib(pe_working_set_t * data_set, cib_t *cib) cib 932 tools/crm_resource_runtime.c rc = cib->cmds->query(cib, NULL, &cib_xml_copy, cib_scope_local | cib_sync_call); cib 947 tools/crm_resource_runtime.c update_dataset(cib_t *cib, pe_working_set_t * data_set, bool simulate) cib 955 tools/crm_resource_runtime.c rc = update_working_set_from_cib(data_set, cib); cib 1078 tools/crm_resource_runtime.c cli_resource_restart(resource_t * rsc, const char *host, int timeout_ms, cib_t * cib) cib 1136 tools/crm_resource_runtime.c rc = update_dataset(cib, &data_set, FALSE); cib 1151 tools/crm_resource_runtime.c rc = cli_resource_ban(rsc_id, host, NULL, cib); cib 1160 tools/crm_resource_runtime.c find_resource_attr(cib, XML_NVPAIR_ATTR_VALUE, lookup_id, NULL, NULL, cib 1165 tools/crm_resource_runtime.c RSC_STOPPED, FALSE, cib, &data_set); cib 1179 tools/crm_resource_runtime.c rc = update_dataset(cib, &data_set, TRUE); cib 1206 tools/crm_resource_runtime.c rc = update_dataset(cib, &data_set, FALSE); cib 1234 tools/crm_resource_runtime.c rc = cli_resource_clear(rsc_id, host, NULL, cib); cib 1239 tools/crm_resource_runtime.c orig_target_role, FALSE, cib, cib 1245 tools/crm_resource_runtime.c XML_RSC_ATTR_TARGET_ROLE, cib, cib 1282 tools/crm_resource_runtime.c rc = update_dataset(cib, &data_set, FALSE); cib 1317 tools/crm_resource_runtime.c cli_resource_clear(rsc_id, host, NULL, cib); cib 1321 tools/crm_resource_runtime.c orig_target_role, FALSE, cib, &data_set); cib 1325 tools/crm_resource_runtime.c XML_RSC_ATTR_TARGET_ROLE, cib, &data_set); cib 1420 tools/crm_resource_runtime.c wait_till_stable(int timeout_ms, cib_t * cib) cib 1446 tools/crm_resource_runtime.c rc = update_working_set_from_cib(&data_set, cib); cib 1461 tools/crm_resource_runtime.c int timeout_ms, cib_t * cib, pe_working_set_t *data_set) cib 1618 tools/crm_resource_runtime.c cib_t *cib, pe_working_set_t *data_set) cib 1692 tools/crm_resource_runtime.c cli_resource_clear(rsc_id, dest->details->uname, data_set->nodes, cib); cib 1695 tools/crm_resource_runtime.c rc = cli_resource_prefer(rsc_id, dest->details->uname, cib); cib 1706 tools/crm_resource_runtime.c (void)cli_resource_ban(rsc_id, current->details->uname, NULL, cib); cib 367 tools/crm_ticket.c const char *attr_name, cib_t * cib) cib 374 tools/crm_ticket.c rc = find_ticket_state_attr_legacy(cib, XML_ATTR_ID, ticket_id, XML_TAG_ATTR_SETS, set_name, cib 391 tools/crm_ticket.c rc = cib->cmds->delete(cib, XML_CIB_TAG_STATUS, xml_obj, cib_options); cib 508 tools/crm_ticket.c cib_t * cib, pe_working_set_t * data_set) cib 526 tools/crm_ticket.c delete_ticket_state_attr_legacy(ticket_id, set_name, attr_id, key, cib); cib 529 tools/crm_ticket.c rc = find_ticket_state(cib, ticket_id, &ticket_state_xml); cib 575 tools/crm_ticket.c rc = cib->cmds->replace(cib, XML_CIB_TAG_STATUS, ticket_state_xml, cib_options); cib 579 tools/crm_ticket.c rc = cib->cmds->modify(cib, XML_CIB_TAG_STATUS, xml_top, cib_options); cib 590 tools/crm_ticket.c delete_ticket_state_attr_legacy(ticket_id, set_name, attr_id, key, cib); cib 594 tools/crm_ticket.c delete_ticket_state_attr_legacy(ticket_id, set_name, attr_id, "last-granted", cib); cib 601 tools/crm_ticket.c delete_ticket_state(const char *ticket_id, cib_t * cib) cib 607 tools/crm_ticket.c rc = find_ticket_state(cib, ticket_id, &ticket_state_xml); cib 618 tools/crm_ticket.c rc = cib->cmds->delete(cib, XML_CIB_TAG_STATUS, ticket_state_xml, cib_options); cib 381 tools/fake_transition.c const char *attr_value, cib_t * cib, int cib_options) cib 387 tools/fake_transition.c rc = find_ticket_state(cib, ticket_id, &ticket_state_xml); cib 408 tools/fake_transition.c rc = cib->cmds->modify(cib, XML_CIB_TAG_STATUS, xml_top, cib_options); cib 416 tools/fake_transition.c modify_configuration(pe_working_set_t * data_set, cib_t *cib, cib 437 tools/fake_transition.c rc = cib->cmds->modify(cib, NULL, top, cib_sync_call | cib_scope_local); cib 444 tools/fake_transition.c rc = update_attr_delegate(cib, cib_sync_call | cib_scope_local, cib 455 tools/fake_transition.c cib_node = modify_node(cib, node, TRUE); cib 458 tools/fake_transition.c rc = cib->cmds->modify(cib, XML_CIB_TAG_STATUS, cib_node, cib 469 tools/fake_transition.c cib_node = modify_node(cib, node, FALSE); cib 472 tools/fake_transition.c rc = cib->cmds->modify(cib, XML_CIB_TAG_STATUS, cib_node, cib 478 tools/fake_transition.c cib->cmds->delete(cib, xpath, NULL, cib 483 tools/fake_transition.c cib->cmds->delete(cib, xpath, NULL, cib 492 tools/fake_transition.c cib_node = modify_node(cib, node, TRUE); cib 496 tools/fake_transition.c rc = cib->cmds->modify(cib, XML_CIB_TAG_STATUS, cib_node, cib 507 tools/fake_transition.c cib, cib_sync_call | cib_scope_local); cib 517 tools/fake_transition.c cib, cib_sync_call | cib_scope_local); cib 527 tools/fake_transition.c cib, cib_sync_call | cib_scope_local); cib 537 tools/fake_transition.c cib, cib_sync_call | cib_scope_local); cib 582 tools/fake_transition.c cib_node = inject_node_state(cib, node, NULL); cib 597 tools/fake_transition.c rc = cib->cmds->modify(cib, XML_CIB_TAG_STATUS, cib_node, cib 802 tools/fake_transition.c run_simulation(pe_working_set_t * data_set, cib_t *cib, GListPtr op_fail_list, bool quiet) cib 814 tools/fake_transition.c fake_cib = cib; cib 2 tools/fake_transition.h pe_working_set_t * data_set, cib_t *cib, cib 7 tools/fake_transition.h int run_simulation(pe_working_set_t * data_set, cib_t *cib, GListPtr op_fail_list, bool quiet);