Function test_finalize_deadlock

test/testsam.c:885–934

}

static int test_finalize_deadlock (void) {
	cs_error_t error;
	unsigned int instance_id;
	pthread_t kill_thread;

	test_sig_delivered = 0;

	printf ("%s: initialize\n", __FUNCTION__);
	error = sam_initialize (2000, SAM_RECOVERY_POLICY_RESTART);
	if (error != CS_OK) {
		fprintf (stderr, "Can't initialize SAM API. Error %d\n", error);
		return 1;
	}
	printf ("%s: register\n", __FUNCTION__);
	error = sam_register (&instance_id);
	if (error != CS_OK) {
		fprintf (stderr, "Can't register. Error %d\n", error);
		return 1;
	}

	if (instance_id == 1) {
		/*
		 * Sam finalize might block forever, but 5s for us should be enough
		 */
		pthread_create (&kill_thread, NULL, test_thread_sleep_exit, NULL);

		printf ("%s iid %d: start\n", __FUNCTION__, instance_id);
		error = sam_start ();
		if (error != CS_OK) {
			fprintf (stderr, "Can't start hc. Error %d\n", error);
			return 1;
		}

		printf ("%s iid %d: call finalize (shouldn't deadlock)\n", __FUNCTION__, instance_id);
		error = sam_finalize ();
		if (error != CS_OK) {
			fprintf (stderr, "Can't finalize sam. Error %d\n", error);
			return 1;
		}

		printf ("%s iid %d: finalize succeeded\n", __FUNCTION__, instance_id);
		return 0;
	}

	if (instance_id == 2) {
		printf ("%s iid %d: previous sam_finalize deadlocked\n", __FUNCTION__, instance_id);
	}

	return 1;
}

/*
 * Test cmap integration + quit policy