private 70 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 75 lib/cib/cib_file.c g_hash_table_insert(client_table, private->id, (gpointer) cib); private 87 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 93 lib/cib/cib_file.c g_hash_table_remove(client_table, private->id); private 232 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 254 lib/cib/cib_file.c request, data, true, &changed, &private->cib_xml, private 271 lib/cib/cib_file.c if (result_cib != private->cib_xml) { private 272 lib/cib/cib_file.c pcmk__xml_free(private->cib_xml); private 273 lib/cib/cib_file.c private->cib_xml = result_cib; private 275 lib/cib/cib_file.c cib_set_file_flags(private, cib_file_flag_dirty); private 279 lib/cib/cib_file.c if ((result_cib != private->cib_xml) && (result_cib != *output)) { private 295 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 332 lib/cib/cib_file.c crm_xml_add(request, PCMK__XA_CIB_CLIENTID, private->id); private 342 lib/cib/cib_file.c if (output->doc == private->cib_xml->doc) { private 351 lib/cib/cib_file.c && (output->doc != private->cib_xml->doc) private 412 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 414 lib/cib/cib_file.c if (private->filename == NULL) { private 417 lib/cib/cib_file.c rc = load_file_cib(private->filename, &private->cib_xml); private 422 lib/cib/cib_file.c private->filename, pcmk__s(name, "client")); private 429 lib/cib/cib_file.c private->filename, pcmk__s(name, "client"), private->id, private 530 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 539 lib/cib/cib_file.c if (pcmk_is_set(private->flags, cib_file_flag_dirty)) { private 542 lib/cib/cib_file.c if (pcmk_is_set(private->flags, cib_file_flag_live)) { private 543 lib/cib/cib_file.c if (cib_file_write_live(private->cib_xml, private->filename) < 0) { private 549 lib/cib/cib_file.c bool compress = pcmk__ends_with_ext(private->filename, ".bz2"); private 551 lib/cib/cib_file.c if (pcmk__xml_write_file(private->cib_xml, private->filename, private 558 lib/cib/cib_file.c crm_info("Wrote CIB to %s", private->filename); private 559 lib/cib/cib_file.c cib_clear_file_flags(private, cib_file_flag_dirty); private 561 lib/cib/cib_file.c crm_err("Could not write CIB to %s", private->filename); private 566 lib/cib/cib_file.c pcmk__xml_free(private->cib_xml); private 567 lib/cib/cib_file.c private->cib_xml = NULL; private 581 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 583 lib/cib/cib_file.c free(private->id); private 584 lib/cib/cib_file.c free(private->filename); private 585 lib/cib/cib_file.c free(private); private 627 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 630 lib/cib/cib_file.c *async_id = private->id; private 633 lib/cib/cib_file.c *sync_id = private->id; private 642 lib/cib/cib_file.c cib_file_opaque_t *private = NULL; private 663 lib/cib/cib_file.c private = calloc(1, sizeof(cib_file_opaque_t)); private 664 lib/cib/cib_file.c if (private == NULL) { private 670 lib/cib/cib_file.c private->id = crm_generate_uuid(); private 671 lib/cib/cib_file.c private->filename = filename; private 674 lib/cib/cib_file.c cib->variant_opaque = private; private 676 lib/cib/cib_file.c private->flags = 0; private 678 lib/cib/cib_file.c cib_set_file_flags(private, cib_file_flag_live); private 1061 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 1078 lib/cib/cib_file.c private->id, private->filename, op, pcmk_rc_str(rc)); private 1085 lib/cib/cib_file.c op, private->id, private->filename); private 1111 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 1112 lib/cib/cib_file.c xmlNode *saved_cib = private->cib_xml; private 1124 lib/cib/cib_file.c CRM_CHECK((*result_cib != NULL) && (*result_cib != private->cib_xml), private 1125 lib/cib/cib_file.c *result_cib = pcmk__xml_copy(NULL, private->cib_xml)); private 1129 lib/cib/cib_file.c private->id, private->filename); private 1132 lib/cib/cib_file.c private->cib_xml = *result_cib; private 1138 lib/cib/cib_file.c private->id, private->filename); private 1146 lib/cib/cib_file.c *result_cib = private->cib_xml; private 1149 lib/cib/cib_file.c private->cib_xml = saved_cib; private 1171 lib/cib/cib_file.c cib_file_opaque_t *private = cib->variant_opaque; private 1175 lib/cib/cib_file.c private->id, private->filename, pcmk_rc_str(rc)); private 67 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; private 96 lib/cib/cib_remote.c pcmk__remote_send_xml(&private->callback, op_msg); private 98 lib/cib/cib_remote.c pcmk__remote_send_xml(&private->command, op_msg); private 120 lib/cib/cib_remote.c rc = pcmk__read_remote_message(&private->command, private 122 lib/cib/cib_remote.c op_reply = pcmk__remote_message_xml(&private->command); private 205 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; private 214 lib/cib/cib_remote.c if (private->start_time == 0) { private 215 lib/cib/cib_remote.c private->start_time = time(NULL); private 218 lib/cib/cib_remote.c rc = pcmk__read_available_remote_data(&private->callback); private 226 lib/cib/cib_remote.c if (time(NULL) >= private->start_time + private->timeout_sec) { private 243 lib/cib/cib_remote.c msg = pcmk__remote_message_xml(&private->callback); private 245 lib/cib/cib_remote.c private->start_time = 0; private 262 lib/cib/cib_remote.c private->start_time = 0; private 271 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; private 274 lib/cib/cib_remote.c if (private->start_time == 0) { private 275 lib/cib/cib_remote.c private->start_time = time(NULL); private 278 lib/cib/cib_remote.c rc = pcmk__read_available_remote_data(&private->command); private 281 lib/cib/cib_remote.c if (time(NULL) >= private->start_time + private->timeout_sec) { private 291 lib/cib/cib_remote.c free(private->command.buffer); private 292 lib/cib/cib_remote.c private->command.buffer = NULL; private 301 lib/cib/cib_remote.c private->start_time = 0; private 308 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; private 310 lib/cib/cib_remote.c if (private->encrypted) { private 311 lib/cib/cib_remote.c if (private->command.tls_session) { private 312 lib/cib/cib_remote.c gnutls_bye(private->command.tls_session, GNUTLS_SHUT_RDWR); private 313 lib/cib/cib_remote.c gnutls_deinit(private->command.tls_session); private 316 lib/cib/cib_remote.c if (private->callback.tls_session) { private 317 lib/cib/cib_remote.c gnutls_bye(private->callback.tls_session, GNUTLS_SHUT_RDWR); private 318 lib/cib/cib_remote.c gnutls_deinit(private->callback.tls_session); private 321 lib/cib/cib_remote.c private->command.tls_session = NULL; private 322 lib/cib/cib_remote.c private->callback.tls_session = NULL; private 327 lib/cib/cib_remote.c if (private->command.tcp_socket >= 0) { private 328 lib/cib/cib_remote.c shutdown(private->command.tcp_socket, SHUT_RDWR); /* no more receptions */ private 329 lib/cib/cib_remote.c close(private->command.tcp_socket); private 331 lib/cib/cib_remote.c if (private->callback.tcp_socket >= 0) { private 332 lib/cib/cib_remote.c shutdown(private->callback.tcp_socket, SHUT_RDWR); /* no more receptions */ private 333 lib/cib/cib_remote.c close(private->callback.tcp_socket); private 335 lib/cib/cib_remote.c private->command.tcp_socket = -1; private 336 lib/cib/cib_remote.c private->callback.tcp_socket = -1; private 338 lib/cib/cib_remote.c free(private->command.buffer); private 339 lib/cib/cib_remote.c free(private->callback.buffer); private 340 lib/cib/cib_remote.c private->command.buffer = NULL; private 341 lib/cib/cib_remote.c private->callback.buffer = NULL; private 356 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; private 370 lib/cib/cib_remote.c rc = pcmk__connect_remote(private->server, private->port, 0, NULL, private 374 lib/cib/cib_remote.c private->server, private->port, pcmk_rc_str(rc), rc); private 378 lib/cib/cib_remote.c if (private->encrypted) { private 398 lib/cib/cib_remote.c private->server, private->port, private 417 lib/cib/cib_remote.c crm_xml_add(login, PCMK_XA_USER, private->user); private 418 lib/cib/cib_remote.c crm_xml_add(login, PCMK__XA_PASSWORD, private->passwd); private 461 lib/cib/cib_remote.c private->timeout_sec = 60; private 472 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; private 478 lib/cib/cib_remote.c if (private->passwd == NULL) { private 479 lib/cib/cib_remote.c if (private->out == NULL) { private 483 lib/cib/cib_remote.c pcmk__text_prompt("Password", false, &(private->passwd)); private 485 lib/cib/cib_remote.c private->out->prompt("Password", false, &(private->passwd)); private 489 lib/cib/cib_remote.c if (private->server == NULL || private->user == NULL) { private 494 lib/cib/cib_remote.c rc = cib_tls_signon(cib, &(private->command), FALSE); private 499 lib/cib/cib_remote.c rc = cib_tls_signon(cib, &(private->callback), TRUE); private 504 lib/cib/cib_remote.c private->server, private->port, name); private 510 lib/cib/cib_remote.c private->server, private->port, name, pcmk_strerror(rc)); private 540 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; private 542 lib/cib/cib_remote.c free(private->server); private 543 lib/cib/cib_remote.c free(private->user); private 544 lib/cib/cib_remote.c free(private->passwd); private 547 lib/cib/cib_remote.c free(private); private 559 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; private 564 lib/cib/cib_remote.c pcmk__remote_send_xml(&private->callback, notify_msg); private 596 lib/cib/cib_remote.c cib_remote_opaque_t *private = cib->variant_opaque; private 600 lib/cib/cib_remote.c *async_id = private->callback.token; private 604 lib/cib/cib_remote.c *sync_id = private->command.token; private 613 lib/cib/cib_remote.c cib_remote_opaque_t *private = NULL; private 620 lib/cib/cib_remote.c private = calloc(1, sizeof(cib_remote_opaque_t)); private 622 lib/cib/cib_remote.c if (private == NULL) { private 628 lib/cib/cib_remote.c cib->variant_opaque = private; private 630 lib/cib/cib_remote.c private->server = pcmk__str_copy(server); private 631 lib/cib/cib_remote.c private->user = pcmk__str_copy(user); private 632 lib/cib/cib_remote.c private->passwd = pcmk__str_copy(passwd); private 633 lib/cib/cib_remote.c private->port = port; private 634 lib/cib/cib_remote.c private->encrypted = encrypted; private 652 lib/cib/cib_remote.c cib_remote_opaque_t *private; private 658 lib/cib/cib_remote.c private = cib->variant_opaque; private 659 lib/cib/cib_remote.c private->out = out; private 67 lib/common/ipc_controld.c struct controld_api_private_s *private = NULL; private 75 lib/common/ipc_controld.c private = api->api_data; private 83 lib/common/ipc_controld.c private->client_uuid = pcmk__getpid_s(); private 106 lib/common/ipc_controld.c struct controld_api_private_s *private = api->api_data; private 111 lib/common/ipc_controld.c hello = create_hello_message(private->client_uuid, client_name, private 204 lib/common/ipc_controld.c struct controld_api_private_s *private = api->api_data; private 218 lib/common/ipc_controld.c return private->replies_expected > 0; private 221 lib/common/ipc_controld.c if (private->replies_expected > 0) { private 222 lib/common/ipc_controld.c private->replies_expected--; private 328 lib/common/ipc_controld.c struct controld_api_private_s *private = NULL; private 336 lib/common/ipc_controld.c private = api->api_data; private 342 lib/common/ipc_controld.c sender_system = crm_strdup_printf("%s_%s", private->client_uuid, private 359 lib/common/ipc_controld.c struct controld_api_private_s *private = api->api_data; private 361 lib/common/ipc_controld.c private->replies_expected++; private 627 lib/common/ipc_controld.c struct controld_api_private_s *private = api->api_data; private 629 lib/common/ipc_controld.c return private->replies_expected; private 126 lib/common/ipc_pacemakerd.c struct pacemakerd_api_private_s *private = NULL; private 134 lib/common/ipc_pacemakerd.c private = api->api_data; private 135 lib/common/ipc_pacemakerd.c private->state = pcmk_pacemakerd_state_invalid; private 139 lib/common/ipc_pacemakerd.c private->client_uuid = pcmk__getpid_s(); private 155 lib/common/ipc_pacemakerd.c struct pacemakerd_api_private_s *private = NULL; private 160 lib/common/ipc_pacemakerd.c private = api->api_data; private 161 lib/common/ipc_pacemakerd.c private->state = pcmk_pacemakerd_state_invalid; private 169 lib/common/ipc_pacemakerd.c struct pacemakerd_api_private_s *private = NULL; private 174 lib/common/ipc_pacemakerd.c private = api->api_data; private 175 lib/common/ipc_pacemakerd.c private->state = pcmk_pacemakerd_state_invalid; private 300 lib/common/ipc_pacemakerd.c pacemakerd_api_private_t *private; private 309 lib/common/ipc_pacemakerd.c private = api->api_data; private 310 lib/common/ipc_pacemakerd.c pcmk__assert(private != NULL); private 312 lib/common/ipc_pacemakerd.c sender_system = crm_strdup_printf("%s_%s", private->client_uuid, private 30 lib/common/ipc_schedulerd.c struct schedulerd_api_private_s *private = NULL; private 38 lib/common/ipc_schedulerd.c private = api->api_data; private 40 lib/common/ipc_schedulerd.c private->client_uuid = pcmk__getpid_s(); private 158 lib/common/ipc_schedulerd.c schedulerd_api_private_t *private; private 167 lib/common/ipc_schedulerd.c private = api->api_data; private 168 lib/common/ipc_schedulerd.c pcmk__assert(private != NULL); private 170 lib/common/ipc_schedulerd.c sender_system = crm_strdup_printf("%s_%s", private->client_uuid, private 251 lib/fencing/st_client.c foreach_notify_entry (stonith_private_t *private, private 255 lib/fencing/st_client.c private->notify_refcnt++; private 256 lib/fencing/st_client.c g_list_foreach(private->notify_list, func, user_data); private 257 lib/fencing/st_client.c private->notify_refcnt--; private 258 lib/fencing/st_client.c if ((private->notify_refcnt == 0) && private 259 lib/fencing/st_client.c private->notify_deletes) { private 260 lib/fencing/st_client.c GList *list_item = private->notify_list; private 262 lib/fencing/st_client.c private->notify_deletes = FALSE; private 270 lib/fencing/st_client.c private->notify_list = private 271 lib/fencing/st_client.c g_list_delete_link(private->notify_list, list_item); private 893 lib/fencing/st_client.c stonith_private_t *private = stonith->st_private; private 896 lib/fencing/st_client.c private->op_callback = NULL; private 897 lib/fencing/st_client.c g_hash_table_destroy(private->stonith_op_callback_table); private 898 lib/fencing/st_client.c private->stonith_op_callback_table = pcmk__intkey_table(stonith_destroy_op_callback); private 901 lib/fencing/st_client.c private->op_callback = NULL; private 904 lib/fencing/st_client.c pcmk__intkey_table_remove(private->stonith_op_callback_table, call_id); private 951 lib/fencing/st_client.c stonith_private_t *private = NULL; private 958 lib/fencing/st_client.c private = stonith->st_private; private 976 lib/fencing/st_client.c cb_info = pcmk__intkey_table_lookup(private->stonith_op_callback_table, private 987 lib/fencing/st_client.c } else if ((private->op_callback == NULL) && !pcmk__result_ok(&result)) { private 996 lib/fencing/st_client.c if (private->op_callback != NULL) { private 999 lib/fencing/st_client.c private->op_callback); private 1055 lib/fencing/st_client.c stonith_private_t *private = st->st_private; private 1057 lib/fencing/st_client.c callback = pcmk__intkey_table_lookup(private->stonith_op_callback_table, private 1073 lib/fencing/st_client.c stonith_private_t *private = NULL; private 1076 lib/fencing/st_client.c private = st->st_private; private 1093 lib/fencing/st_client.c foreach_notify_entry(private, stonith_send_notification, &blob); private 1249 lib/fencing/st_client.c stonith_private_t *private = NULL; private 1251 lib/fencing/st_client.c private = stonith->st_private; private 1252 lib/fencing/st_client.c crm_trace("Adding callback for %s events (%d)", event, g_list_length(private->notify_list)); private 1258 lib/fencing/st_client.c list_item = g_list_find_custom(private->notify_list, new_client, stonithlib_GCompareFunc); private 1266 lib/fencing/st_client.c private->notify_list = g_list_append(private->notify_list, new_client); private 1270 lib/fencing/st_client.c crm_trace("Callback added (%d)", g_list_length(private->notify_list)); private 1292 lib/fencing/st_client.c stonith_private_t *private = stonith->st_private; private 1295 lib/fencing/st_client.c foreach_notify_entry(private, del_notify_entry, stonith); private 1307 lib/fencing/st_client.c list_item = g_list_find_custom(private->notify_list, new_client, stonithlib_GCompareFunc); private 1314 lib/fencing/st_client.c if (private->notify_refcnt) { private 1316 lib/fencing/st_client.c private->notify_deletes = TRUE; private 1318 lib/fencing/st_client.c private->notify_list = g_list_remove(private->notify_list, list_client); private 1337 lib/fencing/st_client.c stonith_private_t *private = NULL; private 1341 lib/fencing/st_client.c private = stonith->st_private; private 1344 lib/fencing/st_client.c private->op_callback = callback; private 1372 lib/fencing/st_client.c pcmk__intkey_table_insert(private->stonith_op_callback_table, call_id, private 1679 lib/fencing/st_client.c stonith_private_t *private = NULL; private 1682 lib/fencing/st_client.c private = stonith_api->st_private; private 1684 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { private 1685 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { private 1686 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); private 1689 lib/fencing/st_client.c pcmk__ipc_free_client_buffer(private->ipc); private 1692 lib/fencing/st_client.c if (!crm_ipc_connected(private->ipc)) { private 1716 lib/fencing/st_client.c stonith_private_t *private = stonith->st_private; private 1718 lib/fencing/st_client.c crm_trace("Removing %d callbacks", g_hash_table_size(private->stonith_op_callback_table)); private 1719 lib/fencing/st_client.c g_hash_table_destroy(private->stonith_op_callback_table); private 1721 lib/fencing/st_client.c crm_trace("Destroying %d notification clients", g_list_length(private->notify_list)); private 1722 lib/fencing/st_client.c g_list_free_full(private->notify_list, free); private 1869 lib/fencing/st_client.c stonith_private_t *private = NULL; private 1876 lib/fencing/st_client.c private = calloc(1, sizeof(stonith_private_t)); private 1877 lib/fencing/st_client.c if (private == NULL) { private 1881 lib/fencing/st_client.c new_stonith->st_private = private; private 1883 lib/fencing/st_client.c private->stonith_op_callback_table = pcmk__intkey_table(stonith_destroy_op_callback); private 1884 lib/fencing/st_client.c private->notify_list = NULL; private 1885 lib/fencing/st_client.c private->notify_refcnt = 0; private 1886 lib/fencing/st_client.c private->notify_deletes = FALSE; private 2838 lib/fencing/st_client.c stonith_private_t *private = stonith->st_private; private 2840 lib/fencing/st_client.c if (private->stonith_op_callback_table == NULL) { private 2843 lib/fencing/st_client.c return g_hash_table_foreach(private->stonith_op_callback_table, private 529 lib/lrmd/lrmd_client.c lrmd_private_t *private = NULL; private 533 lib/lrmd/lrmd_client.c private = lrmd->lrmd_private; private 534 lib/lrmd/lrmd_client.c switch (private->type) { private 536 lib/lrmd/lrmd_client.c while (crm_ipc_ready(private->ipc)) { private 537 lib/lrmd/lrmd_client.c if (crm_ipc_read(private->ipc) > 0) { private 538 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); private 541 lib/lrmd/lrmd_client.c pcmk__ipc_free_client_buffer(private->ipc); private 550 lib/lrmd/lrmd_client.c private->type); private 207 lib/pacemaker/pcmk_sched_fencing.c pcmk__ar_ordered, rsc->private->scheduler); private 403 lib/pengine/native.c } else if (pcmk__str_eq(rsc->private->pending_action, "probe", private 4681 lib/pengine/unpack.c history->rsc->private->pending_action = strdup("probe"); private 4682 lib/pengine/unpack.c history->rsc->private->pending_node = history->node;