Function cib_server_process_diff

cib/messages.c:222–288

int sync_in_progress = 0;

int
cib_server_process_diff(const char *op, int options, const char *section, xmlNode * req,
                        xmlNode * input, xmlNode * existing_cib, xmlNode ** result_cib,
                        xmlNode ** answer)
{
    int rc = pcmk_ok;

    if (cib_is_master) {
        /* the master is never waiting for a resync */
        sync_in_progress = 0;
    }

    if (sync_in_progress > MAX_DIFF_RETRY) {
        /* request another full-sync,
         * the last request may have been lost
         */
        sync_in_progress = 0;
    }

    if (sync_in_progress) {
        int diff_add_updates = 0;
        int diff_add_epoch = 0;
        int diff_add_admin_epoch = 0;

        int diff_del_updates = 0;
        int diff_del_epoch = 0;
        int diff_del_admin_epoch = 0;

        cib_diff_version_details(input,
                                 &diff_add_admin_epoch, &diff_add_epoch, &diff_add_updates,
                                 &diff_del_admin_epoch, &diff_del_epoch, &diff_del_updates);

        sync_in_progress++;
        crm_notice("Not applying diff %d.%d.%d -> %d.%d.%d (sync in progress)",
                   diff_del_admin_epoch, diff_del_epoch, diff_del_updates,
                   diff_add_admin_epoch, diff_add_epoch, diff_add_updates);
        return -pcmk_err_diff_resync;
    }

    rc = cib_process_diff(op, options, section, req, input, existing_cib, result_cib, answer);

    if (rc == -pcmk_err_diff_resync && cib_is_master == FALSE) {
        xmlNode *sync_me = create_xml_node(NULL, "sync-me");

        free_xml(*result_cib);
        *result_cib = NULL;
        crm_info("Requesting re-sync from peer");
        sync_in_progress++;

        crm_xml_add(sync_me, F_TYPE, "cib");
        crm_xml_add(sync_me, F_CIB_OPERATION, CIB_OP_SYNC_ONE);
        crm_xml_add(sync_me, F_CIB_DELEGATED, cib_our_uname);

        if (send_cluster_message(NULL, crm_msg_cib, sync_me, FALSE) == FALSE) {
            rc = -ENOTCONN;
        }
        free_xml(sync_me);