/*
 * Copyright 2004-2020 the Pacemaker project contributors
 *
 * The version control history for this file may have further details.
 *
 * This source code is licensed under the GNU General Public License version 2
 * or later (GPLv2+) WITHOUT ANY WARRANTY.
 */
 
#include <crm_internal.h>
 
#include <sys/param.h>
 
#include <crm/crm.h>
#include <crm/cib.h>
#include <crm/msg_xml.h>
#include <crm/common/xml.h>
 
#include <glib.h>
 
#include <crm/pengine/status.h>
#include <pacemaker-internal.h>
#include <crm/common/ipcs_internal.h>
 
gboolean show_scores = FALSE;
gboolean show_utilization = FALSE;
 
static void
log_resource_details(pe_working_set_t *data_set)
{
    int rc = pcmk_rc_ok;
    pcmk__output_t *out = NULL;
    const char* argv[] = { "", NULL };
    GListPtr unames = NULL;
    pcmk__supported_format_t formats[] = {
        PCMK__SUPPORTED_FORMAT_LOG,
        { NULL, NULL, NULL }
    };
 
    /* We need a list of nodes that we are allowed to output information for.
     * This is necessary because out->message for all the resource-related
     * messages expects such a list, due to the `crm_mon --node=` feature.  Here,
     * we just make it a list of all the nodes.
     */
    unames = g_list_append(unames, strdup("*"));
 
    pcmk__register_formats(NULL, formats);
    rc = pcmk__output_new(&out, "log", NULL, (char**)argv);
    if ((rc != pcmk_rc_ok) || (out == NULL)) {
        crm_err("Can't log resource details due to internal error: %s\n",
                pcmk_rc_str(rc));
        return;
    }
    pe__register_messages(out);
 
    for (GList *item = data_set->resources; item != NULL; item = item->next) {
        pe_resource_t *rsc = (pe_resource_t *) item->data;
 
        // Log all resources except inactive orphans
        if (is_not_set(rsc->flags, pe_rsc_orphan)
            || (rsc->role != RSC_ROLE_STOPPED)) {
            out->message(out, crm_map_element_name(rsc->xml), 0, rsc, unames);
        }
    }
 
    pcmk__output_free(out);
    g_list_free_full(unames, free);
}
 
/*!
 * \internal
 * \brief Run the scheduler for a given CIB
 *
 * \param[in,out] data_set  Cluster working set
 * \param[in]     xml_input CIB XML to use as scheduler input
 * \param[in]     now       Time to use for rule evaluation (or NULL for now)
 */
xmlNode *
pcmk__schedule_actions(pe_working_set_t *data_set, xmlNode *xml_input,
                       crm_time_t *now)
{
    GListPtr gIter = NULL;
 
/*	pe_debug_on(); */
 
    CRM_ASSERT(xml_input || is_set(data_set->flags, pe_flag_have_status));
 
    if (is_set(data_set->flags, pe_flag_have_status) == FALSE) {
        set_working_set_defaults(data_set);
        data_set->input = xml_input;
        data_set->now = now;
 
    } else {
        crm_trace("Already have status - reusing");
    }
 
    if (data_set->now == NULL) {
        data_set->now = crm_time_new(NULL);
    }
 
    crm_trace("Calculate cluster status");
    stage0(data_set);
    if (is_not_set(data_set->flags, pe_flag_quick_location)) {
        log_resource_details(data_set);
    }
 
    crm_trace("Applying placement constraints");
    stage2(data_set);
 
    if(is_set(data_set->flags, pe_flag_quick_location)){
        return NULL;
    }
 
    crm_trace("Create internal constraints");
    stage3(data_set);
 
    crm_trace("Check actions");
    stage4(data_set);
 
    crm_trace("Allocate resources");
    stage5(data_set);
 
    crm_trace("Processing fencing and shutdown cases");
    stage6(data_set);
 
    crm_trace("Applying ordering constraints");
    stage7(data_set);
 
    crm_trace("Create transition graph");
    stage8(data_set);
 
    crm_trace("=#=#=#=#= Summary =#=#=#=#=");
    crm_trace("\t========= Set %d (Un-runnable) =========", -1);
    if (get_crm_log_level() == LOG_TRACE) {
        gIter = data_set->actions;
        for (; gIter != NULL; gIter = gIter->next) {
            pe_action_t *action = (pe_action_t *) gIter->data;
 
            if (is_set(action->flags, pe_action_optional) == FALSE
                && is_set(action->flags, pe_action_runnable) == FALSE
                && is_set(action->flags, pe_action_pseudo) == FALSE) {
                log_action(LOG_TRACE, "\t", action, TRUE);
            }
        }
    }
 
    return data_set->graph;
}