lib/pengine/tests/native/native_find_rsc

/* */
This source file includes following definitions.
setup
teardown
bad_args
primitive_rsc
group_rsc
inactive_group_rsc
group_member_rsc
inactive_group_member_rsc
clone_rsc
inactive_clone_rsc
clone_instance_rsc
renamed_rsc
bundle_rsc
bundle_replica_rsc
clone_group_rsc
clone_group_instance_rsc
clone_group_member_rsc
main
   1 /*
   2  * Copyright 2022 the Pacemaker project contributors
   3  *
   4  * The version control history for this file may have further details.
   5  *
   6  * This source code is licensed under the GNU Lesser General Public License
   7  * version 2.1 or later (LGPLv2.1+) WITHOUT ANY WARRANTY.
   8  */
   9 
  10 #include <crm_internal.h>
  11 
  12 #include <stdarg.h>
  13 #include <stddef.h>
  14 #include <stdint.h>
  15 #include <setjmp.h>
  16 #include <cmocka.h>
  17 
  18 #include <crm/common/xml.h>
  19 #include <crm/pengine/internal.h>
  20 #include <crm/pengine/status.h>
  21 #include <crm/pengine/pe_types.h>
  22 
  23 /* Needed to access replicas inside a bundle. */
  24 #define PE__VARIANT_BUNDLE 1
  25 #include <lib/pengine/variant.h>
  26 
  27 xmlNode *input = NULL;
  28 pe_working_set_t *data_set = NULL;
  29 
  30 pe_node_t *cluster01, *cluster02, *httpd_bundle_0;
  31 pe_resource_t *exim_group, *inactive_group, *promotable_clone, *inactive_clone;
  32 pe_resource_t *httpd_bundle, *mysql_clone_group;
  33 
  34 static int
  35 setup(void **state) {
     /*  */
  36     char *path = NULL;
  37 
  38     crm_xml_init();
  39 
  40     path = crm_strdup_printf("%s/crm_mon.xml", getenv("PCMK_CTS_CLI_DIR"));
  41     input = filename2xml(path);
  42     free(path);
  43 
  44     if (input == NULL) {
  45         return 1;
  46     }
  47 
  48     data_set = pe_new_working_set();
  49 
  50     if (data_set == NULL) {
  51         return 1;
  52     }
  53 
  54     pe__set_working_set_flags(data_set, pe_flag_no_counts|pe_flag_no_compat);
  55     data_set->input = input;
  56 
  57     cluster_status(data_set);
  58 
  59     /* Get references to the cluster nodes so we don't have to find them repeatedly. */
  60     cluster01 = pe_find_node(data_set->nodes, "cluster01");
  61     cluster02 = pe_find_node(data_set->nodes, "cluster02");
  62     httpd_bundle_0 = pe_find_node(data_set->nodes, "httpd-bundle-0");
  63 
  64     /* Get references to several resources we use frequently. */
  65     for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) {
  66         pe_resource_t *rsc = (pe_resource_t *) iter->data;
  67 
  68         if (strcmp(rsc->id, "exim-group") == 0) {
  69             exim_group = rsc;
  70         } else if (strcmp(rsc->id, "httpd-bundle") == 0) {
  71             httpd_bundle = rsc;
  72         } else if (strcmp(rsc->id, "inactive-clone") == 0) {
  73             inactive_clone = rsc;
  74         } else if (strcmp(rsc->id, "inactive-group") == 0) {
  75             inactive_group = rsc;
  76         } else if (strcmp(rsc->id, "mysql-clone-group") == 0) {
  77             mysql_clone_group = rsc;
  78         } else if (strcmp(rsc->id, "promotable-clone") == 0) {
  79             promotable_clone = rsc;
  80         }
  81     }
  82 
  83     return 0;
  84 }
  85 
  86 static int
  87 teardown(void **state) {
     /*  */
  88     pe_free_working_set(data_set);
  89 
  90     return 0;
  91 }
  92 
  93 static void
  94 bad_args(void **state) {
     /*  */
  95     pe_resource_t *rsc = (pe_resource_t *) g_list_first(data_set->resources)->data;
  96     char *id = rsc->id;
  97     char *name = NULL;
  98 
  99     assert_non_null(rsc);
 100 
 101     assert_null(native_find_rsc(NULL, "dummy", NULL, 0));
 102     assert_null(native_find_rsc(rsc, NULL, NULL, 0));
 103 
 104     /* No resources exist with these names. */
 105     name = crm_strdup_printf("%sX", rsc->id);
 106     assert_null(native_find_rsc(rsc, name, NULL, 0));
 107     free(name);
 108 
 109     name = crm_strdup_printf("x%s", rsc->id);
 110     assert_null(native_find_rsc(rsc, name, NULL, 0));
 111     free(name);
 112 
 113     name = g_ascii_strup(rsc->id, -1);
 114     assert_null(native_find_rsc(rsc, name, NULL, 0));
 115     g_free(name);
 116 
 117     /* Fails because resource ID is NULL. */
 118     rsc->id = NULL;
 119     assert_null(native_find_rsc(rsc, id, NULL, 0));
 120     rsc->id = id;
 121 }
 122 
 123 static void
 124 primitive_rsc(void **state) {
     /*  */
 125     pe_resource_t *dummy = NULL;
 126 
 127     /* Find the "dummy" resource, which is the only one with that ID in the set. */
 128     for (GList *iter = data_set->resources; iter != NULL; iter = iter->next) {
 129         pe_resource_t *rsc = (pe_resource_t *) iter->data;
 130 
 131         if (strcmp(rsc->id, "dummy") == 0) {
 132             dummy = rsc;
 133             break;
 134         }
 135     }
 136 
 137     assert_non_null(dummy);
 138 
 139     /* Passes because NULL was passed for node, regardless of flags. */
 140     assert_ptr_equal(dummy, native_find_rsc(dummy, "dummy", NULL, 0));
 141     assert_ptr_equal(dummy, native_find_rsc(dummy, "dummy", NULL, pe_find_current));
 142 
 143     /* Fails because resource is not a clone (nor cloned). */
 144     assert_null(native_find_rsc(dummy, "dummy", NULL, pe_find_clone));
 145     assert_null(native_find_rsc(dummy, "dummy", cluster02, pe_find_clone));
 146 
 147     /* Fails because dummy is not running on cluster01, even with the right flags. */
 148     assert_null(native_find_rsc(dummy, "dummy", cluster01, pe_find_current));
 149 
 150     /* Fails because pe_find_current is required if a node is given. */
 151     assert_null(native_find_rsc(dummy, "dummy", cluster02, 0));
 152 
 153     /* Passes because dummy is running on cluster02. */
 154     assert_ptr_equal(dummy, native_find_rsc(dummy, "dummy", cluster02, pe_find_current));
 155 }
 156 
 157 static void
 158 group_rsc(void **state) {
     /*  */
 159     assert_non_null(exim_group);
 160 
 161     /* Passes because NULL was passed for node, regardless of flags. */
 162     assert_ptr_equal(exim_group, native_find_rsc(exim_group, "exim-group", NULL, 0));
 163     assert_ptr_equal(exim_group, native_find_rsc(exim_group, "exim-group", NULL, pe_find_current));
 164 
 165     /* Fails because resource is not a clone (nor cloned). */
 166     assert_null(native_find_rsc(exim_group, "exim-group", NULL, pe_find_clone));
 167     assert_null(native_find_rsc(exim_group, "exim-group", cluster01, pe_find_clone));
 168 
 169     /* Fails because none of exim-group's children are running on cluster01, even with the right flags. */
 170     assert_null(native_find_rsc(exim_group, "exim-group", cluster01, pe_find_current));
 171 
 172     /* Fails because pe_find_current is required if a node is given. */
 173     assert_null(native_find_rsc(exim_group, "exim-group", cluster01, 0));
 174 
 175     /* Passes because one of exim-group's children is running on cluster02. */
 176     assert_ptr_equal(exim_group, native_find_rsc(exim_group, "exim-group", cluster02, pe_find_current));
 177 }
 178 
 179 static void
 180 inactive_group_rsc(void **state) {
     /*  */
 181     assert_non_null(inactive_group);
 182 
 183     /* Passes because NULL was passed for node, regardless of flags. */
 184     assert_ptr_equal(inactive_group, native_find_rsc(inactive_group, "inactive-group", NULL, 0));
 185     assert_ptr_equal(inactive_group, native_find_rsc(inactive_group, "inactive-group", NULL, pe_find_current));
 186     assert_ptr_equal(inactive_group, native_find_rsc(inactive_group, "inactive-group", NULL, pe_find_inactive));
 187 
 188     /* Fails because resource is not a clone (nor cloned). */
 189     assert_null(native_find_rsc(inactive_group, "inactive-group", NULL, pe_find_clone));
 190     assert_null(native_find_rsc(inactive_group, "inactive-group", cluster01, pe_find_clone));
 191 
 192     /* Fails because none of inactive-group's children are running. */
 193     assert_null(native_find_rsc(inactive_group, "inactive-group", cluster01, pe_find_current));
 194     assert_null(native_find_rsc(inactive_group, "inactive-group", cluster02, pe_find_current));
 195 
 196     /* Passes because of flags. */
 197     assert_ptr_equal(inactive_group, native_find_rsc(inactive_group, "inactive-group", cluster01, pe_find_inactive));
 198     /* Passes because of flags. */
 199     assert_ptr_equal(inactive_group, native_find_rsc(inactive_group, "inactive-group", cluster02, pe_find_inactive));
 200 }
 201 
 202 static void
 203 group_member_rsc(void **state) {
     /*  */
 204     pe_resource_t *public_ip = NULL;
 205 
 206     /* Find the "Public-IP" resource, a member of "exim-group". */
 207     for (GList *iter = exim_group->children; iter != NULL; iter = iter->next) {
 208         pe_resource_t *rsc = (pe_resource_t *) iter->data;
 209 
 210         if (strcmp(rsc->id, "Public-IP") == 0) {
 211             public_ip = rsc;
 212             break;
 213         }
 214     }
 215 
 216     assert_non_null(public_ip);
 217 
 218     /* Passes because NULL was passed for node, regardless of flags. */
 219     assert_ptr_equal(public_ip, native_find_rsc(public_ip, "Public-IP", NULL, 0));
 220     assert_ptr_equal(public_ip, native_find_rsc(public_ip, "Public-IP", NULL, pe_find_current));
 221 
 222     /* Fails because resource is not a clone (nor cloned). */
 223     assert_null(native_find_rsc(public_ip, "Public-IP", NULL, pe_find_clone));
 224     assert_null(native_find_rsc(public_ip, "Public-IP", cluster02, pe_find_clone));
 225 
 226     /* Fails because Public-IP is not running on cluster01, even with the right flags. */
 227     assert_null(native_find_rsc(public_ip, "Public-IP", cluster01, pe_find_current));
 228 
 229     /* Fails because pe_find_current is required if a node is given. */
 230     assert_null(native_find_rsc(public_ip, "Public-IP", cluster02, 0));
 231 
 232     /* Passes because Public-IP is running on cluster02. */
 233     assert_ptr_equal(public_ip, native_find_rsc(public_ip, "Public-IP", cluster02, pe_find_current));
 234 }
 235 
 236 static void
 237 inactive_group_member_rsc(void **state) {
     /*  */
 238     pe_resource_t *inactive_dummy_1 = NULL;
 239 
 240     /* Find the "inactive-dummy-1" resource, a member of "inactive-group". */
 241     for (GList *iter = inactive_group->children; iter != NULL; iter = iter->next) {
 242         pe_resource_t *rsc = (pe_resource_t *) iter->data;
 243 
 244         if (strcmp(rsc->id, "inactive-dummy-1") == 0) {
 245             inactive_dummy_1 = rsc;
 246             break;
 247         }
 248     }
 249 
 250     assert_non_null(inactive_dummy_1);
 251 
 252     /* Passes because NULL was passed for node, regardless of flags. */
 253     assert_ptr_equal(inactive_dummy_1, native_find_rsc(inactive_dummy_1, "inactive-dummy-1", NULL, 0));
 254     assert_ptr_equal(inactive_dummy_1, native_find_rsc(inactive_dummy_1, "inactive-dummy-1", NULL, pe_find_current));
 255 
 256     /* Fails because resource is not a clone (nor cloned). */
 257     assert_null(native_find_rsc(inactive_dummy_1, "inactive-dummy-1", NULL, pe_find_clone));
 258     assert_null(native_find_rsc(inactive_dummy_1, "inactive-dummy-1", cluster01, pe_find_clone));
 259 
 260     /* Fails because inactive-dummy-1 is not running. */
 261     assert_null(native_find_rsc(inactive_dummy_1, "inactive-dummy-1", cluster01, pe_find_current));
 262     assert_null(native_find_rsc(inactive_dummy_1, "inactive-dummy-1", cluster02, pe_find_current));
 263 
 264     /* Passes because of flags. */
 265     assert_ptr_equal(inactive_dummy_1, native_find_rsc(inactive_dummy_1, "inactive-dummy-1", cluster01, pe_find_inactive));
 266     /* Passes because of flags. */
 267     assert_ptr_equal(inactive_dummy_1, native_find_rsc(inactive_dummy_1, "inactive-dummy-1", cluster02, pe_find_inactive));
 268 }
 269 
 270 static void
 271 clone_rsc(void **state) {
     /*  */
 272     assert_non_null(promotable_clone);
 273 
 274     /* Passes because NULL was passed for node, regardless of flags. */
 275     assert_ptr_equal(promotable_clone, native_find_rsc(promotable_clone, "promotable-clone", NULL, 0));
 276     assert_ptr_equal(promotable_clone, native_find_rsc(promotable_clone, "promotable-clone", NULL, pe_find_current));
 277     assert_ptr_equal(promotable_clone, native_find_rsc(promotable_clone, "promotable-clone", NULL, pe_find_clone));
 278 
 279     /* Fails because pe_find_current is required if a node is given. */
 280     assert_null(native_find_rsc(promotable_clone, "promotable-clone", cluster01, 0));
 281 
 282     /* Passes because one of ping-clone's children is running on cluster01. */
 283     assert_ptr_equal(promotable_clone, native_find_rsc(promotable_clone, "promotable-clone", cluster01, pe_find_current));
 284 
 285     /* Fails because pe_find_current is required if a node is given. */
 286     assert_null(native_find_rsc(promotable_clone, "promotable-clone", cluster02, 0));
 287 
 288     /* Passes because one of ping_clone's children is running on cluster02. */
 289     assert_ptr_equal(promotable_clone, native_find_rsc(promotable_clone, "promotable-clone", cluster02, pe_find_current));
 290 
 291     /* Passes for previous reasons, plus includes pe_find_clone check. */
 292     assert_ptr_equal(promotable_clone, native_find_rsc(promotable_clone, "promotable-clone", cluster01, pe_find_clone|pe_find_current));
 293     assert_ptr_equal(promotable_clone, native_find_rsc(promotable_clone, "promotable-clone", cluster02, pe_find_clone|pe_find_current));
 294 }
 295 
 296 static void
 297 inactive_clone_rsc(void **state) {
     /*  */
 298     assert_non_null(inactive_clone);
 299 
 300     /* Passes because NULL was passed for node, regardless of flags. */
 301     assert_ptr_equal(inactive_clone, native_find_rsc(inactive_clone, "inactive-clone", NULL, 0));
 302     assert_ptr_equal(inactive_clone, native_find_rsc(inactive_clone, "inactive-clone", NULL, pe_find_current));
 303     assert_ptr_equal(inactive_clone, native_find_rsc(inactive_clone, "inactive-clone", NULL, pe_find_clone));
 304     assert_ptr_equal(inactive_clone, native_find_rsc(inactive_clone, "inactive-clone", NULL, pe_find_inactive));
 305 
 306     /* Fails because none of inactive-clone's children are running. */
 307     assert_null(native_find_rsc(inactive_clone, "inactive-clone", cluster01, pe_find_current|pe_find_clone));
 308     assert_null(native_find_rsc(inactive_clone, "inactive-clone", cluster02, pe_find_current|pe_find_clone));
 309 
 310     /* Passes because of flags. */
 311     assert_ptr_equal(inactive_clone, native_find_rsc(inactive_clone, "inactive-clone", cluster01, pe_find_inactive));
 312     /* Passes because of flags. */
 313     assert_ptr_equal(inactive_clone, native_find_rsc(inactive_clone, "inactive-clone", cluster02, pe_find_inactive));
 314 }
 315 
 316 static void
 317 clone_instance_rsc(void **state) {
     /*  */
 318     pe_resource_t *promotable_0 = NULL;
 319     pe_resource_t *promotable_1 = NULL;
 320 
 321     /* Find the "promotable-rsc:0" and "promotable-rsc:1" resources, members of "promotable-clone". */
 322     for (GList *iter = promotable_clone->children; iter != NULL; iter = iter->next) {
 323         pe_resource_t *rsc = (pe_resource_t *) iter->data;
 324 
 325         if (strcmp(rsc->id, "promotable-rsc:0") == 0) {
 326             promotable_0 = rsc;
 327         } else if (strcmp(rsc->id, "promotable-rsc:1") == 0) {
 328             promotable_1 = rsc;
 329         }
 330     }
 331 
 332     assert_non_null(promotable_0);
 333     assert_non_null(promotable_1);
 334 
 335     /* Passes because NULL was passed for node, regardless of flags. */
 336     assert_ptr_equal(promotable_0, native_find_rsc(promotable_0, "promotable-rsc:0", NULL, 0));
 337     assert_ptr_equal(promotable_0, native_find_rsc(promotable_0, "promotable-rsc:0", NULL, pe_find_current));
 338     assert_ptr_equal(promotable_1, native_find_rsc(promotable_1, "promotable-rsc:1", NULL, 0));
 339     assert_ptr_equal(promotable_1, native_find_rsc(promotable_1, "promotable-rsc:1", NULL, pe_find_current));
 340 
 341     /* Fails because pe_find_current is required if a node is given. */
 342     assert_null(native_find_rsc(promotable_0, "promotable-rsc:0", cluster02, 0));
 343     assert_null(native_find_rsc(promotable_1, "promotable-rsc:1", cluster01, 0));
 344 
 345     /* Check that the resource is running on the node we expect. */
 346     assert_ptr_equal(promotable_0, native_find_rsc(promotable_0, "promotable-rsc:0", cluster02, pe_find_current));
 347     assert_null(native_find_rsc(promotable_0, "promotable-rsc:0", cluster01, pe_find_current));
 348     assert_ptr_equal(promotable_1, native_find_rsc(promotable_1, "promotable-rsc:1", cluster01, pe_find_current));
 349     assert_null(native_find_rsc(promotable_1, "promotable-rsc:1", cluster02, pe_find_current));
 350 
 351     /* Passes because NULL was passed for node and primitive name was given, with correct flags. */
 352     assert_ptr_equal(promotable_0, native_find_rsc(promotable_0, "promotable-rsc", NULL, pe_find_clone));
 353 
 354     /* Passes because pe_find_any matches any instance's base name. */
 355     assert_ptr_equal(promotable_0, native_find_rsc(promotable_0, "promotable-rsc", NULL, pe_find_any));
 356     assert_ptr_equal(promotable_1, native_find_rsc(promotable_1, "promotable-rsc", NULL, pe_find_any));
 357 
 358     /* Passes because pe_find_anon matches. */
 359     assert_ptr_equal(promotable_0, native_find_rsc(promotable_0, "promotable-rsc", NULL, pe_find_anon));
 360     assert_ptr_equal(promotable_1, native_find_rsc(promotable_1, "promotable-rsc", NULL, pe_find_anon));
 361 
 362     /* Check that the resource is running on the node we expect. */
 363     assert_ptr_equal(promotable_0, native_find_rsc(promotable_0, "promotable-rsc", cluster02, pe_find_any|pe_find_current));
 364     assert_ptr_equal(promotable_0, native_find_rsc(promotable_0, "promotable-rsc", cluster02, pe_find_anon|pe_find_current));
 365     assert_null(native_find_rsc(promotable_0, "promotable-rsc", cluster01, pe_find_any|pe_find_current));
 366     assert_null(native_find_rsc(promotable_0, "promotable-rsc", cluster01, pe_find_anon|pe_find_current));
 367     assert_ptr_equal(promotable_1, native_find_rsc(promotable_1, "promotable-rsc", cluster01, pe_find_any|pe_find_current));
 368     assert_ptr_equal(promotable_1, native_find_rsc(promotable_1, "promotable-rsc", cluster01, pe_find_anon|pe_find_current));
 369     assert_null(native_find_rsc(promotable_1, "promotable-rsc", cluster02, pe_find_any|pe_find_current));
 370     assert_null(native_find_rsc(promotable_1, "promotable-rsc", cluster02, pe_find_anon|pe_find_current));
 371 
 372     /* Fails because incorrect flags were given along with primitive name. */
 373     assert_null(native_find_rsc(promotable_0, "promotable-rsc", NULL, pe_find_current));
 374     assert_null(native_find_rsc(promotable_1, "promotable-rsc", NULL, pe_find_current));
 375 
 376     /* And then we check failure possibilities again, except passing promotable_clone
 377      * instead of promotable_X as the first argument to native_find_rsc.
 378      */
 379 
 380     /* Fails because pe_find_current is required if a node is given. */
 381     assert_null(native_find_rsc(promotable_clone, "promotable-rsc:0", cluster02, 0));
 382     assert_null(native_find_rsc(promotable_clone, "promotable-rsc:1", cluster01, 0));
 383 
 384     /* Check that the resource is running on the node we expect. */
 385     assert_ptr_equal(promotable_0, native_find_rsc(promotable_clone, "promotable-rsc:0", cluster02, pe_find_current));
 386     assert_ptr_equal(promotable_0, native_find_rsc(promotable_clone, "promotable-rsc", cluster02, pe_find_any|pe_find_current));
 387     assert_ptr_equal(promotable_0, native_find_rsc(promotable_clone, "promotable-rsc", cluster02, pe_find_anon|pe_find_current));
 388     assert_ptr_equal(promotable_1, native_find_rsc(promotable_clone, "promotable-rsc:1", cluster01, pe_find_current));
 389     assert_ptr_equal(promotable_1, native_find_rsc(promotable_clone, "promotable-rsc", cluster01, pe_find_any|pe_find_current));
 390     assert_ptr_equal(promotable_1, native_find_rsc(promotable_clone, "promotable-rsc", cluster01, pe_find_anon|pe_find_current));
 391 }
 392 
 393 static void
 394 renamed_rsc(void **state) {
     /*  */
 395     pe_resource_t *promotable_0 = NULL;
 396     pe_resource_t *promotable_1 = NULL;
 397 
 398     /* Find the "promotable-rsc:0" and "promotable-rsc:1" resources, members of "promotable-clone". */
 399     for (GList *iter = promotable_clone->children; iter != NULL; iter = iter->next) {
 400         pe_resource_t *rsc = (pe_resource_t *) iter->data;
 401 
 402         if (strcmp(rsc->id, "promotable-rsc:0") == 0) {
 403             promotable_0 = rsc;
 404         } else if (strcmp(rsc->id, "promotable-rsc:1") == 0) {
 405             promotable_1 = rsc;
 406         }
 407     }
 408 
 409     assert_non_null(promotable_0);
 410     assert_non_null(promotable_1);
 411 
 412     /* Passes because pe_find_renamed means the base name matches clone_name. */
 413     assert_ptr_equal(promotable_0, native_find_rsc(promotable_0, "promotable-rsc", NULL, pe_find_renamed));
 414     assert_ptr_equal(promotable_1, native_find_rsc(promotable_1, "promotable-rsc", NULL, pe_find_renamed));
 415 }
 416 
 417 static void
 418 bundle_rsc(void **state) {
     /*  */
 419     assert_non_null(httpd_bundle);
 420 
 421     /* Passes because NULL was passed for node, regardless of flags. */
 422     assert_ptr_equal(httpd_bundle, native_find_rsc(httpd_bundle, "httpd-bundle", NULL, 0));
 423     assert_ptr_equal(httpd_bundle, native_find_rsc(httpd_bundle, "httpd-bundle", NULL, pe_find_current));
 424 
 425     /* Fails because resource is not a clone (nor cloned). */
 426     assert_null(native_find_rsc(httpd_bundle, "httpd-bundle", NULL, pe_find_clone));
 427     assert_null(native_find_rsc(httpd_bundle, "httpd-bundle", cluster01, pe_find_clone));
 428 
 429     /* Fails because pe_find_current is required if a node is given. */
 430     assert_null(native_find_rsc(httpd_bundle, "httpd-bundle", cluster01, 0));
 431 
 432     /* Passes because one of httpd_bundle's children is running on cluster01. */
 433     assert_ptr_equal(httpd_bundle, native_find_rsc(httpd_bundle, "httpd-bundle", cluster01, pe_find_current));
 434 }
 435 
 436 static void
 437 bundle_replica_rsc(void **state) {
     /*  */
 438     pe__bundle_variant_data_t *bundle_data = NULL;
 439     pe__bundle_replica_t *replica_0 = NULL;
 440 
 441     pe_resource_t *ip_0 = NULL;
 442     pe_resource_t *child_0 = NULL;
 443     pe_resource_t *container_0 = NULL;
 444     pe_resource_t *remote_0 = NULL;
 445 
 446     get_bundle_variant_data(bundle_data, httpd_bundle);
 447     replica_0 = (pe__bundle_replica_t *) bundle_data->replicas->data;
 448 
 449     ip_0 = replica_0->ip;
 450     child_0 = replica_0->child;
 451     container_0 = replica_0->container;
 452     remote_0 = replica_0->remote;
 453 
 454     assert_non_null(ip_0);
 455     assert_non_null(child_0);
 456     assert_non_null(container_0);
 457     assert_non_null(remote_0);
 458 
 459     /* Passes because NULL was passed for node, regardless of flags. */
 460     assert_ptr_equal(ip_0, native_find_rsc(ip_0, "httpd-bundle-ip-192.168.122.131", NULL, 0));
 461     assert_ptr_equal(child_0, native_find_rsc(child_0, "httpd:0", NULL, 0));
 462     assert_ptr_equal(container_0, native_find_rsc(container_0, "httpd-bundle-docker-0", NULL, 0));
 463     assert_ptr_equal(remote_0, native_find_rsc(remote_0, "httpd-bundle-0", NULL, 0));
 464 
 465     /* Fails because pe_find_current is required if a node is given. */
 466     assert_null(native_find_rsc(ip_0, "httpd-bundle-ip-192.168.122.131", cluster01, 0));
 467     assert_null(native_find_rsc(child_0, "httpd:0", httpd_bundle_0, 0));
 468     assert_null(native_find_rsc(container_0, "httpd-bundle-docker-0", cluster01, 0));
 469     assert_null(native_find_rsc(remote_0, "httpd-bundle-0", cluster01, 0));
 470 
 471     /* Check that the resource is running on the node we expect. */
 472     assert_ptr_equal(ip_0, native_find_rsc(ip_0, "httpd-bundle-ip-192.168.122.131", cluster01, pe_find_current));
 473     assert_null(native_find_rsc(ip_0, "httpd-bundle-ip-192.168.122.131", cluster02, pe_find_current));
 474     assert_null(native_find_rsc(ip_0, "httpd-bundle-ip-192.168.122.131", httpd_bundle_0, pe_find_current));
 475     assert_ptr_equal(child_0, native_find_rsc(child_0, "httpd:0", httpd_bundle_0, pe_find_current));
 476     assert_null(native_find_rsc(child_0, "httpd:0", cluster01, pe_find_current));
 477     assert_null(native_find_rsc(child_0, "httpd:0", cluster02, pe_find_current));
 478     assert_ptr_equal(container_0, native_find_rsc(container_0, "httpd-bundle-docker-0", cluster01, pe_find_current));
 479     assert_null(native_find_rsc(container_0, "httpd-bundle-docker-0", cluster02, pe_find_current));
 480     assert_null(native_find_rsc(container_0, "httpd-bundle-docker-0", httpd_bundle_0, pe_find_current));
 481     assert_ptr_equal(remote_0, native_find_rsc(remote_0, "httpd-bundle-0", cluster01, pe_find_current));
 482     assert_null(native_find_rsc(remote_0, "httpd-bundle-0", cluster02, pe_find_current));
 483     assert_null(native_find_rsc(remote_0, "httpd-bundle-0", httpd_bundle_0, pe_find_current));
 484 
 485     /* Passes because pe_find_any matches any replica's base name. */
 486     assert_ptr_equal(child_0, native_find_rsc(child_0, "httpd", NULL, pe_find_any));
 487 
 488     /* Passes because pe_find_anon matches. */
 489     assert_ptr_equal(child_0, native_find_rsc(child_0, "httpd", NULL, pe_find_anon));
 490 
 491     /* Check that the resource is running on the node we expect. */
 492     assert_ptr_equal(child_0, native_find_rsc(child_0, "httpd", httpd_bundle_0, pe_find_any|pe_find_current));
 493     assert_ptr_equal(child_0, native_find_rsc(child_0, "httpd", httpd_bundle_0, pe_find_anon|pe_find_current));
 494     assert_null(native_find_rsc(child_0, "httpd", cluster01, pe_find_any|pe_find_current));
 495     assert_null(native_find_rsc(child_0, "httpd", cluster01, pe_find_anon|pe_find_current));
 496     assert_null(native_find_rsc(child_0, "httpd", cluster02, pe_find_any|pe_find_current));
 497     assert_null(native_find_rsc(child_0, "httpd", cluster02, pe_find_anon|pe_find_current));
 498 
 499     /* Fails because incorrect flags were given along with base name. */
 500     assert_null(native_find_rsc(child_0, "httpd", NULL, pe_find_current));
 501 
 502     /* And then we check failure possibilities again, except passing httpd-bundle
 503      * instead of X_0 as the first argument to native_find_rsc.
 504      */
 505 
 506     /* Fails because pe_find_current is required if a node is given. */
 507     assert_null(native_find_rsc(httpd_bundle, "httpd-bundle-ip-192.168.122.131", cluster01, 0));
 508     assert_null(native_find_rsc(httpd_bundle, "httpd:0", httpd_bundle_0, 0));
 509     assert_null(native_find_rsc(httpd_bundle, "httpd-bundle-docker-0", cluster01, 0));
 510     assert_null(native_find_rsc(httpd_bundle, "httpd-bundle-0", cluster01, 0));
 511 
 512     /* Check that the resource is running on the node we expect. */
 513     assert_ptr_equal(ip_0, native_find_rsc(httpd_bundle, "httpd-bundle-ip-192.168.122.131", cluster01, pe_find_current));
 514     assert_ptr_equal(child_0, native_find_rsc(httpd_bundle, "httpd:0", httpd_bundle_0, pe_find_current));
 515     assert_ptr_equal(container_0, native_find_rsc(httpd_bundle, "httpd-bundle-docker-0", cluster01, pe_find_current));
 516     assert_ptr_equal(remote_0, native_find_rsc(httpd_bundle, "httpd-bundle-0", cluster01, pe_find_current));
 517 }
 518 
 519 static void
 520 clone_group_rsc(void **rsc) {
     /*  */
 521     assert_non_null(mysql_clone_group);
 522 
 523     /* Passes because NULL was passed for node, regardless of flags. */
 524     assert_ptr_equal(mysql_clone_group, native_find_rsc(mysql_clone_group, "mysql-clone-group", NULL, 0));
 525     assert_ptr_equal(mysql_clone_group, native_find_rsc(mysql_clone_group, "mysql-clone-group", NULL, pe_find_current));
 526     assert_ptr_equal(mysql_clone_group, native_find_rsc(mysql_clone_group, "mysql-clone-group", NULL, pe_find_clone));
 527 
 528     /* Fails because pe_find_current is required if a node is given. */
 529     assert_null(native_find_rsc(mysql_clone_group, "mysql-clone-group", cluster01, 0));
 530 
 531     /* Passes because one of mysql-clone-group's children is running on cluster01. */
 532     assert_ptr_equal(mysql_clone_group, native_find_rsc(mysql_clone_group, "mysql-clone-group", cluster01, pe_find_current));
 533 
 534     /* Fails because pe_find_current is required if a node is given. */
 535     assert_null(native_find_rsc(mysql_clone_group, "mysql-clone-group", cluster02, 0));
 536 
 537     /* Passes because one of mysql-clone-group's children is running on cluster02. */
 538     assert_ptr_equal(mysql_clone_group, native_find_rsc(mysql_clone_group, "mysql-clone-group", cluster02, pe_find_current));
 539 
 540     /* Passes for previous reasons, plus includes pe_find_clone check. */
 541     assert_ptr_equal(mysql_clone_group, native_find_rsc(mysql_clone_group, "mysql-clone-group", cluster01, pe_find_clone|pe_find_current));
 542     assert_ptr_equal(mysql_clone_group, native_find_rsc(mysql_clone_group, "mysql-clone-group", cluster02, pe_find_clone|pe_find_current));
 543 }
 544 
 545 static void
 546 clone_group_instance_rsc(void **rsc) {
     /*  */
 547     pe_resource_t *mysql_group_0 = NULL;
 548     pe_resource_t *mysql_group_1 = NULL;
 549 
 550     /* Find the "mysql-group:0" and "mysql-group:1" resources, members of "mysql-clone-group". */
 551     for (GList *iter = mysql_clone_group->children; iter != NULL; iter = iter->next) {
 552         pe_resource_t *rsc = (pe_resource_t *) iter->data;
 553 
 554         if (strcmp(rsc->id, "mysql-group:0") == 0) {
 555             mysql_group_0 = rsc;
 556         } else if (strcmp(rsc->id, "mysql-group:1") == 0) {
 557             mysql_group_1 = rsc;
 558         }
 559     }
 560 
 561     assert_non_null(mysql_group_0);
 562     assert_non_null(mysql_group_1);
 563 
 564     /* Passes because NULL was passed for node, regardless of flags. */
 565     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_group_0, "mysql-group:0", NULL, 0));
 566     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_group_0, "mysql-group:0", NULL, pe_find_current));
 567     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_group_1, "mysql-group:1", NULL, 0));
 568     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_group_1, "mysql-group:1", NULL, pe_find_current));
 569 
 570     /* Fails because pe_find_current is required if a node is given. */
 571     assert_null(native_find_rsc(mysql_group_0, "mysql-group:0", cluster02, 0));
 572     assert_null(native_find_rsc(mysql_group_1, "mysql-group:1", cluster01, 0));
 573 
 574     /* Check that the resource is running on the node we expect. */
 575     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_group_0, "mysql-group:0", cluster02, pe_find_current));
 576     assert_null(native_find_rsc(mysql_group_0, "mysql-group:0", cluster01, pe_find_current));
 577     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_group_1, "mysql-group:1", cluster01, pe_find_current));
 578     assert_null(native_find_rsc(mysql_group_1, "mysql-group:1", cluster02, pe_find_current));
 579 
 580     /* Passes because NULL was passed for node and base name was given, with correct flags. */
 581     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_group_0, "mysql-group" , NULL, pe_find_clone));
 582 
 583     /* Passes because pe_find_any matches any base name. */
 584     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_group_0, "mysql-group" , NULL, pe_find_any));
 585     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_group_1, "mysql-group" , NULL, pe_find_any));
 586 
 587     /* Passes because pe_find_anon matches. */
 588     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_group_0, "mysql-group" , NULL, pe_find_anon));
 589     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_group_1, "mysql-group" , NULL, pe_find_anon));
 590 
 591     /* Check that the resource is running on the node we expect. */
 592     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_group_0, "mysql-group", cluster02, pe_find_any|pe_find_current));
 593     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_group_0, "mysql-group", cluster02, pe_find_anon|pe_find_current));
 594     assert_null(native_find_rsc(mysql_group_0, "mysql-group", cluster01, pe_find_any|pe_find_current));
 595     assert_null(native_find_rsc(mysql_group_0, "mysql-group", cluster01, pe_find_anon|pe_find_current));
 596     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_group_1, "mysql-group", cluster01, pe_find_any|pe_find_current));
 597     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_group_1, "mysql-group", cluster01, pe_find_anon|pe_find_current));
 598     assert_null(native_find_rsc(mysql_group_1, "mysql-group", cluster02, pe_find_any|pe_find_current));
 599     assert_null(native_find_rsc(mysql_group_1, "mysql-group", cluster02, pe_find_anon|pe_find_current));
 600 
 601     /* Fails because incorrect flags were given along with base name. */
 602     assert_null(native_find_rsc(mysql_group_0, "mysql-group", NULL, pe_find_current));
 603     assert_null(native_find_rsc(mysql_group_1, "mysql-group", NULL, pe_find_current));
 604 
 605     /* And then we check failure possibilities again, except passing mysql_clone_group
 606      * instead of mysql_group_X as the first argument to native_find_rsc.
 607      */
 608 
 609     /* Fails because pe_find_current is required if a node is given. */
 610     assert_null(native_find_rsc(mysql_clone_group, "mysql-group:0", cluster02, 0));
 611     assert_null(native_find_rsc(mysql_clone_group, "mysql-group:1", cluster01, 0));
 612 
 613     /* Check that the resource is running on the node we expect. */
 614     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_clone_group, "mysql-group:0", cluster02, pe_find_current));
 615     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_clone_group, "mysql-group", cluster02, pe_find_any|pe_find_current));
 616     assert_ptr_equal(mysql_group_0, native_find_rsc(mysql_clone_group, "mysql-group", cluster02, pe_find_anon|pe_find_current));
 617     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_clone_group, "mysql-group:1", cluster01, pe_find_current));
 618     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_clone_group, "mysql-group", cluster01, pe_find_any|pe_find_current));
 619     assert_ptr_equal(mysql_group_1, native_find_rsc(mysql_clone_group, "mysql-group", cluster01, pe_find_anon|pe_find_current));
 620 }
 621 
 622 static void
 623 clone_group_member_rsc(void **state) {
     /*  */
 624     pe_resource_t *mysql_proxy = NULL;
 625 
 626     /* Find the "mysql-proxy" resource, a member of "mysql-group". */
 627     for (GList *iter = mysql_clone_group->children; iter != NULL; iter = iter->next) {
 628         pe_resource_t *rsc = (pe_resource_t *) iter->data;
 629 
 630         if (strcmp(rsc->id, "mysql-group:0") == 0) {
 631             for (GList *iter2 = rsc->children; iter2 != NULL; iter2 = iter2->next) {
 632                 pe_resource_t *child = (pe_resource_t *) iter2->data;
 633 
 634                 if (strcmp(child->id, "mysql-proxy:0") == 0) {
 635                     mysql_proxy = child;
 636                     break;
 637                 }
 638             }
 639 
 640             break;
 641         }
 642     }
 643 
 644     assert_non_null(mysql_proxy);
 645 
 646     /* Passes because NULL was passed for node, regardless of flags. */
 647     assert_ptr_equal(mysql_proxy, native_find_rsc(mysql_proxy, "mysql-proxy:0", NULL, 0));
 648     assert_ptr_equal(mysql_proxy, native_find_rsc(mysql_proxy, "mysql-proxy:0", NULL, pe_find_current));
 649 
 650     /* Passes because resource's parent is a clone. */
 651     assert_ptr_equal(mysql_proxy, native_find_rsc(mysql_proxy, "mysql-proxy:0", NULL, pe_find_clone));
 652     assert_ptr_equal(mysql_proxy, native_find_rsc(mysql_proxy, "mysql-proxy:0", cluster02, pe_find_clone|pe_find_current));
 653 
 654     /* Fails because mysql-proxy:0 is not running on cluster01, even with the right flags. */
 655     assert_null(native_find_rsc(mysql_proxy, "mysql-proxy:0", cluster01, pe_find_current));
 656 
 657     /* Fails because pe_find_current is required if a node is given. */
 658     assert_null(native_find_rsc(mysql_proxy, "mysql-proxy:0", cluster02, 0));
 659 
 660     /* Passes because mysql-proxy:0 is running on cluster02. */
 661     assert_ptr_equal(mysql_proxy, native_find_rsc(mysql_proxy, "mysql-proxy:0", cluster02, pe_find_current));
 662 }
 663 
 664 int main(int argc, char **argv) {
     /*  */
 665     /* TODO: Add tests for finding on allocated node (passing a node without
 666      * pe_find_current, after scheduling, for a resource that is starting/stopping/moving.
 667      */
 668 
 669     const struct CMUnitTest tests[] = {
 670         cmocka_unit_test(bad_args),
 671         cmocka_unit_test(primitive_rsc),
 672         cmocka_unit_test(group_rsc),
 673         cmocka_unit_test(inactive_group_rsc),
 674         cmocka_unit_test(group_member_rsc),
 675         cmocka_unit_test(inactive_group_member_rsc),
 676         cmocka_unit_test(clone_rsc),
 677         cmocka_unit_test(inactive_clone_rsc),
 678         cmocka_unit_test(clone_instance_rsc),
 679         cmocka_unit_test(renamed_rsc),
 680         cmocka_unit_test(bundle_rsc),
 681         cmocka_unit_test(bundle_replica_rsc),
 682         cmocka_unit_test(clone_group_rsc),
 683         cmocka_unit_test(clone_group_instance_rsc),
 684         cmocka_unit_test(clone_group_member_rsc),
 685     };
 686 
 687     cmocka_set_message_output(CM_OUTPUT_TAP);
 688     return cmocka_run_group_tests(tests, setup, teardown);
 689 }
/* */
root/lib/pengine/tests/native/native_find_rsc_test.c

DEFINITIONS
