1 /* Copyright (c) 2010-2015. The SimGrid Team.
2 * All rights reserved. */
4 /* This program is free software; you can redistribute it and/or modify it
5 * under the terms of the license (GNU LGPL) which comes with this package. */
7 #include "simgrid/jedule/jedule_platform.h"
9 #include "xbt/asserts.h"
10 #include "xbt/dynar.h"
18 /********************************************************************/
20 static xbt_dict_t host2_simgrid_parent_container;
21 static xbt_dict_t container_name2container;
23 /********************************************************************/
25 static void add_subset_to(xbt_dynar_t subset_list, int start, int end,
26 jed_simgrid_container_t parent);
28 static void add_subsets_to(xbt_dynar_t subset_list, xbt_dynar_t hostgroup,
29 jed_simgrid_container_t parent);
31 static void jed_free_container(jed_simgrid_container_t container);
33 /********************************************************************/
35 static int compare_ids(const void *num1, const void *num2) {
36 int *i1 = (int*) num1;
37 int *i2 = (int*) num2;
41 static void jed_free_container(jed_simgrid_container_t container) {
43 xbt_dict_free(&container->name2id);
44 xbt_dynar_free(&container->resource_list);
46 if( container->container_children != NULL ) {
48 jed_simgrid_container_t child_container;
49 xbt_dynar_foreach(container->container_children, iter, child_container) {
50 jed_free_container(child_container);
52 xbt_dynar_free(&container->container_children);
55 xbt_free(container->name);
59 void jed_simgrid_create_container(jed_simgrid_container_t *container,
62 xbt_assert( name != NULL );
64 *container = xbt_new0(s_jed_simgrid_container_t,1);
65 (*container)->name = xbt_strdup(name);
66 (*container)->is_lowest = 0;
67 (*container)->container_children = xbt_dynar_new(sizeof(jed_simgrid_container_t), NULL);
68 (*container)->parent = NULL;
70 xbt_dict_set(container_name2container, (*container)->name, *container, NULL);
74 void jed_simgrid_add_container(jed_simgrid_container_t parent,
75 jed_simgrid_container_t child) {
76 xbt_assert(parent != NULL);
77 xbt_assert(child != NULL);
78 xbt_dynar_push(parent->container_children, &child);
79 child->parent = parent;
82 void jed_simgrid_add_resources(jed_simgrid_container_t parent,
83 xbt_dynar_t host_names) {
89 parent->is_lowest = 1;
90 xbt_dynar_free(&parent->container_children);
91 parent->container_children = NULL;
92 parent->name2id = xbt_dict_new_homogeneous(xbt_free_f);
94 parent->resource_list = xbt_dynar_new(sizeof(char *), NULL);
96 xbt_dynar_sort_strings(host_names);
98 xbt_dynar_foreach(host_names, iter, host_name) {
99 buf = bprintf("%d", parent->last_id);
101 xbt_dict_set(parent->name2id, host_name, buf, NULL);
102 xbt_dict_set(host2_simgrid_parent_container, host_name, parent, NULL);
103 xbt_dynar_push(parent->resource_list, &host_name);
108 static void add_subset_to(xbt_dynar_t subset_list, int start, int end,
109 jed_simgrid_container_t parent) {
111 jed_res_subset_t subset;
113 xbt_assert( subset_list != NULL );
114 xbt_assert( parent != NULL );
116 // printf(">>> start=%d end=%d\n", start, end);
118 subset = xbt_new0(s_jed_res_subset_t,1);
119 subset->start_idx = start;
120 subset->nres = end-start+1;
121 subset->parent = parent;
123 xbt_dynar_push(subset_list, &subset);
127 static void add_subsets_to(xbt_dynar_t subset_list, xbt_dynar_t hostgroup,
128 jed_simgrid_container_t parent) {
137 // get ids for each host
140 // create subset for each id group
142 xbt_assert( host2_simgrid_parent_container != NULL );
143 xbt_assert( subset_list != NULL );
144 xbt_assert( hostgroup != NULL );
145 xbt_assert( parent != NULL );
147 id_list = xbt_dynar_new(sizeof(char *), NULL);
149 xbt_dynar_foreach(hostgroup, iter, host_name) {
150 jed_simgrid_container_t parent;
151 xbt_assert( host_name != NULL );
152 parent = (jed_simgrid_container_t)xbt_dict_get(host2_simgrid_parent_container, host_name);
153 id_str = (char*)xbt_dict_get(parent->name2id, host_name);
154 xbt_dynar_push(id_list, &id_str);
157 nb_ids = xbt_dynar_length(id_list);
158 id_ar = xbt_new0(int,nb_ids);
159 xbt_dynar_foreach(id_list, iter, id_str) {
160 id_ar[iter] = xbt_str_parse_int(id_str, "Parse error: not a number: %s");
163 qsort (id_ar, nb_ids, sizeof(int), &compare_ids);
171 for(i=0; i<nb_ids; i++) {
173 if( id_ar[i] - id_ar[pos] > 1 ) {
175 add_subset_to( subset_list, id_ar[start], id_ar[pos], parent );
178 if( i == nb_ids-1 ) {
179 add_subset_to( subset_list, id_ar[i], id_ar[i], parent );
183 if( i == nb_ids-1 ) {
184 add_subset_to( subset_list, id_ar[start], id_ar[i], parent );
193 xbt_dynar_free(&id_list);
198 void jed_simgrid_get_resource_selection_by_hosts(xbt_dynar_t subset_list,
199 xbt_dynar_t host_names) {
203 xbt_dict_t parent2hostgroup; // group hosts by parent
205 parent2hostgroup = xbt_dict_new_homogeneous(NULL);
207 xbt_assert( host_names != NULL );
209 // for each host name
210 // find parent container
211 // group by parent container
213 xbt_dynar_foreach(host_names, iter, host_name) {
214 //printf("checking %s \n", host_name);
216 jed_simgrid_container_t parent = (jed_simgrid_container_t)xbt_dict_get(host2_simgrid_parent_container, host_name);
217 xbt_assert( parent != NULL );
219 xbt_dynar_t hostgroup = (xbt_dynar_t)xbt_dict_get_or_null (parent2hostgroup, parent->name);
220 if( hostgroup == NULL ) {
221 hostgroup = xbt_dynar_new(sizeof(char*), NULL);
222 xbt_dict_set(parent2hostgroup, parent->name, hostgroup, NULL);
225 xbt_dynar_push(hostgroup, &host_name);
229 xbt_dict_cursor_t cursor=NULL;
231 xbt_dynar_t hostgroup;
232 jed_simgrid_container_t parent;
234 xbt_dict_foreach(parent2hostgroup,cursor,parent_name,hostgroup) {
235 parent = (jed_simgrid_container_t)xbt_dict_get(container_name2container, parent_name);
236 // printf("subset parent >>> %s\n", parent->name);
237 add_subsets_to(subset_list, hostgroup, parent);
239 xbt_dynar_free(&hostgroup);
242 xbt_dict_free(&parent2hostgroup);
247 void jedule_add_meta_info(jedule_t jedule, char *key, char *value) {
251 xbt_assert(key != NULL);
252 xbt_assert(value != NULL);
254 val_cp = xbt_strdup(value);
255 xbt_dict_set(jedule->jedule_meta_info, key, val_cp, NULL);
258 void jed_create_jedule(jedule_t *jedule) {
259 *jedule = xbt_new0(s_jedule_t,1);
260 host2_simgrid_parent_container = xbt_dict_new_homogeneous(NULL);
261 container_name2container = xbt_dict_new_homogeneous(NULL);
262 (*jedule)->jedule_meta_info = xbt_dict_new_homogeneous(NULL);
265 void jed_free_jedule(jedule_t jedule) {
267 jed_free_container(jedule->root_container);
269 xbt_dict_free(&jedule->jedule_meta_info);
272 xbt_dict_free(&host2_simgrid_parent_container);
273 xbt_dict_free(&container_name2container);