pending 172 crmd/crmd_lrm.h gboolean process_lrm_event(lrm_state_t * lrm_state, lrmd_event_data_t * op, struct recurring_op_s *pending); pending 415 crmd/lrm.c struct recurring_op_s *pending = NULL; pending 440 crmd/lrm.c while (g_hash_table_iter_next(&gIter, NULL, (void **)&pending)) { pending 442 crmd/lrm.c if (pending->interval == 0) { pending 454 crmd/lrm.c while (g_hash_table_iter_next(&gIter, (gpointer*)&key, (gpointer*)&pending)) { pending 455 crmd/lrm.c do_crm_log(log_level, "Pending action: %s (%s)", key, pending->op_key); pending 490 crmd/lrm.c while (g_hash_table_iter_next(&hIter, (gpointer*)&key, (gpointer*)&pending)) { pending 491 crmd/lrm.c if (crm_str_eq(entry->id, pending->rsc_id, TRUE)) { pending 493 crmd/lrm.c pending->interval == 0 ? "A" : "Recurring a", pending 494 crmd/lrm.c key, pending->op_key, when); pending 933 crmd/lrm.c struct recurring_op_s *pending = value; pending 935 crmd/lrm.c if (crm_str_eq(rsc, pending->rsc_id, TRUE)) { pending 937 crmd/lrm.c pending->op_key, pending->call_id, rsc); pending 1164 crmd/lrm.c struct recurring_op_s *pending = NULL; pending 1172 crmd/lrm.c pending = g_hash_table_lookup(lrm_state->pending_ops, key); pending 1174 crmd/lrm.c if (pending) { pending 1175 crmd/lrm.c if (remove && pending->remove == FALSE) { pending 1176 crmd/lrm.c pending->remove = TRUE; pending 1180 crmd/lrm.c if (pending->cancelled) { pending 1186 crmd/lrm.c pending->cancelled = TRUE; pending 1195 crmd/lrm.c rc = lrm_state_cancel(lrm_state, pending->rsc_id, pending->op_type, pending->interval); pending 2230 crmd/lrm.c struct recurring_op_s *pending = NULL; pending 2232 crmd/lrm.c pending = calloc(1, sizeof(struct recurring_op_s)); pending 2235 crmd/lrm.c pending->call_id = call_id; pending 2236 crmd/lrm.c pending->interval = op->interval; pending 2237 crmd/lrm.c pending->op_type = strdup(operation); pending 2238 crmd/lrm.c pending->op_key = strdup(op_id); pending 2239 crmd/lrm.c pending->rsc_id = strdup(rsc->id); pending 2240 crmd/lrm.c pending->start_time = time(NULL); pending 2241 crmd/lrm.c pending->user_data = strdup(op->user_data); pending 2242 crmd/lrm.c g_hash_table_replace(lrm_state->pending_ops, call_id_s, pending); pending 2258 crmd/lrm.c pending->params = op->params; pending 2424 crmd/lrm.c process_lrm_event(lrm_state_t * lrm_state, lrmd_event_data_t * op, struct recurring_op_s *pending) pending 2440 crmd/lrm.c if(pending == NULL) { pending 2442 crmd/lrm.c pending = g_hash_table_lookup(lrm_state->pending_ops, op_id); pending 2472 crmd/lrm.c } else if (pending == NULL) { pending 2482 crmd/lrm.c } else if (pending->remove) { pending 2486 crmd/lrm.c } else if (pending && op->rsc_deleted) { pending 155 crmd/te_callbacks.c if (transition_graph->pending == 0) { pending 145 include/crm/pengine/status.h gboolean pending; pending 110 include/crm/transition.h int pending; pending 1378 lib/pengine/unpack.c this_node->details->pending = TRUE; pending 1406 lib/pengine/unpack.c this_node->details->pending = TRUE; pending 1549 lib/pengine/unpack.c this_node->details->pending ? "pending" : pending 570 lib/pengine/utils.c } else if (action->node->details->pending) { pending 67 lib/services/dbus.c pcmk_dbus_find_error(DBusPendingCall *pending, DBusMessage *reply, pending 74 lib/services/dbus.c if(pending == NULL) { pending 155 lib/services/dbus.c DBusPendingCall* pending = NULL; pending 171 lib/services/dbus.c if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) { pending 181 lib/services/dbus.c if(pending) { pending 183 lib/services/dbus.c dbus_pending_call_block(pending); pending 186 lib/services/dbus.c reply = dbus_pending_call_steal_reply(pending); pending 189 lib/services/dbus.c (void)pcmk_dbus_find_error(pending, reply, error); pending 191 lib/services/dbus.c if(pending) { pending 193 lib/services/dbus.c dbus_pending_call_unref(pending); pending 201 lib/services/dbus.c void(*done)(DBusPendingCall *pending, void *user_data), pending 205 lib/services/dbus.c DBusPendingCall* pending = NULL; pending 218 lib/services/dbus.c if (!dbus_connection_send_with_reply(connection, msg, &pending, timeout)) { pending 222 lib/services/dbus.c } else if (pending == NULL) { pending 228 lib/services/dbus.c if (dbus_pending_call_get_completed(pending)) { pending 233 lib/services/dbus.c done(pending, user_data); pending 234 lib/services/dbus.c pending = NULL; pending 236 lib/services/dbus.c CRM_ASSERT(dbus_pending_call_set_notify(pending, done, user_data, NULL)); pending 241 lib/services/dbus.c CRM_ASSERT(dbus_pending_call_set_notify(pending, done, user_data, NULL)); pending 243 lib/services/dbus.c return pending; pending 371 lib/services/dbus.c pcmk_dbus_lookup_cb(DBusPendingCall *pending, void *user_data) pending 376 lib/services/dbus.c if(pending) { pending 377 lib/services/dbus.c reply = dbus_pending_call_steal_reply(pending); pending 392 lib/services/dbus.c void *userdata, DBusPendingCall **pending, int timeout) pending 430 lib/services/dbus.c if (pending != NULL) { pending 431 lib/services/dbus.c *pending = _pending; pending 28 lib/services/pcmk-dbus.h void(*done)(DBusPendingCall *pending, void *user_data), void *user_data, int timeout); pending 40 lib/services/pcmk-dbus.h DBusPendingCall **pending, int timeout); pending 43 lib/services/pcmk-dbus.h bool pcmk_dbus_find_error(DBusPendingCall *pending, DBusMessage *reply, pending 507 lib/services/services.c services_set_op_pending(svc_action_t *op, DBusPendingCall *pending) pending 509 lib/services/services.c if (op->opaque->pending && (op->opaque->pending != pending)) { pending 510 lib/services/services.c if (pending) { pending 511 lib/services/services.c crm_info("Lost pending %s DBus call (%p)", op->id, op->opaque->pending); pending 513 lib/services/services.c crm_trace("Done with pending %s DBus call (%p)", op->id, op->opaque->pending); pending 515 lib/services/services.c dbus_pending_call_unref(op->opaque->pending); pending 517 lib/services/services.c op->opaque->pending = pending; pending 518 lib/services/services.c if (pending) { pending 519 lib/services/services.c crm_trace("Updated pending %s DBus call (%p)", op->id, pending); pending 540 lib/services/services.c if(op->opaque->pending) { pending 541 lib/services/services.c crm_trace("Cleaning up pending dbus call %p %s for %s", op->opaque->pending, op->action, op->rsc); pending 542 lib/services/services.c if(dbus_pending_call_get_completed(op->opaque->pending)) { pending 545 lib/services/services.c dbus_pending_call_cancel(op->opaque->pending); pending 546 lib/services/services.c dbus_pending_call_unref(op->opaque->pending); pending 547 lib/services/services.c op->opaque->pending = NULL; pending 46 lib/services/services_private.h DBusPendingCall* pending; pending 89 lib/services/services_private.h void services_set_op_pending(svc_action_t *op, DBusPendingCall *pending); pending 43 lib/services/systemd.c void(*done)(DBusPendingCall *pending, void *user_data), pending 126 lib/services/systemd.c void *userdata, DBusPendingCall **pending, int timeout) pending 130 lib/services/systemd.c name, callback, userdata, pending, timeout) pending 183 lib/services/systemd.c systemd_daemon_reload_complete(DBusPendingCall *pending, void *user_data) pending 190 lib/services/systemd.c if(pending) { pending 191 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); pending 194 lib/services/systemd.c if (pcmk_dbus_find_error(pending, reply, &error)) { pending 202 lib/services/systemd.c if(pending) { pending 203 lib/services/systemd.c dbus_pending_call_unref(pending); pending 282 lib/services/systemd.c systemd_loadunit_cb(DBusPendingCall *pending, void *user_data) pending 287 lib/services/systemd.c if(pending) { pending 288 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); pending 291 lib/services/systemd.c crm_trace("Got result: %p for %p / %p for %s", reply, pending, op->opaque->pending, op->id); pending 293 lib/services/systemd.c CRM_LOG_ASSERT(pending == op->opaque->pending); pending 308 lib/services/systemd.c DBusPendingCall* pending = NULL; pending 348 lib/services/systemd.c pending = systemd_send(msg, systemd_loadunit_cb, op, op->timeout); pending 349 lib/services/systemd.c if(pending) { pending 350 lib/services/systemd.c services_set_op_pending(op, pending); pending 552 lib/services/systemd.c systemd_async_dispatch(DBusPendingCall *pending, void *user_data) pending 557 lib/services/systemd.c if(pending) { pending 558 lib/services/systemd.c reply = dbus_pending_call_steal_reply(pending); pending 561 lib/services/systemd.c crm_trace("Got result: %p for %p for %s, %s", reply, pending, op->rsc, op->action); pending 563 lib/services/systemd.c CRM_LOG_ASSERT(pending == op->opaque->pending); pending 612 lib/services/systemd.c DBusPendingCall *pending = NULL; pending 617 lib/services/systemd.c op, (op->synchronous? NULL : &pending), pending 623 lib/services/systemd.c } else if (pending) { pending 624 lib/services/systemd.c services_set_op_pending(op, pending); pending 710 lib/services/systemd.c DBusPendingCall *pending = systemd_send(msg, systemd_async_dispatch, pending 714 lib/services/systemd.c if(pending) { pending 715 lib/services/systemd.c services_set_op_pending(op, pending); pending 781 lib/services/systemd.c if (op->opaque->pending) { pending 366 lib/services/upstart.c upstart_async_dispatch(DBusPendingCall *pending, void *user_data) pending 373 lib/services/upstart.c if(pending) { pending 374 lib/services/upstart.c reply = dbus_pending_call_steal_reply(pending); pending 377 lib/services/upstart.c if (pcmk_dbus_find_error(pending, reply, &error)) { pending 405 lib/services/upstart.c CRM_LOG_ASSERT(pending == op->opaque->pending); pending 456 lib/services/upstart.c DBusPendingCall *pending = NULL; pending 460 lib/services/upstart.c op->synchronous?NULL:&pending, op->timeout); pending 469 lib/services/upstart.c } else if (pending) { pending 470 lib/services/upstart.c services_set_op_pending(op, pending); pending 510 lib/services/upstart.c DBusPendingCall* pending = pcmk_dbus_send(msg, upstart_proxy, upstart_async_dispatch, op, op->timeout); pending 513 lib/services/upstart.c if(pending) { pending 514 lib/services/upstart.c services_set_op_pending(op, pending); pending 263 lib/transition/graph.c graph->pending = 0; pending 279 lib/transition/graph.c graph->pending++; pending 287 lib/transition/graph.c if (graph->batch_limit > 0 && graph->pending >= graph->batch_limit) { pending 311 lib/transition/graph.c graph->pending++; pending 320 lib/transition/graph.c if (graph->pending == 0 && graph->fired == 0) { pending 342 lib/transition/graph.c graph->id, graph->completed, graph->pending, graph->fired, pending 147 lib/transition/utils.c char *pending = NULL; pending 169 lib/transition/utils.c pending = add_list_element(pending, id_string); pending 176 lib/transition/utils.c pending = add_list_element(pending, id_string); pending 190 lib/transition/utils.c synapse->priority, pending ? pending : "none"); pending 213 lib/transition/utils.c free(pending); pending 2946 tools/crm_mon.c } else if (node->details->pending) { pending 2953 tools/crm_mon.c } else if (node->details->pending) { pending 3131 tools/crm_mon.c fprintf(stream, "pending=\"%s\" ", node->details->pending ? "true" : "false"); pending 110 tools/crm_simulate.c } else if (node->details->pending) { pending 117 tools/crm_simulate.c } else if (node->details->pending) {