pending 400 daemons/controld/controld_execd.c active_op_t *pending = NULL; pending 426 daemons/controld/controld_execd.c while (g_hash_table_iter_next(&gIter, NULL, (void **)&pending)) { pending 428 daemons/controld/controld_execd.c if (pending->interval_ms == 0) { pending 442 daemons/controld/controld_execd.c while (g_hash_table_iter_next(&gIter, (gpointer*)&key, (gpointer*)&pending)) { pending 443 daemons/controld/controld_execd.c do_crm_log(log_level, "Pending action: %s (%s)", key, pending->op_key); pending 478 daemons/controld/controld_execd.c while (g_hash_table_iter_next(&hIter, (gpointer*)&key, (gpointer*)&pending)) { pending 479 daemons/controld/controld_execd.c if (pcmk__str_eq(entry->id, pending->rsc_id, pcmk__str_none)) { pending 481 daemons/controld/controld_execd.c pending->interval_ms == 0 ? "A" : "Recurring a", pending 482 daemons/controld/controld_execd.c key, pending->op_key, when); pending 696 daemons/controld/controld_execd.c active_op_t *pending = value; pending 698 daemons/controld/controld_execd.c if (pcmk__str_eq(rsc, pending->rsc_id, pcmk__str_none)) { pending 700 daemons/controld/controld_execd.c pending->op_key, pending->call_id, rsc); pending 795 daemons/controld/controld_execd.c active_op_t *pending = NULL; pending 803 daemons/controld/controld_execd.c pending = g_hash_table_lookup(lrm_state->active_ops, key); pending 805 daemons/controld/controld_execd.c if (pending) { pending 806 daemons/controld/controld_execd.c if (remove && !pcmk_is_set(pending->flags, active_op_remove)) { pending 807 daemons/controld/controld_execd.c controld_set_active_op_flags(pending, active_op_remove); pending 811 daemons/controld/controld_execd.c if (pcmk_is_set(pending->flags, active_op_cancelled)) { pending 816 daemons/controld/controld_execd.c controld_set_active_op_flags(pending, active_op_cancelled); pending 825 daemons/controld/controld_execd.c rc = lrm_state_cancel(lrm_state, pending->rsc_id, pending->op_type, pending 826 daemons/controld/controld_execd.c pending->interval_ms); pending 2027 daemons/controld/controld_execd.c active_op_t *pending = NULL; pending 2029 daemons/controld/controld_execd.c pending = pcmk__assert_alloc(1, sizeof(active_op_t)); pending 2032 daemons/controld/controld_execd.c pending->call_id = call_id; pending 2033 daemons/controld/controld_execd.c pending->interval_ms = op->interval_ms; pending 2034 daemons/controld/controld_execd.c pending->op_type = pcmk__str_copy(operation); pending 2035 daemons/controld/controld_execd.c pending->op_key = pcmk__str_copy(op_id); pending 2036 daemons/controld/controld_execd.c pending->rsc_id = pcmk__str_copy(rsc->id); pending 2037 daemons/controld/controld_execd.c pending->start_time = time(NULL); pending 2038 daemons/controld/controld_execd.c pending->user_data = pcmk__str_copy(op->user_data); pending 2040 daemons/controld/controld_execd.c &(pending->lock_time)) != pcmk_ok) { pending 2041 daemons/controld/controld_execd.c pending->lock_time = 0; pending 2043 daemons/controld/controld_execd.c g_hash_table_replace(lrm_state->active_ops, call_id_s, pending); pending 2055 daemons/controld/controld_execd.c pending->params = op->params; pending 2227 daemons/controld/controld_execd.c active_op_t *pending, const xmlNode *action_xml) pending 2290 daemons/controld/controld_execd.c if(pending == NULL) { pending 2293 daemons/controld/controld_execd.c pending = g_hash_table_lookup(lrm_state->active_ops, op_id); pending 2322 daemons/controld/controld_execd.c time_t lock_time = (pending == NULL)? 0 : pending->lock_time; pending 2352 daemons/controld/controld_execd.c } else if (pending == NULL) { pending 2364 daemons/controld/controld_execd.c } else if (pcmk_is_set(pending->flags, active_op_remove)) { pending 2378 daemons/controld/controld_execd.c if (did_lrm_rsc_op_fail(lrm_state, pending->rsc_id, pending 2379 daemons/controld/controld_execd.c pending->op_type, pending->interval_ms)) { pending 176 daemons/controld/controld_lrm.h active_op_t *pending, const xmlNode *action_xml); pending 119 daemons/controld/controld_te_callbacks.c if ((controld_globals.transition_graph->pending == 0) && (max > 1)) { pending 255 daemons/controld/controld_te_callbacks.c if ((controld_globals.transition_graph->pending == 0) pending 88 include/crm/common/nodes.h gboolean pending; // Whether controller membership is pending pending 122 include/pcmki/pcmki_transition.h int pending; pending 44 lib/common/nodes.c return (node != NULL) && node->details->pending; pending 28 lib/common/tests/nodes/pcmk_node_is_pending_test.c .pending = TRUE, pending 42 lib/common/tests/nodes/pcmk_node_is_pending_test.c .pending = FALSE, pending 2308 lib/fencing/st_client.c stonith_history_t *new = NULL, *pending = NULL, *hp, *np, *tmp; pending 2332 lib/fencing/st_client.c hp->next = pending; pending 2333 lib/fencing/st_client.c pending = hp; pending 2339 lib/fencing/st_client.c if (pending) { pending 2340 lib/fencing/st_client.c stonith_history_t *last_pending = pending; pending 2347 lib/fencing/st_client.c new = pending; pending 431 lib/pacemaker/pcmk_graph_consumer.c graph->pending = 0; pending 445 lib/pacemaker/pcmk_graph_consumer.c graph->pending++; pending 449 lib/pacemaker/pcmk_graph_consumer.c graph->id, graph->completed, graph->pending); pending 456 lib/pacemaker/pcmk_graph_consumer.c && (graph->pending >= graph->batch_limit)) { pending 482 lib/pacemaker/pcmk_graph_consumer.c graph->pending++; pending 491 lib/pacemaker/pcmk_graph_consumer.c if ((graph->pending == 0) && (graph->fired == 0)) { pending 517 lib/pacemaker/pcmk_graph_consumer.c graph->id, graph->completed, graph->pending, graph->fired, pending 122 lib/pacemaker/pcmk_graph_logging.c GString *pending = NULL; pending 128 lib/pacemaker/pcmk_graph_logging.c pcmk__add_word(&pending, 1024, pcmk__xe_id(input->xml)); pending 135 lib/pacemaker/pcmk_graph_logging.c pcmk__add_word(&pending, 1024, pcmk__xe_id(input->xml)); pending 138 lib/pacemaker/pcmk_graph_logging.c return pending; pending 182 lib/pacemaker/pcmk_graph_logging.c const char *pending = "none"; pending 188 lib/pacemaker/pcmk_graph_logging.c pending = (const char *) g_pending->str; pending 194 lib/pacemaker/pcmk_graph_logging.c (pcmk__graph_action_t *) lpc->data, pending); pending 987 lib/pengine/native.c const char *pending = print_pending? native_pending_task(rsc) : NULL; pending 1025 lib/pengine/native.c PCMK_XA_PENDING, pending, pending 351 lib/pengine/pe_actions.c && action->node->details->pending) { pending 1866 lib/pengine/pe_output.c } else if (node->details->pending) { pending 1873 lib/pengine/pe_output.c } else if (node->details->pending) { pending 2054 lib/pengine/pe_output.c const char *pending = pcmk__btoa(node->details->pending); pending 2074 lib/pengine/pe_output.c PCMK_XA_PENDING, pending, pending 2589 lib/pengine/pe_output.c if (node->details->unclean || node->details->pending pending 1762 lib/pengine/unpack.c this_node->details->pending = TRUE; pending 1788 lib/pengine/unpack.c this_node->details->pending = TRUE; pending 1930 lib/pengine/unpack.c this_node->details->pending ? "pending" : pending 330 lib/services/dbus.c pcmk_dbus_find_error(const DBusPendingCall *pending, DBusMessage *reply, pending 337 lib/services/dbus.c if (pending == NULL) { pending 417 lib/services/dbus.c DBusPendingCall* pending = NULL; pending 433 lib/services/dbus.c if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) { pending 443 lib/services/dbus.c if (pending) { pending 445 lib/services/dbus.c dbus_pending_call_block(pending); pending 448 lib/services/dbus.c reply = dbus_pending_call_steal_reply(pending); pending 451 lib/services/dbus.c (void) pcmk_dbus_find_error(pending, reply, error); pending 453 lib/services/dbus.c if (pending) { pending 455 lib/services/dbus.c dbus_pending_call_unref(pending); pending 477 lib/services/dbus.c void (*done)(DBusPendingCall *pending, void *user_data), pending 481 lib/services/dbus.c DBusPendingCall* pending = NULL; pending 493 lib/services/dbus.c if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) { pending 497 lib/services/dbus.c } else if (pending == NULL) { pending 503 lib/services/dbus.c if (dbus_pending_call_get_completed(pending)) { pending 509 lib/services/dbus.c if (!dbus_pending_call_set_notify(pending, done, user_data, NULL)) { pending 512 lib/services/dbus.c return pending; pending 657 lib/services/dbus.c async_query_result_cb(DBusPendingCall *pending, void *user_data) pending 662 lib/services/dbus.c if (pending) { pending 663 lib/services/dbus.c reply = dbus_pending_call_steal_reply(pending); pending 698 lib/services/dbus.c DBusPendingCall **pending, int timeout) pending 760 lib/services/dbus.c if (pending) { pending 761 lib/services/dbus.c *pending = local_pending; pending 27 lib/services/pcmk-dbus.h void(*done)(DBusPendingCall *pending, void *user_data), void *user_data, int timeout); pending 39 lib/services/pcmk-dbus.h DBusPendingCall **pending, int timeout); pending 42 lib/services/pcmk-dbus.h bool pcmk_dbus_find_error(const DBusPendingCall *pending, DBusMessage *reply, pending 499 lib/services/services.c services_set_op_pending(svc_action_t *op, DBusPendingCall *pending) pending 501 lib/services/services.c if (op->opaque->pending && (op->opaque->pending != pending)) { pending 502 lib/services/services.c if (pending) { pending 503 lib/services/services.c crm_info("Lost pending %s DBus call (%p)", op->id, op->opaque->pending); pending 505 lib/services/services.c crm_trace("Done with pending %s DBus call (%p)", op->id, op->opaque->pending); pending 507 lib/services/services.c dbus_pending_call_unref(op->opaque->pending); pending 509 lib/services/services.c op->opaque->pending = pending; pending 510 lib/services/services.c if (pending) { pending 511 lib/services/services.c crm_trace("Updated pending %s DBus call (%p)", op->id, pending); pending 532 lib/services/services.c if(op->opaque->pending) { pending 533 lib/services/services.c if (dbus_pending_call_get_completed(op->opaque->pending)) { pending 541 lib/services/services.c dbus_pending_call_cancel(op->opaque->pending); pending 42 lib/services/services_private.h DBusPendingCall* pending; pending 98 lib/services/services_private.h void services_set_op_pending(svc_action_t *op, DBusPendingCall *pending); pending 80 lib/services/systemd.c void(*done)(DBusPendingCall *pending, void *user_data), pending 163 lib/services/systemd.c void *userdata, DBusPendingCall **pending, int timeout) pending 167 lib/services/systemd.c name, callback, userdata, pending, timeout) pending 252 lib/services/systemd.c systemd_daemon_reload_complete(DBusPendingCall *pending, void *user_data) pending 259 lib/services/systemd.c if(pending) { pending 260 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); pending 263 lib/services/systemd.c if (pcmk_dbus_find_error(pending, reply, &error)) { pending 272 lib/services/systemd.c if(pending) { pending 273 lib/services/systemd.c dbus_pending_call_unref(pending); pending 397 lib/services/systemd.c loadunit_completed(DBusPendingCall *pending, void *user_data) pending 405 lib/services/systemd.c if (pending != NULL) { pending 406 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); pending 410 lib/services/systemd.c CRM_LOG_ASSERT(pending == op->opaque->pending); pending 440 lib/services/systemd.c DBusPendingCall *pending = NULL; pending 501 lib/services/systemd.c pending = systemd_send(msg, loadunit_completed, op, op->timeout); pending 502 lib/services/systemd.c if (pending == NULL) { pending 511 lib/services/systemd.c services_set_op_pending(op, pending); pending 776 lib/services/systemd.c unit_method_complete(DBusPendingCall *pending, void *user_data) pending 784 lib/services/systemd.c if (pending != NULL) { pending 785 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); pending 789 lib/services/systemd.c CRM_LOG_ASSERT(pending == op->opaque->pending); pending 958 lib/services/systemd.c DBusPendingCall *pending = NULL; pending 963 lib/services/systemd.c op, (op->synchronous? NULL : &pending), pending 969 lib/services/systemd.c } else if (pending == NULL) { // Could not get ActiveState property pending 976 lib/services/systemd.c services_set_op_pending(op, pending); pending 1033 lib/services/systemd.c DBusPendingCall *pending = systemd_send(msg, unit_method_complete, op, pending 1037 lib/services/systemd.c if (pending == NULL) { pending 1043 lib/services/systemd.c services_set_op_pending(op, pending); pending 461 lib/services/upstart.c job_method_complete(DBusPendingCall *pending, void *user_data) pending 468 lib/services/upstart.c if (pending != NULL) { pending 469 lib/services/upstart.c reply = dbus_pending_call_steal_reply(pending); pending 474 lib/services/upstart.c if (pcmk_dbus_find_error(pending, reply, &error)) { pending 502 lib/services/upstart.c CRM_LOG_ASSERT(pending == op->opaque->pending); pending 581 lib/services/upstart.c DBusPendingCall *pending = NULL; pending 594 lib/services/upstart.c op->synchronous? NULL : &pending, pending 602 lib/services/upstart.c } else if (pending == NULL) { pending 608 lib/services/upstart.c services_set_op_pending(op, pending); pending 656 lib/services/upstart.c DBusPendingCall *pending = pcmk_dbus_send(msg, upstart_proxy, pending 660 lib/services/upstart.c if (pending == NULL) { pending 667 lib/services/upstart.c services_set_op_pending(op, pending); pending 207 maint/gnulib/lib/sigprocmask.c sigset_t pending = 0; pending 212 maint/gnulib/lib/sigprocmask.c pending |= 1U << sig; pending 213 maint/gnulib/lib/sigprocmask.c *set = pending;