root/lib/pacemaker/pcmk_sched_messages.c

/* */

DEFINITIONS

1. log_resource_details
2. pcmk__schedule_actions

   1 /*
   2  * Copyright 2004-2021 the Pacemaker project contributors
   3  *
   4  * The version control history for this file may have further details.
   5  *
   6  * This source code is licensed under the GNU General Public License version 2
   7  * or later (GPLv2+) WITHOUT ANY WARRANTY.
   8  */
   9 
  10 #include <crm_internal.h>
  11 
  12 #include <sys/param.h>
  13 
  14 #include <crm/crm.h>
  15 #include <crm/cib.h>
  16 #include <crm/msg_xml.h>
  17 #include <crm/common/xml.h>
  18 
  19 #include <glib.h>
  20 
  21 #include <crm/pengine/status.h>
  22 #include <pacemaker-internal.h>
  23 #include <crm/common/ipc_internal.h>
  24 
  25 extern bool pcmk__is_daemon;
  26 
  27 static void
  28 log_resource_details(pe_working_set_t *data_set)
     /*  */
  29 {
  30     pcmk__output_t *out = data_set->priv;
  31     GList *all = NULL;
  32 
  33     /* We need a list of nodes that we are allowed to output information for.
  34      * This is necessary because out->message for all the resource-related
  35      * messages expects such a list, due to the `crm_mon --node=` feature.  Here,
  36      * we just make it a list of all the nodes.
  37      */
  38     all = g_list_prepend(all, strdup("*"));
  39 
  40     for (GList *item = data_set->resources; item != NULL; item = item->next) {
  41         pe_resource_t *rsc = (pe_resource_t *) item->data;
  42 
  43         // Log all resources except inactive orphans
  44         if (!pcmk_is_set(rsc->flags, pe_rsc_orphan)
  45             || (rsc->role != RSC_ROLE_STOPPED)) {
  46             out->message(out, crm_map_element_name(rsc->xml), 0, rsc, all, all);
  47         }
  48     }
  49 
  50     g_list_free_full(all, free);
  51 }
  52 
  53 /*!
  54  * \internal
  55  * \brief Run the scheduler for a given CIB
  56  *
  57  * \param[in,out] data_set  Cluster working set
  58  * \param[in]     xml_input CIB XML to use as scheduler input
  59  * \param[in]     now       Time to use for rule evaluation (or NULL for now)
  60  */
  61 xmlNode *
  62 pcmk__schedule_actions(pe_working_set_t *data_set, xmlNode *xml_input,
     /*  */
  63                        crm_time_t *now)
  64 {
  65     GList *gIter = NULL;
  66 
  67     CRM_ASSERT(xml_input || pcmk_is_set(data_set->flags, pe_flag_have_status));
  68 
  69     if (!pcmk_is_set(data_set->flags, pe_flag_have_status)) {
  70         set_working_set_defaults(data_set);
  71         data_set->input = xml_input;
  72         data_set->now = now;
  73 
  74     } else {
  75         crm_trace("Already have status - reusing");
  76     }
  77 
  78     if (data_set->now == NULL) {
  79         data_set->now = crm_time_new(NULL);
  80     }
  81 
  82     crm_trace("Calculate cluster status");
  83     stage0(data_set);
  84     if (!pcmk_is_set(data_set->flags, pe_flag_quick_location) &&
  85          pcmk__is_daemon) {
  86         log_resource_details(data_set);
  87     }
  88 
  89     crm_trace("Applying location constraints");
  90     stage2(data_set);
  91 
  92     if (pcmk_is_set(data_set->flags, pe_flag_quick_location)) {
  93         return NULL;
  94     }
  95 
  96     crm_trace("Create internal constraints");
  97     stage3(data_set);
  98 
  99     crm_trace("Check actions");
 100     stage4(data_set);
 101 
 102     crm_trace("Allocate resources");
 103     stage5(data_set);
 104 
 105     crm_trace("Processing fencing and shutdown cases");
 106     stage6(data_set);
 107 
 108     crm_trace("Applying ordering constraints");
 109     stage7(data_set);
 110 
 111     crm_trace("Create transition graph");
 112     stage8(data_set);
 113 
 114     crm_trace("=#=#=#=#= Summary =#=#=#=#=");
 115     crm_trace("\t========= Set %d (Un-runnable) =========", -1);
 116     if (get_crm_log_level() == LOG_TRACE) {
 117         gIter = data_set->actions;
 118         for (; gIter != NULL; gIter = gIter->next) {
 119             pe_action_t *action = (pe_action_t *) gIter->data;
 120 
 121             if (!pcmk_any_flags_set(action->flags,
 122                                     pe_action_optional
 123                                     |pe_action_runnable
 124                                     |pe_action_pseudo)) {
 125                 log_action(LOG_TRACE, "\t", action, TRUE);
 126             }
 127         }
 128     }
 129 
 130     return data_set->graph;
 131 }

/* */