r 417 daemons/controld/controld_te_actions.c struct te_peer_s *r = NULL; r 423 daemons/controld/controld_te_actions.c r = g_hash_table_lookup(te_targets, target); r 424 daemons/controld/controld_te_actions.c if(r == NULL) { r 425 daemons/controld/controld_te_actions.c r = calloc(1, sizeof(struct te_peer_s)); r 426 daemons/controld/controld_te_actions.c r->name = strdup(target); r 427 daemons/controld/controld_te_actions.c g_hash_table_insert(te_targets, r->name, r); r 430 daemons/controld/controld_te_actions.c r->jobs += offset; r 432 daemons/controld/controld_te_actions.c r->migrate_jobs += offset; r 434 daemons/controld/controld_te_actions.c crm_trace("jobs[%s] = %d", target, r->jobs); r 474 daemons/controld/controld_te_actions.c struct te_peer_s *r = NULL; r 486 daemons/controld/controld_te_actions.c r = g_hash_table_lookup(te_targets, target); r 489 daemons/controld/controld_te_actions.c if(r == NULL) { r 490 daemons/controld/controld_te_actions.c r = calloc(1, sizeof(struct te_peer_s)); r 491 daemons/controld/controld_te_actions.c r->name = strdup(target); r 492 daemons/controld/controld_te_actions.c g_hash_table_insert(te_targets, r->name, r); r 495 daemons/controld/controld_te_actions.c if(limit <= r->jobs) { r 497 daemons/controld/controld_te_actions.c target, limit, r->jobs, id); r 500 daemons/controld/controld_te_actions.c } else if(graph->migration_limit > 0 && r->migrate_jobs >= graph->migration_limit) { r 503 daemons/controld/controld_te_actions.c target, graph->migration_limit, r->migrate_jobs, id); r 508 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 388 daemons/controld/controld_throttle.c struct throttle_record_s *r = p; r 389 daemons/controld/controld_throttle.c free(r->node); r 390 daemons/controld/controld_throttle.c free(r); r 458 daemons/controld/controld_throttle.c struct throttle_record_s *r = NULL; r 462 daemons/controld/controld_throttle.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) &r)) { r 463 daemons/controld/controld_throttle.c switch(r->mode) { r 496 daemons/controld/controld_throttle.c struct throttle_record_s *r = NULL; r 498 daemons/controld/controld_throttle.c r = g_hash_table_lookup(throttle_records, node); r 499 daemons/controld/controld_throttle.c if(r == NULL) { r 500 daemons/controld/controld_throttle.c r = calloc(1, sizeof(struct throttle_record_s)); r 501 daemons/controld/controld_throttle.c r->node = strdup(node); r 502 daemons/controld/controld_throttle.c r->mode = throttle_low; r 503 daemons/controld/controld_throttle.c r->max = throttle_job_max; r 506 daemons/controld/controld_throttle.c g_hash_table_insert(throttle_records, r->node, r); r 509 daemons/controld/controld_throttle.c switch(r->mode) { r 515 daemons/controld/controld_throttle.c jobs = QB_MAX(1, r->max / 4); r 518 daemons/controld/controld_throttle.c jobs = QB_MAX(1, r->max / 2); r 521 daemons/controld/controld_throttle.c jobs = QB_MAX(1, r->max); r 524 daemons/controld/controld_throttle.c crm_err("Unknown throttle mode %.4x on %s", r->mode, node); r 535 daemons/controld/controld_throttle.c struct throttle_record_s *r = NULL; r 541 daemons/controld/controld_throttle.c r = g_hash_table_lookup(throttle_records, from); r 543 daemons/controld/controld_throttle.c if(r == NULL) { r 544 daemons/controld/controld_throttle.c r = calloc(1, sizeof(struct throttle_record_s)); r 545 daemons/controld/controld_throttle.c r->node = strdup(from); r 546 daemons/controld/controld_throttle.c g_hash_table_insert(throttle_records, r->node, r); r 549 daemons/controld/controld_throttle.c r->max = max; r 550 daemons/controld/controld_throttle.c r->mode = (enum throttle_state_e) mode; r 1373 lib/common/iso8601.c #define do_cmp_field(l, r, field) \ r 1375 lib/common/iso8601.c if(l->field > r->field) { \ r 1377 lib/common/iso8601.c #field, l->field, r->field); \ r 1379 lib/common/iso8601.c } else if(l->field < r->field) { \ r 1381 lib/common/iso8601.c #field, l->field, r->field); \ r 101 lib/common/md5.c char *r = resbuf; r 102 lib/common/md5.c set_uint32 (r + 0 * sizeof ctx->A, SWAP (ctx->A)); r 103 lib/common/md5.c set_uint32 (r + 1 * sizeof ctx->B, SWAP (ctx->B)); r 104 lib/common/md5.c set_uint32 (r + 2 * sizeof ctx->C, SWAP (ctx->C)); r 105 lib/common/md5.c set_uint32 (r + 3 * sizeof ctx->D, SWAP (ctx->D)); r 101 lib/gnu/md5.c char *r = resbuf; r 102 lib/gnu/md5.c set_uint32 (r + 0 * sizeof ctx->A, SWAP (ctx->A)); r 103 lib/gnu/md5.c set_uint32 (r + 1 * sizeof ctx->B, SWAP (ctx->B)); r 104 lib/gnu/md5.c set_uint32 (r + 2 * sizeof ctx->C, SWAP (ctx->C)); r 105 lib/gnu/md5.c set_uint32 (r + 3 * sizeof ctx->D, SWAP (ctx->D)); r 748 lib/pacemaker/pcmk_sched_constraints.c pe_resource_t *r = rIter->data; r 760 lib/pacemaker/pcmk_sched_constraints.c status = regexec(r_patt, r->id, nregs, pmatch, 0); r 764 lib/pacemaker/pcmk_sched_constraints.c .string = r->id, r 770 lib/pacemaker/pcmk_sched_constraints.c .params = r->parameters, r 771 lib/pacemaker/pcmk_sched_constraints.c .meta = r->meta, r 773 lib/pacemaker/pcmk_sched_constraints.c crm_debug("'%s' matched '%s' for %s", r->id, value, id); r 774 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, &match_data); r 777 lib/pacemaker/pcmk_sched_constraints.c crm_debug("'%s' is an inverted match of '%s' for %s", r->id, value, id); r 778 lib/pacemaker/pcmk_sched_constraints.c unpack_rsc_location(xml_obj, r, NULL, NULL, data_set, NULL); r 781 lib/pacemaker/pcmk_sched_constraints.c crm_trace("'%s' does not match '%s' for %s", r->id, value, id); r 866 lib/pacemaker/pcmk_sched_constraints.c enum rsc_role_e r = text2role(role); r 867 lib/pacemaker/pcmk_sched_constraints.c switch(r) { r 875 lib/pacemaker/pcmk_sched_constraints.c location->role_filter = r; r 775 lib/pacemaker/pcmk_sched_graph.c for (GList *r = data_set->resources; r != NULL; r = r->next) { r 776 lib/pacemaker/pcmk_sched_graph.c rsc_stonith_ordering((pe_resource_t *) r->data, stonith_op, data_set); r 1198 tools/crm_resource.c pe_resource_t *r = (pe_resource_t *) lpc->data; r 1200 tools/crm_resource.c pe__clear_resource_flags(r, pe_rsc_allocating); r 1209 tools/crm_resource.c pe_resource_t *r = (pe_resource_t *) lpc->data; r 1211 tools/crm_resource.c pe__clear_resource_flags(r, pe_rsc_allocating); r 374 tools/crm_resource_runtime.c pe_resource_t *r = (pe_resource_t *) lpc->data; r 376 tools/crm_resource_runtime.c pe__clear_resource_flags(r, pe_rsc_allocating); r 1245 tools/crm_resource_runtime.c #define waiting_for_starts(d, r, h) ((d != NULL) || \ r 1246 tools/crm_resource_runtime.c (resource_is_running_on((r), (h)) == FALSE))