equilibrium-data_main.c

Go to the documentation of this file.

/*
 * $Id: equilibrium-data_main.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) 2008, Juniper Networks, Inc.
 * All rights reserved.
 */

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

#include "equilibrium-data_main.h"
#include "equilibrium-data_config.h"
#include "equilibrium-data_conn.h"
#include "equilibrium-data_monitor.h"
#include "equilibrium-data_packet.h"

/*** Constants ***/

#define DNAME_EQUILIBRIUM_DATA    "equilibrium-data"

/*** Data Structures ***/

static evContext mainctx; 

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


static void 
equilibrium_quit(int signo __unused)
{
    LOG(LOG_INFO, "Shutting down");
    
    close_connections();
    
    LOG(LOG_INFO, "Shutting down data loops");
    destroy_packet_loops(mainctx);
    LOG(LOG_INFO, "Shutting down data loops...done");
    
    clear_config();
    
    LOG(LOG_INFO, "Stopping server montior");
    shutdown_monitor();
    
    msp_exit();
    
    LOG(LOG_INFO, "Shutting down finished");
    
    exit(0);
}


static int
equilibrium_init(evContext ctx)
{
    int rc;
    int other_user_cpu, tmp_cpu;
    int monitor_user_cpu;
    int mon_core_num, tmp_core_num;

    msp_init();
    
    // Handle some signals that we may receive:
    signal(SIGTERM, equilibrium_quit); // call quit fnc
    signal(SIGHUP, SIG_IGN); // ignore
    signal(SIGPIPE, SIG_IGN); // ignore
    
    logging_set_level(LOG_INFO);
    logging_set_mode(LOGGING_SYSLOG);
    
    // call init function for modules:
    
    mainctx = ctx;
    
    rc = init_config(ctx);
    if(rc != SUCCESS) {
        goto failed;
    }
    
    rc = init_connections(ctx);
    if(rc != SUCCESS) {
        goto failed;
    }
    
    // give the monitor a user cpu number to use
    
    monitor_user_cpu = msp_env_get_next_user_cpu(MSP_NEXT_NONE);
    
    rc = init_monitor(ctx, monitor_user_cpu);
    if(rc != SUCCESS) {
        goto failed;
    }
    
    // find another user cpu number to use for this main thread
    tmp_cpu = other_user_cpu = msp_env_get_next_user_cpu(monitor_user_cpu);
    
    // if at least one valid user cpu available...
    if(monitor_user_cpu != MSP_NEXT_END && other_user_cpu != MSP_NEXT_END) {

        mon_core_num = msp_env_cpu_to_core(monitor_user_cpu);
        tmp_core_num = msp_env_cpu_to_core(tmp_cpu);
        
        // try to find a user cpu on a different core from the monitoring
        // thread if one exists
        while(mon_core_num == tmp_core_num) {
            if((tmp_cpu = msp_env_get_next_user_cpu(tmp_cpu)) == MSP_NEXT_END) {
                break;
            }
            tmp_core_num = msp_env_cpu_to_core(tmp_cpu);
        }
        
        if(tmp_cpu != MSP_NEXT_END) { // it should be on another user core
            other_user_cpu = tmp_cpu;
        }
        // else it will be on the same user core as the monitoring thread
        
        LOG(LOG_INFO, "%s: Binding main process to user cpu %d",
                __func__, other_user_cpu);
        
        if(msp_process_bind(other_user_cpu) != SUCCESS) {
            goto failed;
        }
    }
    
    rc = init_packet_loops(ctx);
    if(rc != SUCCESS) {
        goto failed;
    }

    return SUCCESS;
    
failed:

    LOG(LOG_ALERT, "%s: Failed to intialize. "
            "See error log for details ", __func__);
    equilibrium_quit(0);
    return EFAIL;
}


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


int
main(int32_t argc , char **argv)
{
    mp_sdk_app_ctx_t app_ctx;
    int rc;

    app_ctx = msp_create_app_ctx(argc, argv, DNAME_EQUILIBRIUM_DATA);
    msp_set_app_cb_init(app_ctx, equilibrium_init);

    rc = msp_app_init(app_ctx);
    
    /* Should never reach this point */
    msp_destroy_app_ctx(app_ctx);
    return rc;
}

---