tuple 32 lib/pengine/container.c void tuple_free(container_grouping_t *tuple); tuple 62 lib/pengine/container.c allocate_ip(container_variant_data_t *data, container_grouping_t *tuple, char *buffer, int max) tuple 68 lib/pengine/container.c tuple->ipaddr = next_ip(data->ip_last); tuple 71 lib/pengine/container.c tuple->ipaddr = strdup(data->ip_range_start); tuple 74 lib/pengine/container.c data->ip_last = tuple->ipaddr; tuple 77 lib/pengine/container.c data->prefix, tuple->offset, tuple->ipaddr, tuple 78 lib/pengine/container.c data->prefix, tuple->offset, data->prefix, tuple->offset); tuple 82 lib/pengine/container.c data->prefix, tuple->offset, tuple->ipaddr); tuple 85 lib/pengine/container.c tuple->ipaddr, data->prefix, tuple->offset); tuple 136 lib/pengine/container.c resource_t *parent, container_variant_data_t *data, container_grouping_t *tuple, tuple 144 lib/pengine/container.c id = crm_strdup_printf("%s-ip-%s", data->prefix, tuple->ipaddr); tuple 150 lib/pengine/container.c crm_xml_set_id(xml_obj, "%s-attributes-%d", data->prefix, tuple->offset); tuple 152 lib/pengine/container.c crm_create_nvpair_xml(xml_obj, NULL, "ip", tuple->ipaddr); tuple 171 lib/pengine/container.c if (common_unpack(xml_ip, &tuple->ip, parent, data_set) == false) { tuple 175 lib/pengine/container.c parent->children = g_list_append(parent->children, tuple->ip); tuple 182 lib/pengine/container.c resource_t *parent, container_variant_data_t *data, container_grouping_t *tuple, tuple 195 lib/pengine/container.c id = crm_strdup_printf("%s-docker-%d", data->prefix, tuple->offset); tuple 201 lib/pengine/container.c crm_xml_set_id(xml_obj, "%s-attributes-%d", data->prefix, tuple->offset); tuple 217 lib/pengine/container.c data->prefix, tuple->offset); tuple 238 lib/pengine/container.c "%s/%s-%d", mount->source, data->prefix, tuple->offset); tuple 258 lib/pengine/container.c if(tuple->ipaddr) { tuple 260 lib/pengine/container.c tuple->ipaddr, port->source, port->target); tuple 281 lib/pengine/container.c if(tuple->child) { tuple 330 lib/pengine/container.c if (common_unpack(xml_docker, &tuple->docker, parent, data_set) == FALSE) { tuple 333 lib/pengine/container.c parent->children = g_list_append(parent->children, tuple->docker); tuple 339 lib/pengine/container.c resource_t *parent, container_variant_data_t *data, container_grouping_t *tuple, tuple 354 lib/pengine/container.c id = crm_strdup_printf("%s-rkt-%d", data->prefix, tuple->offset); tuple 360 lib/pengine/container.c crm_xml_set_id(xml_obj, "%s-attributes-%d", data->prefix, tuple->offset); tuple 374 lib/pengine/container.c data->prefix, tuple->offset); tuple 395 lib/pengine/container.c "%s/%s-%d", mount->source, data->prefix, tuple->offset); tuple 421 lib/pengine/container.c if(tuple->ipaddr) { tuple 423 lib/pengine/container.c port->target, tuple->ipaddr, port->source); tuple 443 lib/pengine/container.c if(tuple->child) { tuple 491 lib/pengine/container.c if (common_unpack(xml_docker, &tuple->docker, parent, data_set) == FALSE) { tuple 494 lib/pengine/container.c parent->children = g_list_append(parent->children, tuple->docker); tuple 524 lib/pengine/container.c resource_t *parent, container_variant_data_t *data, container_grouping_t *tuple, tuple 527 lib/pengine/container.c if (tuple->child && valid_network(data)) { tuple 532 lib/pengine/container.c char *id = crm_strdup_printf("%s-%d", data->prefix, tuple->offset); tuple 540 lib/pengine/container.c id = crm_strdup_printf("pcmk-internal-%s-remote-%d", tuple->child->id, tuple->offset); tuple 548 lib/pengine/container.c connect_name = (tuple->ipaddr? tuple->ipaddr : "#uname"); tuple 559 lib/pengine/container.c xml_remote = pe_create_remote_xml(NULL, id, tuple->docker->id, tuple 608 lib/pengine/container.c tuple->node = node_copy(node); tuple 609 lib/pengine/container.c tuple->node->weight = 500; tuple 610 lib/pengine/container.c tuple->node->rsc_discover_mode = pe_discover_exclusive; tuple 613 lib/pengine/container.c g_hash_table_destroy(tuple->child->allowed_nodes); tuple 614 lib/pengine/container.c tuple->child->allowed_nodes = g_hash_table_new_full(crm_str_hash, g_str_equal, NULL, g_hash_destroy_str); tuple 615 lib/pengine/container.c g_hash_table_insert(tuple->child->allowed_nodes, (gpointer) tuple->node->details->id, node_copy(tuple->node)); tuple 618 lib/pengine/container.c node_t *copy = node_copy(tuple->node); tuple 620 lib/pengine/container.c g_hash_table_insert(tuple->child->parent->allowed_nodes, (gpointer) tuple->node->details->id, copy); tuple 623 lib/pengine/container.c if (common_unpack(xml_remote, &tuple->remote, parent, data_set) == FALSE) { tuple 627 lib/pengine/container.c g_hash_table_iter_init(&gIter, tuple->remote->allowed_nodes); tuple 635 lib/pengine/container.c tuple->node->details->remote_rsc = tuple->remote; tuple 636 lib/pengine/container.c tuple->remote->container = tuple->docker; // Ensures is_container_remote_node() functions correctly immediately tuple 641 lib/pengine/container.c g_hash_table_insert(tuple->node->details->attrs, tuple 653 lib/pengine/container.c parent->children = g_list_append(parent->children, tuple->remote); tuple 660 lib/pengine/container.c resource_t *parent, container_variant_data_t *data, container_grouping_t *tuple, tuple 665 lib/pengine/container.c create_docker_resource(parent, data, tuple, data_set) == FALSE) { tuple 669 lib/pengine/container.c create_rkt_resource(parent, data, tuple, data_set) == FALSE) { tuple 673 lib/pengine/container.c if(create_ip_resource(parent, data, tuple, data_set) == FALSE) { tuple 676 lib/pengine/container.c if(create_remote_resource(parent, data, tuple, data_set) == FALSE) { tuple 679 lib/pengine/container.c if(tuple->child && tuple->ipaddr) { tuple 680 lib/pengine/container.c add_hash_param(tuple->child->meta, "external-ip", tuple->ipaddr); tuple 683 lib/pengine/container.c if(tuple->remote) { tuple 693 lib/pengine/container.c set_bit(tuple->remote->flags, pe_rsc_allow_remote_remotes); tuple 745 lib/pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 746 lib/pengine/container.c if(tuple->remote == remote) { tuple 747 lib/pengine/container.c return tuple; tuple 796 lib/pengine/container.c container_grouping_t *tuple = NULL; tuple 802 lib/pengine/container.c tuple = tuple_for_remote(rsc); tuple 803 lib/pengine/container.c if(tuple == NULL) { tuple 807 lib/pengine/container.c node = tuple->docker->allocated_to; tuple 808 lib/pengine/container.c if(node == NULL && tuple->docker->running_on) { tuple 812 lib/pengine/container.c node = tuple->docker->running_on->data; tuple 816 lib/pengine/container.c crm_trace("Cannot fix address for %s", tuple->remote->id); tuple 1063 lib/pengine/container.c container_grouping_t *tuple = calloc(1, sizeof(container_grouping_t)); tuple 1064 lib/pengine/container.c tuple->child = childIter->data; tuple 1065 lib/pengine/container.c tuple->child->exclusive_discover = TRUE; tuple 1066 lib/pengine/container.c tuple->offset = lpc++; tuple 1069 lib/pengine/container.c if(is_set(tuple->child->flags, pe_rsc_notify)) { tuple 1073 lib/pengine/container.c offset += allocate_ip(container_data, tuple, buffer+offset, max-offset); tuple 1074 lib/pengine/container.c container_data->tuples = g_list_append(container_data->tuples, tuple); tuple 1075 lib/pengine/container.c container_data->attribute_target = g_hash_table_lookup(tuple->child->meta, XML_RSC_ATTR_TARGET); tuple 1089 lib/pengine/container.c container_grouping_t *tuple = calloc(1, sizeof(container_grouping_t)); tuple 1090 lib/pengine/container.c tuple->offset = lpc; tuple 1091 lib/pengine/container.c offset += allocate_ip(container_data, tuple, buffer+offset, max-offset); tuple 1092 lib/pengine/container.c container_data->tuples = g_list_append(container_data->tuples, tuple); tuple 1099 lib/pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 1100 lib/pengine/container.c if (create_container(rsc, container_data, tuple, data_set) == FALSE) { tuple 1136 lib/pengine/container.c container_grouping_t *tuple = (container_grouping_t *)(iter->data); tuple 1139 lib/pengine/container.c rsc_active = tuple_rsc_active(tuple->ip, all); tuple 1144 lib/pengine/container.c rsc_active = tuple_rsc_active(tuple->child, all); tuple 1149 lib/pengine/container.c rsc_active = tuple_rsc_active(tuple->docker, all); tuple 1154 lib/pengine/container.c rsc_active = tuple_rsc_active(tuple->remote, all); tuple 1179 lib/pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 1181 lib/pengine/container.c CRM_ASSERT(tuple); tuple 1182 lib/pengine/container.c if(tuple->node->details == node->details) { tuple 1183 lib/pengine/container.c rsc = tuple->child; tuple 1256 lib/pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 1258 lib/pengine/container.c CRM_ASSERT(tuple); tuple 1259 lib/pengine/container.c status_print("%s <replica id=\"%d\">\n", pre_text, tuple->offset); tuple 1260 lib/pengine/container.c print_rsc_in_list(tuple->ip, child_text, options, print_data); tuple 1261 lib/pengine/container.c print_rsc_in_list(tuple->child, child_text, options, print_data); tuple 1262 lib/pengine/container.c print_rsc_in_list(tuple->docker, child_text, options, print_data); tuple 1263 lib/pengine/container.c print_rsc_in_list(tuple->remote, child_text, options, print_data); tuple 1271 lib/pengine/container.c tuple_print(container_grouping_t * tuple, const char *pre_text, long options, void *print_data) tuple 1274 lib/pengine/container.c resource_t *rsc = tuple->child; tuple 1280 lib/pengine/container.c rsc = tuple->docker; tuple 1283 lib/pengine/container.c if(tuple->remote) { tuple 1284 lib/pengine/container.c offset += snprintf(buffer + offset, LINE_MAX - offset, "%s", rsc_printable_id(tuple->remote)); tuple 1286 lib/pengine/container.c offset += snprintf(buffer + offset, LINE_MAX - offset, "%s", rsc_printable_id(tuple->docker)); tuple 1288 lib/pengine/container.c if(tuple->ipaddr) { tuple 1289 lib/pengine/container.c offset += snprintf(buffer + offset, LINE_MAX - offset, " (%s)", tuple->ipaddr); tuple 1292 lib/pengine/container.c if (tuple->docker->running_on) { tuple 1293 lib/pengine/container.c node = tuple->docker->running_on->data; tuple 1327 lib/pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 1329 lib/pengine/container.c CRM_ASSERT(tuple); tuple 1337 lib/pengine/container.c status_print(" %sReplica[%d]\n", pre_text, tuple->offset); tuple 1342 lib/pengine/container.c print_rsc_in_list(tuple->ip, child_text, options, print_data); tuple 1343 lib/pengine/container.c print_rsc_in_list(tuple->docker, child_text, options, print_data); tuple 1344 lib/pengine/container.c print_rsc_in_list(tuple->remote, child_text, options, print_data); tuple 1345 lib/pengine/container.c print_rsc_in_list(tuple->child, child_text, options, print_data); tuple 1351 lib/pengine/container.c tuple_print(tuple, child_text, options, print_data); tuple 1365 lib/pengine/container.c tuple_free(container_grouping_t *tuple) tuple 1367 lib/pengine/container.c if(tuple == NULL) { tuple 1371 lib/pengine/container.c if(tuple->node) { tuple 1372 lib/pengine/container.c free(tuple->node); tuple 1373 lib/pengine/container.c tuple->node = NULL; tuple 1376 lib/pengine/container.c if(tuple->ip) { tuple 1377 lib/pengine/container.c free_xml(tuple->ip->xml); tuple 1378 lib/pengine/container.c tuple->ip->xml = NULL; tuple 1379 lib/pengine/container.c tuple->ip->fns->free(tuple->ip); tuple 1380 lib/pengine/container.c tuple->ip = NULL; tuple 1382 lib/pengine/container.c if(tuple->docker) { tuple 1383 lib/pengine/container.c free_xml(tuple->docker->xml); tuple 1384 lib/pengine/container.c tuple->docker->xml = NULL; tuple 1385 lib/pengine/container.c tuple->docker->fns->free(tuple->docker); tuple 1386 lib/pengine/container.c tuple->docker = NULL; tuple 1388 lib/pengine/container.c if(tuple->remote) { tuple 1389 lib/pengine/container.c free_xml(tuple->remote->xml); tuple 1390 lib/pengine/container.c tuple->remote->xml = NULL; tuple 1391 lib/pengine/container.c tuple->remote->fns->free(tuple->remote); tuple 1392 lib/pengine/container.c tuple->remote = NULL; tuple 1394 lib/pengine/container.c free(tuple->ipaddr); tuple 1395 lib/pengine/container.c free(tuple); tuple 33 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 34 pengine/container.c if(node->details == tuple->node->details) { tuple 53 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 54 pengine/container.c containers = g_list_append(containers, tuple->docker); tuple 68 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 69 pengine/container.c containers = g_list_append(containers, tuple->docker); tuple 141 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 142 pengine/container.c pe_node_t *docker_host = tuple->docker->allocated_to; tuple 144 pengine/container.c CRM_ASSERT(tuple); tuple 145 pengine/container.c if(tuple->ip) { tuple 146 pengine/container.c tuple->ip->cmds->allocate(tuple->ip, prefer, data_set); tuple 149 pengine/container.c if(tuple->remote && is_remote_node(docker_host)) { tuple 155 pengine/container.c INFINITY, tuple->remote, docker_host->details->remote_rsc, NULL, NULL, data_set); tuple 158 pengine/container.c if(tuple->remote) { tuple 159 pengine/container.c tuple->remote->cmds->allocate(tuple->remote, prefer, data_set); tuple 163 pengine/container.c if(tuple->child) { tuple 166 pengine/container.c g_hash_table_iter_init(&iter, tuple->child->allowed_nodes); tuple 168 pengine/container.c if(node->details != tuple->node->details) { tuple 170 pengine/container.c } else if(migration_threshold_reached(tuple->child, node, data_set) == FALSE) { tuple 175 pengine/container.c set_bit(tuple->child->parent->flags, pe_rsc_allocating); tuple 176 pengine/container.c tuple->child->cmds->allocate(tuple->child, tuple->node, data_set); tuple 177 pengine/container.c clear_bit(tuple->child->parent->flags, pe_rsc_allocating); tuple 213 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 215 pengine/container.c CRM_ASSERT(tuple); tuple 216 pengine/container.c if(tuple->ip) { tuple 217 pengine/container.c tuple->ip->cmds->create_actions(tuple->ip, data_set); tuple 219 pengine/container.c if(tuple->docker) { tuple 220 pengine/container.c tuple->docker->cmds->create_actions(tuple->docker, data_set); tuple 222 pengine/container.c if(tuple->remote) { tuple 223 pengine/container.c tuple->remote->cmds->create_actions(tuple->remote, data_set); tuple 271 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 273 pengine/container.c CRM_ASSERT(tuple); tuple 274 pengine/container.c CRM_ASSERT(tuple->docker); tuple 276 pengine/container.c tuple->docker->cmds->internal_constraints(tuple->docker, data_set); tuple 278 pengine/container.c order_start_start(rsc, tuple->docker, pe_order_runnable_left | pe_order_implies_first_printed); tuple 280 pengine/container.c if(tuple->child) { tuple 281 pengine/container.c order_stop_stop(rsc, tuple->child, pe_order_implies_first_printed); tuple 283 pengine/container.c order_stop_stop(rsc, tuple->docker, pe_order_implies_first_printed); tuple 284 pengine/container.c new_rsc_order(tuple->docker, RSC_START, rsc, RSC_STARTED, pe_order_implies_then_printed, data_set); tuple 285 pengine/container.c new_rsc_order(tuple->docker, RSC_STOP, rsc, RSC_STOPPED, pe_order_implies_then_printed, data_set); tuple 287 pengine/container.c if(tuple->ip) { tuple 288 pengine/container.c tuple->ip->cmds->internal_constraints(tuple->ip, data_set); tuple 291 pengine/container.c new_rsc_order(tuple->ip, RSC_START, tuple->docker, RSC_START, tuple 293 pengine/container.c new_rsc_order(tuple->docker, RSC_STOP, tuple->ip, RSC_STOP, tuple 296 pengine/container.c rsc_colocation_new("ip-with-docker", NULL, INFINITY, tuple->ip, tuple->docker, NULL, NULL, data_set); tuple 299 pengine/container.c if(tuple->remote) { tuple 305 pengine/container.c tuple->remote->cmds->internal_constraints(tuple->remote, data_set); tuple 308 pengine/container.c if(tuple->child) { tuple 309 pengine/container.c CRM_ASSERT(tuple->remote); tuple 356 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 358 pengine/container.c if(is_child_compatible(tuple->docker, candidate, filter, current)) { tuple 360 pengine/container.c rsc_lh->id, tuple->docker->id, candidate->details->uname); tuple 361 pengine/container.c return tuple->docker; tuple 481 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 484 pengine/container.c tuple->docker->cmds->rsc_colocation_rh(rsc_lh, tuple->docker, constraint); tuple 487 pengine/container.c node_t *chosen = tuple->docker->fns->location(tuple->docker, NULL, FALSE); tuple 489 pengine/container.c if (chosen != NULL && is_set_recursive(tuple->docker, pe_rsc_block, TRUE) == FALSE) { tuple 572 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 573 pengine/container.c if(tuple->child tuple 574 pengine/container.c && docker == tuple->docker tuple 575 pengine/container.c && node->details == tuple->node->details) { tuple 576 pengine/container.c return tuple; tuple 801 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 803 pengine/container.c if (tuple->docker) { tuple 804 pengine/container.c tuple->docker->cmds->rsc_location(tuple->docker, constraint); tuple 806 pengine/container.c if(tuple->ip) { tuple 807 pengine/container.c tuple->ip->cmds->rsc_location(tuple->ip, constraint); tuple 831 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 833 pengine/container.c CRM_ASSERT(tuple); tuple 834 pengine/container.c if (tuple->remote && tuple->docker && container_fix_remote_addr(tuple->remote)) { tuple 836 pengine/container.c xmlNode *nvpair = get_xpath_object("//nvpair[@name='addr']", tuple->remote->xml, LOG_ERR); tuple 837 pengine/container.c const char *calculated_addr = container_fix_remote_addr_in(tuple->remote, nvpair, "value"); tuple 840 pengine/container.c crm_trace("Fixed addr for %s on %s", tuple->remote->id, calculated_addr); tuple 841 pengine/container.c g_hash_table_replace(tuple->remote->parameters, strdup("addr"), strdup(calculated_addr)); tuple 843 pengine/container.c crm_err("Could not fix addr for %s", tuple->remote->id); tuple 846 pengine/container.c if(tuple->ip) { tuple 847 pengine/container.c tuple->ip->cmds->expand(tuple->ip, data_set); tuple 849 pengine/container.c if(tuple->docker) { tuple 850 pengine/container.c tuple->docker->cmds->expand(tuple->docker, data_set); tuple 852 pengine/container.c if(tuple->remote) { tuple 853 pengine/container.c tuple->remote->cmds->expand(tuple->remote, data_set); tuple 869 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 871 pengine/container.c CRM_ASSERT(tuple); tuple 872 pengine/container.c if(tuple->ip) { tuple 873 pengine/container.c any_created |= tuple->ip->cmds->create_probe(tuple->ip, node, complete, force, data_set); tuple 875 pengine/container.c if(tuple->child && node->details == tuple->node->details) { tuple 876 pengine/container.c any_created |= tuple->child->cmds->create_probe(tuple->child, node, complete, force, data_set); tuple 878 pengine/container.c if(tuple->docker) { tuple 879 pengine/container.c bool created = tuple->docker->cmds->create_probe(tuple->docker, node, complete, force, data_set); tuple 899 pengine/container.c if ((other != tuple) && (other != NULL) tuple 902 pengine/container.c custom_action_order(tuple->docker, generate_op_key(tuple->docker->id, RSC_STATUS, 0), NULL, tuple 909 pengine/container.c if (tuple->docker && tuple->remote tuple 910 pengine/container.c && tuple->remote->cmds->create_probe(tuple->remote, node, complete, tuple 916 pengine/container.c char *probe_uuid = generate_op_key(tuple->remote->id, RSC_STATUS, 0); tuple 917 pengine/container.c action_t *probe = find_first_action(tuple->remote->actions, probe_uuid, NULL, node); tuple 923 pengine/container.c tuple->remote->id, node->details->uname); tuple 924 pengine/container.c custom_action_order(tuple->docker, tuple 925 pengine/container.c generate_op_key(tuple->docker->id, RSC_START, 0), tuple 926 pengine/container.c NULL, tuple->remote, NULL, probe, tuple 955 pengine/container.c container_grouping_t *tuple = (container_grouping_t *)gIter->data; tuple 957 pengine/container.c CRM_ASSERT(tuple); tuple 958 pengine/container.c if(tuple->ip) { tuple 959 pengine/container.c LogActions(tuple->ip, data_set, terminal); tuple 961 pengine/container.c if(tuple->docker) { tuple 962 pengine/container.c LogActions(tuple->docker, data_set, terminal); tuple 964 pengine/container.c if(tuple->remote) { tuple 965 pengine/container.c LogActions(tuple->remote, data_set, terminal); tuple 967 pengine/container.c if(tuple->child) { tuple 968 pengine/container.c LogActions(tuple->child, data_set, terminal);