equilibrium2-mgmt.h

Go to the documentation of this file.

/*
 * $Id: equilibrium2-mgmt.h 366303 2010-03-05 13:14:01Z taoliu $
 *
 * 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.
 */
 
#ifndef __EQUILIBRIUM2_MGMT_H__
#define __EQUILIBRIUM2_MGMT_H__

#include <netinet/in.h>
#include <jnx/ipc_types.h>
#include <jnx/aux_types.h>
#include <jnx/junos_kcom_pub_blob.h>
#include <jnx/pconn.h>

#define DNAME_EQUILIBRIUM2_MGMT    "equilibrium2-mgmt"

#define PMON_HB_INTERVAL   30

#define EQ2_TRACE(_msg_type, _fmt, ...) \
    junos_trace((_msg_type), _fmt, ##__VA_ARGS__)

#define EQ2_LOG(_level, _fmt, ...)   \
        ERRMSG(EQ2_MGMT, (_level), _fmt, ##__VA_ARGS__)

typedef enum config_ssrb_op_e {
    CONFIG_SSRB_ADD = 1,  
    CONFIG_SSRB_CHANGE,   
    CONFIG_SSRB_DEL       
} config_ssrb_op_t;

typedef enum ssrb_state_e {
    SSRB_IDLE = 0,
    SSRB_PENDING,
    SSRB_UPDATED
} ssrb_state_t;

typedef struct svc_gate_s {
    LIST_ENTRY(svc_gate_s) entry;                   
    char                   gate_name[MAX_NAME_LEN]; 
    in_addr_t              gate_addr;               
} svc_gate_t;

typedef LIST_HEAD(svc_gate_head_s, svc_gate_s) svc_gate_head_t;

typedef struct svc_type_s {
    LIST_ENTRY(svc_type_s) entry;                   
    char                   type_name[MAX_NAME_LEN]; 
    in_port_t              type_port;               
} svc_type_t;

typedef LIST_HEAD(svc_type_head_s, svc_type_s) svc_type_head_t;

typedef struct svc_term_s {
    LIST_ENTRY(svc_term_s)  entry;                        
    char                    term_name[MAX_NAME_LEN];      
    int                     term_match;                   
    char                    term_match_val[MAX_NAME_LEN]; 
    int                     term_act;                     
    char                    term_act_val[MAX_NAME_LEN];   
} svc_term_t;

typedef LIST_HEAD(svc_term_head_s, svc_term_s) svc_term_head_t;

typedef struct svc_rule_s {
    LIST_ENTRY(svc_rule_s) entry;                   
    char                   rule_name[MAX_NAME_LEN]; 
    svc_term_head_t        rule_term_head;          
    int                    rule_term_count;         
} svc_rule_t;

typedef LIST_HEAD(svc_rule_head_s, svc_rule_s) svc_rule_head_t;

typedef struct svc_set_rule_s {
    LIST_ENTRY(svc_set_rule_s) entry;                   
    char                       rule_name[MAX_NAME_LEN]; 
} svc_set_rule_t;

typedef LIST_HEAD(svc_set_rule_head_s, svc_set_rule_s) svc_set_rule_head_t;

typedef struct svc_set_s {
    LIST_ENTRY(svc_set_s) entry;              
    char           ss_name[MAX_NAME_LEN];     
    char           ss_if_name[MAX_NAME_LEN];  
    uint16_t       ss_id;                     
    uint8_t        ss_eq2_svc_id;             
    svc_set_rule_head_t  ss_rule_head;        
    int            ss_rule_count;             
} svc_set_t;

typedef LIST_HEAD(svc_set_head_s, svc_set_s) svc_set_head_t;

typedef struct svc_if_s {
    LIST_ENTRY(svc_if_s) entry;     
    char                 *if_name;  
} svc_if_t;

typedef LIST_HEAD(svc_if_head_s, svc_if_s) svc_if_head_t;

typedef struct ssrb_node_s {
    LIST_ENTRY(ssrb_node_s) entry;       
    junos_kcom_pub_ssrb_t   ssrb;        
    ssrb_state_t            ssrb_state;  
} ssrb_node_t;

typedef LIST_HEAD(ssrb_head_s, ssrb_node_s) ssrb_head_t;

typedef struct client_s {
    LIST_ENTRY(client_s) entry;     
    pconn_session_t      *session;  
    pconn_peer_info_t    info;      
    char                 *msg;      
} client_t;

typedef LIST_HEAD(client_head_s, client_s) client_head_t;


provider_origin_id_t  eq2_origin_id;   
provider_id_t         eq2_provider_id; 
svc_if_head_t         svc_if_head;     
int                   svc_if_count;    
/*** GLOBAL/EXTERNAL Functions ***/

int kcom_init(evContext ctx);

void kcom_close(void);

int kcom_get_config_blob(void);

int kcom_add_config_blob(config_blob_key_t *key, void *blob);

int kcom_del_config_blob(config_blob_key_t *key);

int server_open(evContext ctx);

void server_close(void);

void config_init(void);

void config_clear(void);

void clear_ssrb_config(void);

int config_ssrb_op(junos_kcom_pub_ssrb_t *ssrb, config_ssrb_op_t op);

int eq2_config_read(int check);

void config_svr_group_blob_proc(config_blob_key_t *key, void *blob);

void config_svc_set_blob_proc(config_blob_key_t *key, void *blob);

client_t *client_get_next(client_t *client);

#endif

---