Function test_quorum

test/testsam.c:769–883

* Test quorum */

 * Test quorum
 */
static int test_quorum (void) {
	cmap_handle_t cmap_handle;
	cs_error_t err;
	unsigned int instance_id;
	pthread_t kill_thread;
	char *str;
	uint32_t expected_votes;

	err = cmap_initialize (&cmap_handle);
	if (err != CS_OK) {
		printf ("Could not initialize Cluster Map API instance error %d. Test skipped\n", err);
		return (1);
	}


	if (cmap_get_string(cmap_handle, "quorum.provider", &str) != CS_OK) {
		printf ("Could not get \"provider\" key: %d. Test skipped\n", err);
		return (1);
	}
        if (strcmp(str, "corosync_votequorum") != 0) {
		printf ("Provider is not corosync_votequorum. Test skipped\n");
		free(str);
		return (1);
        }
	free(str);

	if (cmap_get_uint32(cmap_handle, "quorum.expected_votes", &expected_votes) != CS_OK) {
		printf ("Could not get \"expected_votes\" key: %d. Test skipped\n", err);
		return (1);
	}

	if (expected_votes != 1) {
		printf ("Expected_votes is not 1. Test skipped\n");
		return (1);
	}

	/*
	 * Set to not quorate
	 */
	err = cmap_set_uint32(cmap_handle, "quorum.expected_votes", 2);
	if (err != CS_OK) {
		printf ("Can't set map key. Error %d\n", err);
		return (2);
	}

	printf ("%s: initialize\n", __FUNCTION__);
	err = sam_initialize (2000, SAM_RECOVERY_POLICY_QUORUM_RESTART);
	if (err != CS_OK) {
		fprintf (stderr, "Can't initialize SAM API. Error %d\n", err);
		return 2;
	}

	printf ("%s: register\n", __FUNCTION__);
	err = sam_register (&instance_id);
	if (err != CS_OK) {
		fprintf (stderr, "Can't register. Error %d\n", err);
		return 2;
	}