Function attrd_ais_dispatch

tools/attrd.c:360–396

#if SUPPORT_COROSYNC
static gboolean
attrd_ais_dispatch(int kind, const char *from, const char *data)
{
    xmlNode *xml = NULL;

    if (kind == crm_class_cluster) {
        xml = string2xml(data);
        if (xml == NULL) {
            crm_err("Bad message received: '%.120s'", data);
        }
    }

    if (xml != NULL) {
        attr_hash_entry_t *hash_entry = NULL;
        const char *op = crm_element_value(xml, F_ATTRD_TASK);
        const char *host = crm_element_value(xml, F_ATTRD_HOST);
        const char *ignore = crm_element_value(xml, F_ATTRD_IGNORE_LOCALLY);

        /* crm_xml_add_int(xml, F_SEQ, wrapper->id); */
        crm_xml_add(xml, F_ORIG, from);

        if (host != NULL && safe_str_eq(host, attrd_uname)) {
            crm_notice("Update relayed from %s", from);
            attrd_local_callback(xml);

        } else if (ignore == NULL || safe_str_neq(from, attrd_uname)) {
            crm_trace("%s message from %s", op, from);
            hash_entry = find_hash_entry(xml);
            stop_attrd_timer(hash_entry);
            attrd_perform_update(hash_entry);
        }

        free_xml(xml);
    }

    return TRUE;
}

static void
attrd_ais_destroy(gpointer unused)