Function sam_start

lib/sam.c:601–647

}

cs_error_t sam_start (void)
{
	char command;
	cs_error_t ret;
	sam_recovery_policy_t recpol;

	ret = CS_OK;

	pthread_mutex_lock (&sam_internal_data.lock);

	if (sam_internal_data.internal_status != SAM_INTERNAL_STATUS_REGISTERED) {
		ret = CS_ERR_BAD_HANDLE;
		goto exit_mutex_unlock;
	}

	recpol = sam_internal_data.recovery_policy;

	command = SAM_COMMAND_START;

	if (sam_safe_write (sam_internal_data.child_fd_out, &command, sizeof (command)) != sizeof (command)) {
		ret = CS_ERR_LIBRARY;
		goto exit_mutex_unlock;
	}

	if (recpol & SAM_RECOVERY_POLICY_QUORUM || recpol & SAM_RECOVERY_POLICY_CMAP) {
		/*
		 * Wait for parent reply
		 */
		if ((ret = sam_read_reply (sam_internal_data.child_fd_in)) != CS_OK) {
			goto exit_mutex_unlock;
		}
	}

	if (sam_internal_data.hc_callback) {
		if (sam_safe_write (sam_internal_data.cb_wpipe_fd, &command, sizeof (command)) != sizeof (command)) {
			ret = CS_ERR_LIBRARY;
			goto exit_mutex_unlock;
		}
	}

	sam_internal_data.internal_status = SAM_INTERNAL_STATUS_STARTED;

exit_mutex_unlock:
	pthread_mutex_unlock (&sam_internal_data.lock);

	return (ret);
}

static cs_error_t sam_stop_nolock (void)
{