config.h File Reference

---

Detailed Description

CDiameterPeer - start-up configuration.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file config.h.

#include "utils.h"

Go to the source code of this file.

Data Structures
struct	peer_config
	Peer configuration. More...
struct	acceptor_config
	Acceptor socket configuration. More...
struct	app_config
	Application configuration. More...
struct	_routing_entry
	Routing Table Entry. More...
struct	_routing_realm
	Routing Table realm. More...
struct	routing_table
	Routing Table configuration. More...
struct	dp_config
	Full Diameter Peer configuration. More...
Typedefs
typedef _routing_entry	routing_entry
	Routing Table Entry.
typedef _routing_realm	routing_realm
	Routing Table realm.
Enumerations
enum	app_type { DP_AUTHORIZATION, DP_ACCOUNTING }
Functions
dp_config *	new_dp_config ()
	Create a new dp_config.
routing_realm *	new_routing_realm ()
	Create a new dp_config.
routing_entry *	new_routing_entry ()
	Create a new dp_config.
void	free_dp_config (dp_config *x)
	Frees the memory held by a dp_config.
void	free_routing_realm (routing_realm *rr)
	Free the space claimed by a routing realm.
void	free_routing_entry (routing_entry *re)
	Free the space claimed by a routing entry.
void	log_dp_config (int level, dp_config *x)
	Log the dp_config to output, for debug purposes.
dp_config *	parse_dp_config (char *filename)
	Parses a DiameterPeer configuration file.

---

Typedef Documentation

typedef struct _routing_entry routing_entry

Routing Table Entry.

typedef struct _routing_realm routing_realm

Routing Table realm.

---

Enumeration Type Documentation

enum app_type

Enumerator:

DP_AUTHORIZATION	Authorization application.
DP_ACCOUNTING	Accounting application.

Definition at line 73 of file config.h.

             {
    DP_AUTHORIZATION,   
    DP_ACCOUNTING       
} app_type;

---

Function Documentation

dp_config* new_dp_config

(

)

[inline]

Create a new dp_config.

Definition at line 59 of file config.c.

References LOG_NO_MEM.

Referenced by parse_dp_config().

{
    dp_config *x;   
    x = shm_malloc(sizeof(dp_config));
    if (!x) {
        LOG_NO_MEM("shm",sizeof(dp_config));
        goto error;
    }   
    memset(x,0,sizeof(dp_config));
    return x;
error:
    LOG(L_ERR,"ERROR:%s(): failed to create new dp_config.\n",__FUNCTION__);    
    return 0;
}

routing_realm* new_routing_realm

(

)

[inline]

Create a new dp_config.

Definition at line 77 of file config.c.

References LOG_NO_MEM.

Referenced by parse_dp_config().

{
    routing_realm *x;   
    x = shm_malloc(sizeof(routing_realm));
    if (!x) {
        LOG_NO_MEM("shm",sizeof(routing_realm));
        goto error;
    }   
    memset(x,0,sizeof(routing_realm));
    return x;
error:
    LOG(L_ERR,"ERROR:%s(): failed to create new routing_realm.\n",__FUNCTION__);    
    return 0;
}

routing_entry* new_routing_entry

(

)

[inline]

Create a new dp_config.

Definition at line 95 of file config.c.

References LOG_NO_MEM.

Referenced by parse_dp_config().

{
    routing_entry *x;   
    x = shm_malloc(sizeof(routing_entry));
    if (!x) {
        LOG_NO_MEM("shm",sizeof(routing_entry));
        goto error;
    }   
    memset(x,0,sizeof(routing_entry));
    return x;
error:
    LOG(L_ERR,"ERROR:%s(): failed to create new routing_entry.\n",__FUNCTION__);    
    return 0;
}

void free_dp_config

(

dp_config *

x

)

[inline]

Frees the memory held by a dp_config.

Definition at line 142 of file config.c.

References dp_config::acceptors, dp_config::acceptors_cnt, dp_config::applications, acceptor_config::bind, peer_config::fqdn, dp_config::fqdn, free_routing_entry(), free_routing_realm(), dp_config::identity, if, _routing_entry::next, _routing_realm::next, dp_config::peers, dp_config::peers_cnt, dp_config::product_name, dp_config::r_table, peer_config::realm, dp_config::realm, routing_table::realms, and routing_table::routes.

Referenced by diameter_peer_destroy(), diameter_peer_init(), and parse_dp_config().

{
    int i;
    if (!x) return;
    if (x->fqdn.s) shm_free(x->fqdn.s);
    if (x->identity.s) shm_free(x->identity.s);
    if (x->realm.s) shm_free(x->realm.s);
    if (x->product_name.s) shm_free(x->product_name.s);
    if (x->peers) {
        for(i=0;i<x->peers_cnt;i++){
            if (x->peers[i].fqdn.s) shm_free(x->peers[i].fqdn.s);
            if (x->peers[i].realm.s) shm_free(x->peers[i].realm.s);
        }
        shm_free(x->peers);
    }
    if (x->acceptors) {
        for(i=0;i<x->acceptors_cnt;i++){
            if (x->acceptors[i].bind.s) shm_free(x->acceptors[i].bind.s);
        }       
        shm_free(x->acceptors);
    }
    if (x->applications) shm_free(x->applications);
    
    if (x->r_table) {
        routing_realm *rr,*rrn;
        routing_entry *re,*ren;
        for(rr=x->r_table->realms;rr;rr=rrn){
            rrn = rr->next;
            free_routing_realm(rr);
        }
        for(re=x->r_table->routes;re;re=ren){
            ren = re->next;
            free_routing_entry(re);
        }
        shm_free(x->r_table);
    }   
    shm_free(x);
}

void free_routing_realm

(

routing_realm *

rr

)

[inline]

Free the space claimed by a routing realm.

Definition at line 124 of file config.c.

References free_routing_entry(), _routing_entry::next, _routing_realm::realm, and _routing_realm::routes.

Referenced by free_dp_config().

{
    routing_entry *re,*ren;
    if (!rr) return;
    if (rr->realm.s) shm_free(rr->realm.s);
    for(re=rr->routes;re;re=ren){
        ren = re->next;
        free_routing_entry(re);
    }
    shm_free(rr);
}

void free_routing_entry

(

routing_entry *

re

)

[inline]

Free the space claimed by a routing entry.

Definition at line 114 of file config.c.

References _routing_entry::fqdn.

Referenced by free_dp_config(), and free_routing_realm().

{
    if (!re) return;
    if (re->fqdn.s) shm_free(re->fqdn.s);
    shm_free(re);
}

void log_dp_config	(	int	level,
		dp_config *	x
	)			[inline]

Log the dp_config to output, for debug purposes.

Definition at line 184 of file config.c.

References dp_config::accept_unknown_peers, dp_config::acceptors, dp_config::acceptors_cnt, dp_config::applications, dp_config::applications_cnt, acceptor_config::bind, DP_AUTHORIZATION, dp_config::drop_unknown_peers, peer_config::fqdn, dp_config::fqdn, app_config::id, if, _routing_realm::next, dp_config::peers, dp_config::peers_cnt, acceptor_config::port, peer_config::port, dp_config::product_name, dp_config::queue_length, dp_config::r_table, peer_config::realm, dp_config::realm, routing_table::realms, dp_config::tc, app_config::type, app_config::vendor, dp_config::vendor_id, and dp_config::workers.

Referenced by diameter_peer_init().

{
    int i;
    LOG(level,"Diameter Peer Config:\n");
    LOG(level,"\tFQDN    : %.*s\n",x->fqdn.len,x->fqdn.s);
    LOG(level,"\tRealm   : %.*s\n",x->realm.len,x->realm.s);
    LOG(level,"\tVendorID: %d\n",x->vendor_id);
    LOG(level,"\tProdName: %.*s\n",x->product_name.len,x->product_name.s);
    LOG(level,"\tAcceptUn: [%c]\n",x->accept_unknown_peers?'X':' ');
    LOG(level,"\tDropUnkn: [%c]\n",x->drop_unknown_peers?'X':' ');
    LOG(level,"\tTc      : %d\n",x->tc);
    LOG(level,"\tWorkers : %d\n",x->workers);
    LOG(level,"\tQueueLen: %d\n",x->queue_length);
    LOG(level,"\tPeers : %d\n",x->peers_cnt);
    for(i=0;i<x->peers_cnt;i++)
        LOG(level,"\t\tFQDN:  %.*s \t Realm: %.*s \t Port: %d\n",
            x->peers[i].fqdn.len,x->peers[i].fqdn.s,
            x->peers[i].realm.len,x->peers[i].realm.s,
            x->peers[i].port);
    LOG(level,"\tAcceptors : %d\n",x->acceptors_cnt);
    for(i=0;i<x->acceptors_cnt;i++)
        LOG(level,"\t\tPort:  %d \t Bind: %.*s \n",
            x->acceptors[i].port,
            x->acceptors[i].bind.len,x->acceptors[i].bind.s);
    LOG(level,"\tApplications : %d\n",x->applications_cnt);
    for(i=0;i<x->applications_cnt;i++)
        LOG(level,"\t\t%s ID:  %d \t Vendor: %d \n",
            (x->applications[i].type==DP_AUTHORIZATION)?"Auth":"Acct",
            x->applications[i].id,
            x->applications[i].vendor); 
    if (x->r_table){
        routing_realm *rr;
        routing_entry *re;
        LOG(level,"\tRouting Table : \n");
        for(rr=x->r_table->realms;rr;rr=rr->next){
            LOG(level,"\t\tRealm: %.*s\n",
                rr->realm.len,rr->realm.s);
            for(re=rr->routes;re;re=re->next)       
                LOG(level,"\t\t\tRoute: [%4d] %.*s\n",
                    re->metric,re->fqdn.len,re->fqdn.s);            
        }
        for(re=x->r_table->routes;re;re=re->next)       
            LOG(level,"\t\tDefaultRoute: [%4d] %.*s\n",
                re->metric,re->fqdn.len,re->fqdn.s);            
    }
    
}

dp_config* parse_dp_config

(

char *

filename

)

Parses a DiameterPeer configuration file.

Parameters:

filename

- path to the file

Returns:

the dp_config* structure containing the parsed configuration

Definition at line 118 of file configparser.c.

References dp_config::accept_unknown_peers, dp_config::acceptors, dp_config::acceptors_cnt, dp_config::applications, dp_config::applications_cnt, acceptor_config::bind, DP_ACCOUNTING, DP_AUTHORIZATION, dp_config::drop_unknown_peers, errno, dp_config::fqdn, peer_config::fqdn, _routing_entry::fqdn, free_dp_config(), app_config::id, dp_config::identity, LOG_NO_MEM, _routing_entry::metric, new_dp_config(), new_routing_entry(), new_routing_realm(), _routing_entry::next, _routing_realm::next, parser_destroy(), parser_init(), dp_config::peers, dp_config::peers_cnt, peer_config::port, acceptor_config::port, dp_config::product_name, dp_config::queue_length, quote_trim_dup(), dp_config::r_table, dp_config::realm, peer_config::realm, _routing_realm::realm, routing_table::realms, routing_table::routes, _routing_realm::routes, dp_config::tc, app_config::type, app_config::vendor, dp_config::vendor_id, and dp_config::workers.

Referenced by diameter_peer_init().

{
    FILE *f=0;
    dp_config *x=0;
    xmlDocPtr doc=0;
    xmlNodePtr root=0,child=0,nephew=0;
    xmlChar *xc=0;
    int k;
    routing_entry *re,*rei;
    routing_realm *rr,*rri;

    parser_init();

    if (!filename){
        LOG(L_ERR,"ERROR:parse_dp_config(): filename parameter is null\n");
        goto error;
    }
    f = fopen(filename,"r");
    if (!f){
        LOG(L_ERR,"ERROR:parse_dp_config(): Error opening <%s> file > %s\n",filename,strerror(errno));
        goto error;
    }
    fclose(f);
    
    
    x = new_dp_config();
    if (!f){
        LOG(L_ERR,"ERROR:parse_dp_config(): Error opening <%s> file > %s\n",filename,strerror(errno));
        goto error;
    }

    doc = xmlParseFile(filename);
    if (!doc){
        LOG(L_ERR,"ERR:parse_dp_config():  This is not a valid XML file <%s>\n",
            filename);
        goto error;
    }

    root = xmlDocGetRootElement(doc);
    if (!root){
        LOG(L_ERR,"ERR:parse_dp_config():  Empty XML <%s>\n",filename);
        goto error;
    }

    k = xmlStrlen(root->name);
    if (k>12) k = 12;
    if (strncasecmp((char*)root->name,"DiameterPeer",k)!=0){
        LOG(L_ERR,"ERR:parse_dp_config(): XML Root is not <DiameterPeer>\n");
        goto error;
    }

    xc = xmlGetProp(root,(xmlChar*)"FQDN");
    quote_trim_dup(&(x->fqdn),(char*)xc);
    quote_trim_dup(&(x->identity),(char*)xc);

    xc = xmlGetProp(root,(xmlChar*)"Realm");
    quote_trim_dup(&(x->realm),(char*)xc);
    
    xc = xmlGetProp(root,(xmlChar*)"Vendor_Id");
    x->vendor_id = atoi((char*)xc);

    xc = xmlGetProp(root,(xmlChar*)"Product_Name");
    quote_trim_dup(&(x->product_name),(char*)xc);

    xc = xmlGetProp(root,(xmlChar*)"AcceptUnknownPeers");
    x->accept_unknown_peers = atoi((char*)xc);
    
    xc = xmlGetProp(root,(xmlChar*)"DropUnknownOnDisconnect");
    x->drop_unknown_peers = atoi((char*)xc);
    
    xc = xmlGetProp(root,(xmlChar*)"Tc");
    x->tc = atoi((char*)xc);

    xc = xmlGetProp(root,(xmlChar*)"Workers");
    x->workers = atoi((char*)xc);

    xc = xmlGetProp(root,(xmlChar*)"QueueLength");
    x->queue_length = atoi((char*)xc);

    for(child = root->children; child; child = child->next)
        if (child->type == XML_ELEMENT_NODE)
    {
        if (xmlStrlen(child->name)==4 && strncasecmp((char*)child->name,"Peer",4)==0){
            //PEER
            x->peers_cnt++;     
        }
        else if (xmlStrlen(child->name)==8 && strncasecmp((char*)child->name,"Acceptor",8)==0){
            //Acceptor
            x->acceptors_cnt++;     
        }
        else if (xmlStrlen(child->name)==4 && (strncasecmp((char*)child->name,"Auth",4)==0||
            strncasecmp((char*)child->name,"Acct",4)==0)){
            //Application
            x->applications_cnt++;      
        }   
    }
    x->peers = shm_malloc(x->peers_cnt*sizeof(peer_config));
    if (!x->peers){
        LOG_NO_MEM("shm",x->peers_cnt*sizeof(peer_config));
        goto error;
    }
    memset(x->peers,0,x->peers_cnt*sizeof(peer_config));
    x->peers_cnt=0;
    x->acceptors = shm_malloc(x->acceptors_cnt*sizeof(acceptor_config));
    if (!x->acceptors){
        LOG_NO_MEM("shm",x->acceptors_cnt*sizeof(acceptor_config));
        goto error;
    }
    memset(x->acceptors,0,x->acceptors_cnt*sizeof(acceptor_config));
    x->acceptors_cnt=0;
    x->applications = shm_malloc(x->applications_cnt*sizeof(app_config));
    if (!x->applications){
        LOG_NO_MEM("shm",x->applications_cnt*sizeof(app_config));
        goto error;
    }
    memset(x->applications,0,x->applications_cnt*sizeof(app_config));
    x->applications_cnt=0;

    for(child = root->children; child; child = child->next)
        if (child->type == XML_ELEMENT_NODE)
    {
        if (xmlStrlen(child->name)==4 && strncasecmp((char*)child->name,"Peer",4)==0){
            //PEER
            xc = xmlGetProp(child,(xmlChar*)"FQDN");
            quote_trim_dup(&(x->peers[x->peers_cnt].fqdn),(char*)xc);
            xc = xmlGetProp(child,(xmlChar*)"Realm");
            quote_trim_dup(&(x->peers[x->peers_cnt].realm),(char*)xc);          
            xc = xmlGetProp(child,(xmlChar*)"port");
            x->peers[x->peers_cnt].port = atoi((char*)xc);                      
            x->peers_cnt++;     
        }
        else if (xmlStrlen(child->name)==8 && strncasecmp((char*)child->name,"Acceptor",8)==0){
            //Acceptor
            xc = xmlGetProp(child,(xmlChar*)"bind");            
            quote_trim_dup(&(x->acceptors[x->acceptors_cnt].bind),(char*)xc);           
            xc = xmlGetProp(child,(xmlChar*)"port");
            x->acceptors[x->acceptors_cnt].port = atoi((char*)xc);                      
            x->acceptors_cnt++;     
        }
        else if (xmlStrlen(child->name)==4 && ((char*)strncasecmp((char*)child->name,"Auth",4)==0||
            strncasecmp((char*)child->name,"Acct",4)==0)){
            //Application
            xc = xmlGetProp(child,(xmlChar*)"id");          
            x->applications[x->applications_cnt].id = atoi((char*)xc);                      
            xc = xmlGetProp(child,(xmlChar*)"vendor");
            x->applications[x->applications_cnt].vendor = atoi((char*)xc);                      
            if (child->name[1]=='u'||child->name[1]=='U')
                x->applications[x->applications_cnt].type = DP_AUTHORIZATION;                       
            else
                x->applications[x->applications_cnt].type = DP_ACCOUNTING;                                      
            x->applications_cnt++;      
        }   
        else if (xmlStrlen(child->name)==12 && ((char*)strncasecmp((char*)child->name,"DefaultRoute",12)==0)){
            if (!x->r_table) {
                x->r_table = shm_malloc(sizeof(routing_table));
                memset(x->r_table,0,sizeof(routing_table));
            }
            re = new_routing_entry();
            if (re){            
                xc = xmlGetProp(child,(xmlChar*)"FQDN");
                quote_trim_dup(&(re->fqdn),(char*)xc);          
                xc = xmlGetProp(child,(xmlChar*)"metric");          
                re->metric = atoi((char*)xc);           
                
                /* add it the list in ascending order */
                if (! x->r_table->routes || re->metric <= x->r_table->routes->metric){
                    re->next = x->r_table->routes;
                    x->r_table->routes = re;
                }else{
                    for(rei=x->r_table->routes;rei;rei=rei->next)
                        if (!rei->next){
                            rei->next = re;
                            break;                      
                        }else{
                            if (re->metric <= rei->next->metric){
                                re->next = rei->next;
                                rei->next = re;
                                break;
                            }
                        }               
                }
            }                   
        }
        else if (xmlStrlen(child->name)==5 && ((char*)strncasecmp((char*)child->name,"Realm",5)==0)){
            if (!x->r_table) {
                x->r_table = shm_malloc(sizeof(routing_table));
                memset(x->r_table,0,sizeof(routing_table));
            }
            rr = new_routing_realm();
            if (rr){            
                xc = xmlGetProp(child,(xmlChar*)"name");
                quote_trim_dup(&(rr->realm),(char*)xc);         
                
                if (!x->r_table->realms) {              
                    x->r_table->realms = rr;
                }else{              
                    for(rri=x->r_table->realms;rri->next;rri=rri->next);
                    rri->next = rr;             
                }           
                for(nephew = child->children; nephew; nephew = nephew->next)
                    if (nephew->type == XML_ELEMENT_NODE){
                        if (xmlStrlen(nephew->name)==5 && ((char*)strncasecmp((char*)nephew->name,"Route",5)==0))
                        {
                            re = new_routing_entry();
                            if (re) {
                                xc = xmlGetProp(nephew,(xmlChar*)"FQDN");
                                quote_trim_dup(&(re->fqdn),(char*)xc);          
                                xc = xmlGetProp(nephew,(xmlChar*)"metric");         
                                re->metric = atoi((char*)xc);           
                                
                                /* add it the list in ascending order */
                                if (! rr->routes || re->metric <= rr->routes->metric){
                                    re->next = rr->routes;
                                    rr->routes = re;
                                }else{
                                    for(rei=rr->routes;rei;rei=rei->next)
                                        if (!rei->next){
                                            rei->next = re;
                                            break;                      
                                        }else{
                                            if (re->metric <= rei->next->metric){
                                                re->next = rei->next;
                                                rei->next = re;
                                                break;
                                            }
                                        }                   
                                }
                            }
                        }
                    }
            }       
        }
    }
    
    if (doc) xmlFreeDoc(doc);   
    parser_destroy();
    return x;
error:
    if (doc) xmlFreeDoc(doc);
    parser_destroy();
    if (x) free_dp_config(x);
    return 0;   
}

---