r 503 daemons/controld/controld_te_actions.c struct te_peer_s *r = NULL; r 509 daemons/controld/controld_te_actions.c r = g_hash_table_lookup(te_targets, target); r 510 daemons/controld/controld_te_actions.c if(r == NULL) { r 511 daemons/controld/controld_te_actions.c r = pcmk__assert_alloc(1, sizeof(struct te_peer_s)); r 512 daemons/controld/controld_te_actions.c r->name = pcmk__str_copy(target); r 513 daemons/controld/controld_te_actions.c g_hash_table_insert(te_targets, r->name, r); r 516 daemons/controld/controld_te_actions.c r->jobs += offset; r 518 daemons/controld/controld_te_actions.c r->migrate_jobs += offset; r 520 daemons/controld/controld_te_actions.c crm_trace("jobs[%s] = %d", target, r->jobs); r 574 daemons/controld/controld_te_actions.c struct te_peer_s *r = NULL; r 586 daemons/controld/controld_te_actions.c r = g_hash_table_lookup(te_targets, target); r 589 daemons/controld/controld_te_actions.c if(r == NULL) { r 590 daemons/controld/controld_te_actions.c r = pcmk__assert_alloc(1, sizeof(struct te_peer_s)); r 591 daemons/controld/controld_te_actions.c r->name = pcmk__str_copy(target); r 592 daemons/controld/controld_te_actions.c g_hash_table_insert(te_targets, r->name, r); r 595 daemons/controld/controld_te_actions.c if(limit <= r->jobs) { r 597 daemons/controld/controld_te_actions.c target, limit, r->jobs, id); r 600 daemons/controld/controld_te_actions.c } else if(graph->migration_limit > 0 && r->migrate_jobs >= graph->migration_limit) { r 604 daemons/controld/controld_te_actions.c target, graph->migration_limit, r->migrate_jobs, id); r 609 daemons/controld/controld_te_actions.c crm_trace("Peer %s has not hit their limit yet. current jobs = %d limit= %d limit", target, r->jobs, limit); r 211 daemons/controld/controld_throttle.c struct throttle_record_s *r = p; r 212 daemons/controld/controld_throttle.c free(r->node); r 213 daemons/controld/controld_throttle.c free(r); r 311 daemons/controld/controld_throttle.c struct throttle_record_s *r = NULL; r 315 daemons/controld/controld_throttle.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &r)) { r 316 daemons/controld/controld_throttle.c switch(r->mode) { r 348 daemons/controld/controld_throttle.c struct throttle_record_s *r = NULL; r 350 daemons/controld/controld_throttle.c r = g_hash_table_lookup(throttle_records, node); r 351 daemons/controld/controld_throttle.c if(r == NULL) { r 352 daemons/controld/controld_throttle.c r = pcmk__assert_alloc(1, sizeof(struct throttle_record_s)); r 353 daemons/controld/controld_throttle.c r->node = pcmk__str_copy(node); r 354 daemons/controld/controld_throttle.c r->mode = throttle_low; r 355 daemons/controld/controld_throttle.c r->max = throttle_job_max; r 358 daemons/controld/controld_throttle.c g_hash_table_insert(throttle_records, r->node, r); r 361 daemons/controld/controld_throttle.c switch(r->mode) { r 367 daemons/controld/controld_throttle.c jobs = QB_MAX(1, r->max / 4); r 370 daemons/controld/controld_throttle.c jobs = QB_MAX(1, r->max / 2); r 373 daemons/controld/controld_throttle.c jobs = QB_MAX(1, r->max); r 376 daemons/controld/controld_throttle.c crm_err("Unknown throttle mode %.4x on %s", r->mode, node); r 387 daemons/controld/controld_throttle.c struct throttle_record_s *r = NULL; r 393 daemons/controld/controld_throttle.c r = g_hash_table_lookup(throttle_records, from); r 395 daemons/controld/controld_throttle.c if(r == NULL) { r 396 daemons/controld/controld_throttle.c r = pcmk__assert_alloc(1, sizeof(struct throttle_record_s)); r 397 daemons/controld/controld_throttle.c r->node = pcmk__str_copy(from); r 398 daemons/controld/controld_throttle.c g_hash_table_insert(throttle_records, r->node, r); r 401 daemons/controld/controld_throttle.c r->max = max; r 402 daemons/controld/controld_throttle.c r->mode = (enum throttle_state_e) mode; r 1722 lib/common/iso8601.c #define do_cmp_field(l, r, field) \ r 1724 lib/common/iso8601.c if(l->field > r->field) { \ r 1726 lib/common/iso8601.c #field, l->field, r->field); \ r 1728 lib/common/iso8601.c } else if(l->field < r->field) { \ r 1730 lib/common/iso8601.c #field, l->field, r->field); \ r 297 lib/pacemaker/pcmk_sched_fencing.c for (GList *r = scheduler->priv->resources; r != NULL; r = r->next) { r 298 lib/pacemaker/pcmk_sched_fencing.c rsc_stonith_ordering((pcmk_resource_t *) r->data, stonith_op); r 1132 lib/pacemaker/pcmk_sched_instances.c #define display_role(r) \ r 1133 lib/pacemaker/pcmk_sched_instances.c (((r) == pcmk_role_unknown)? "matching" : pcmk_role_text(r)) r 426 lib/pacemaker/pcmk_sched_location.c pcmk_resource_t *r = iter->data; r 438 lib/pacemaker/pcmk_sched_location.c status = regexec(®ex, r->id, nregs, pmatch, 0); r 441 lib/pacemaker/pcmk_sched_location.c crm_debug("'%s' matched '%s' for %s", r->id, value, id); r 442 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(xml_obj, r, NULL, NULL, r->id, nregs, r 447 lib/pacemaker/pcmk_sched_location.c r->id, value, id); r 448 lib/pacemaker/pcmk_sched_location.c unpack_rsc_location(xml_obj, r, NULL, NULL, NULL, 0, NULL); r 451 lib/pacemaker/pcmk_sched_location.c crm_trace("'%s' does not match '%s' for %s", r->id, value, id); r 399 lib/pacemaker/pcmk_sched_nodes.c for (GList *r = scheduler->priv->resources; r != NULL; r = r->next) { r 400 lib/pacemaker/pcmk_sched_nodes.c pcmk_resource_t *rsc = (pcmk_resource_t *) r->data; r 608 lib/pengine/utils.c pcmk_resource_t *r = (pcmk_resource_t *) lpc->data; r 610 lib/pengine/utils.c pe__clear_resource_flags_recursive(r, flag); r 1644 tools/crm_resource_runtime.c #define waiting_for_starts(d, r, h) ((d != NULL) || \ r 1645 tools/crm_resource_runtime.c (!resource_is_running_on((r), (h))))