monitube2-mgmt_main.c

Go to the documentation of this file.

/*
 * $Id: monitube2-mgmt_main.c 347265 2009-11-19 13:55:39Z kdickman $
 *
 * 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) 2009, Juniper Networks, Inc.
 * All rights reserved.
 */

/* The Application and This Daemon's Documentation: */

#include <sync/common.h>
#include <jnx/pmon.h>
#include <jnx/patricia.h>
#include "monitube2-mgmt_main.h"
#include "monitube2-mgmt_config.h"
#include "monitube2-mgmt_conn.h"
#include "monitube2-mgmt_kcom.h"
#include "monitube2-mgmt_logging.h"

#include MONITUBE2_OUT_H
#include MONITUBE2_SEQUENCE_H

/*** Constants ***/

#define DNAME_MONITUBE_MGMT    "monitube2-mgmt"


#define PMON_HB_INTERVAL   30


/*** Data Structures ***/

extern const parse_menu_t master_menu[];

static junos_pmon_context_t pmon; 

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


static void
monitube_sigterm(int signal_ign __unused)
{
    monitube_shutdown(TRUE);
}

static int
monitube_init (evContext ctx)
{
    struct timespec interval;
    
    pmon = NULL;
    
    junos_sig_register(SIGTERM, monitube_sigterm);

    if(kcom_init(ctx) != KCOM_OK) {
        goto init_fail;
    }
    
    init_config(ctx);

    if((pmon = junos_pmon_create_context()) == PMON_CONTEXT_INVALID) {
        LOG(LOG_ERR, "%s: health monitoring: initialization failed", __func__);
        goto init_fail;
    }

    if(junos_pmon_set_event_context(pmon, ctx)) {
        LOG(LOG_ERR, "%s: health monitoring: setup failed", __func__);
        goto init_fail;
    } else  {
        if(junos_pmon_select_backend(pmon, PMON_BACKEND_LOCAL, NULL)) {
            LOG(LOG_ERR, "%s: health monitoring: select backend failed",
                    __func__);
        } else {
            interval.tv_sec = PMON_HB_INTERVAL;
            interval.tv_nsec = 0;
            
            if(junos_pmon_heartbeat(pmon, &interval, 0)) {
                LOG(LOG_ERR, "%s: health monitoring: setup heartbeat failed",
                        __func__);
            }
        }
    }

    if(init_server(ctx)) {
        goto init_fail;
    }
    
    return SUCCESS;

init_fail:

    LOG(LOG_CRIT, "initialization failed");
    kcom_shutdown();
    clear_config();
    clear_stats();
//    close_connections();
    if(pmon) {
        junos_pmon_destroy_context(&pmon);
    }
    
    return EFAIL;
}


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

void
monitube_shutdown(boolean do_exit)
{
    //kcom_shutdown();
    clear_config();
    clear_stats();
    //close_connections();
    
    if(pmon)
        junos_pmon_destroy_context(&pmon);
    
    if(do_exit) {
        LOG(TRACE_LOG_INFO, "monitube2-mgmt shutting down");
        exit(0);
    }
}


int
main (int argc, char **argv)
{
    const char * monitube_trace_config[] = 
        {DDLNAME_SERVICES, DDLNAME_SYNC, DDLNAME_MONITUBE, NULL};
    
    int ret = 0;
    junos_sdk_app_ctx_t ctx;
    
    // create an application context
    ctx = junos_create_app_ctx(argc, argv, DNAME_MONITUBE_MGMT,
                 master_menu, PACKAGE_NAME, SEQUENCE_NUMBER);
    if (ctx == NULL) {
        return -1;
    }

    // set config read call back
    ret = junos_set_app_cb_config_read(ctx, monitube_config_read);
    if (ret < 0) {
        junos_destroy_app_ctx(ctx); 
        return ret;
    }
    
    ret = junos_set_app_cfg_trace_path(ctx, monitube_trace_config);
    if (ret < 0) {
        junos_destroy_app_ctx(ctx); 
        return ret;
    }
    
    // set init call back
    ret = junos_set_app_cb_init(ctx, monitube_init);
    if (ret < 0) {
        junos_destroy_app_ctx(ctx); 
        return ret;
    }

    // now just call the great junos_app_init
    ret = junos_app_init(ctx);

    // should not come here unless daemon exiting or init failed,
    // destroy context
    junos_destroy_app_ctx(ctx);
    return ret;
}

---