counterd_config.c

Go to the documentation of this file.

/*
 * $Id: counterd_config.c 346460 2009-11-14 05:06:47Z ssiano $
 *
 * This code is provided as is by Juniper Networks SDK Developer Support.
 * It is provided with no warranties or guarantees, and Juniper Networks
 * will not provide support or maintenance of this code in any fashion.
 * The code is provided only to help a developer better understand how
 * the SDK can be used.
 *
 * Copyright (c) 2007-2008, Juniper Networks, Inc.
 * All rights reserved.
 */

#include <ddl/dax.h>
#include <jnx/patricia.h>
#include <jnx/junos_trace.h>
#include "counterd_config.h"
#include "counterd_message.h"
#include COUNTERD_OUT_H

/*** Data Structures ***/


static patroot root; 


/*** STATIC/INTERNAL Functions ***/


PATNODE_TO_STRUCT(data_entry, counter_data_t, node)



static int
delete_message (counter_data_t *data)
{
    /* remove data from patricia tree */
    if (!patricia_delete(&root, &data->node)) {
        free(data);
        return EFAIL;
    }

    free(data);
    return SUCCESS;
}


static counter_data_t *
add_message (const char * message)
{
    counter_data_t *data;

    /* allocate & initialize data */
    data = calloc(1, sizeof(counter_data_t)); /* calloc zeros mem */
    INSIST_ERR(data != NULL); /* check that allocation worked */
    INSIST_ERR(strlen(message) < MESSAGE_STR_SIZE); /* check for length */
    
    strcpy(data->message, message);

    /* add to data_root patricia tree */
    patricia_node_init_length(&data->node,
                              strlen(data->message) + 1);
                              
    if (!patricia_add(&root, &data->node)) {
        free(data);
        return NULL;
    }

    return data;
}


static int
clear_messages (void)
{
    counter_data_t *data = NULL;

    while ((data = first_message()) != NULL) {
        if(delete_message(data) == EFAIL) {
            return EFAIL;
        }
    }
    return SUCCESS;
}


/*** GLOBAL/EXTERNAL Functions ***/


void
init_messages_ds (void)
{
    patricia_root_init(&root, FALSE, MESSAGE_STR_SIZE, 0);
}


counter_data_t *
first_message (void)
{
    return data_entry(patricia_find_next(&root, NULL));
}


counter_data_t *
next_message (counter_data_t * data)
{
    return data_entry(patricia_find_next(&root, (data ? &(data->node) : NULL)));
}


int
counterd_config_read (int check)
{

    ddl_handle_t * dop = NULL; /* DDL Object Pointer */
    const char   * data_config_name[] =  { DDLNAME_SYNC,
                                           DDLNAME_SYNC_COUNTER,
                                           DDLNAME_SYNC_COUNTER_MESSAGE,
                                           NULL};
    char          msg[MESSAGE_STR_SIZE];
    int           status = SUCCESS;

    /*
     * read counterd data configuration
     */
    if (dax_get_object_by_path(NULL, data_config_name, &dop, FALSE)) {

        if (dax_is_changed(dop)) {
            /* if message has changed */

            /* clear stored config data, & repopulate with new config data */
            if((status = clear_messages()) == EFAIL) {
                dax_error(dop, "Failed to clear stored configuration");
            }
    
            if (dax_get_stringr_by_aid(dop, COUNTER_MESSAGE_CONTENTS, 
                    msg, sizeof(msg))) {
    
                if(add_message(msg) == NULL) { /* add this message */
                    dax_error(dop, "Failed to add message to configuration");
                    status = EFAIL;
                } else if(!check) {
                    reset_message(msg); /* message added, GENCFG reset */
                }
    
            } else {
                dax_error(dop, "Couldn't read message from configuration");
                status = EFAIL;
            }
        }
    } else {
        /* clear stored config data because we have no configure data */
        if((status = clear_messages()) == EFAIL) {
            dax_error(dop, "Failed to clear stored configuration");
        }
    }

    if (dop) {
        dax_release_object(&dop);
    }
    
    return status;
}

---