pcmk_setup.c

Go to the documentation of this file.

/*
 * Copyright 2024 the Pacemaker project contributors
 *
 * The version control history for this file may have further details.
 *
 * This source code is licensed under the GNU Lesser General Public License
 * version 2.1 or later (LGPLv2.1+) WITHOUT ANY WARRANTY.
 */

#include <crm_internal.h>
#include <crm/cib/internal.h>
#include <crm/common/output.h>
#include <crm/common/results.h>
#include <crm/common/scheduler.h>
#include <crm/fencing/internal.h>
#include <pacemaker-internal.h>
#include <pacemaker.h>

#include "libpacemaker_private.h"

int
pcmk__setup_output_cib_sched(pcmk__output_t **out, cib_t **cib,
                             pcmk_scheduler_t **scheduler, xmlNode **xml)
{
    int rc = pcmk_rc_ok;

    rc = pcmk__xml_output_new(out, xml);
    if (rc != pcmk_rc_ok) {
        return rc;
    }

    if (cib != NULL) {
        *cib = cib_new();
        if (*cib == NULL) {
            return pcmk_rc_cib_corrupt;
        }

        rc = (*cib)->cmds->signon(*cib, crm_system_name, cib_command);
        rc = pcmk_legacy2rc(rc);

        if (rc != pcmk_rc_ok) {
            cib__clean_up_connection(cib);
            return rc;
        }
    }

    if (scheduler != NULL) {
        rc = pcmk__init_scheduler(*out, NULL, NULL, scheduler);
        if (rc != pcmk_rc_ok && cib != NULL) {
            cib__clean_up_connection(cib);
            return rc;
        }

        pcmk__unpack_constraints(*scheduler);
    }

    pcmk__register_lib_messages(*out);
    return rc;
}

int
pcmk__setup_output_fencing(pcmk__output_t **out, stonith_t **st, xmlNode **xml)
{
    int rc = pcmk_rc_ok;

    rc = pcmk__xml_output_new(out, xml);
    if (rc != pcmk_rc_ok) {
        return rc;
    }

    *st = stonith_api_new();
    if (*st == NULL) {
        return ENOMEM;
    }

    rc = (*st)->cmds->connect(*st, crm_system_name, NULL);
    if (rc < 0) {
        rc = pcmk_legacy2rc(rc);
        stonith_api_delete(*st);
        return rc;
    }

    pcmk__register_lib_messages(*out);
    stonith__register_messages(*out);
    return rc;
}