registrar_storage.h

Go to the documentation of this file.

/*
 * $Id: registrar_storage.h 336 2007-06-21 23:07:09Z flp $
 *  
 * Copyright (C) 2004-2006 FhG Fokus
 *
 * This file is part of Open IMS Core - an open source IMS CSCFs & HSS
 * implementation
 *
 * Open IMS Core is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * For a license to use the Open IMS Core software under conditions
 * other than those described here, or to purchase support for this
 * software, please contact Fraunhofer FOKUS by e-mail at the following
 * addresses:
 *     info@open-ims.org
 *
 * Open IMS Core is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 * 
 * It has to be noted that this Open Source IMS Core System is not 
 * intended to become or act as a product in a commercial context! Its 
 * sole purpose is to provide an IMS core reference implementation for 
 * IMS technology testing and IMS application prototyping for research 
 * purposes, typically performed in IMS test-beds.
 * 
 * Users of the Open Source IMS Core System have to be aware that IMS
 * technology may be subject of patents and licence terms, as being 
 * specified within the various IMS-related IETF, ITU-T, ETSI, and 3GPP
 * standards. Thus all Open IMS Core users have to take notice of this 
 * fact and have to agree to check out carefully before installing, 
 * using and extending the Open Source IMS Core System, if related 
 * patents and licences may become applicable to the intended usage 
 * context.  
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 * 
 */

#ifndef P_CSCF_REGISTRAR_STORAGE_H_
#define P_CSCF_REGISTRAR_STORAGE_H_

#include "../../sr_module.h"
#include "../../locking.h"

typedef struct _r_nat_dest{
    struct ip_addr nat_addr;    
    unsigned short nat_port;    
}r_nat_dest;

typedef struct _r_public {
    str aor;                    
    char is_default;            
    struct _r_public *next;     
    struct _r_public *prev;     
} r_public;

enum Reg_States {
    NOT_REGISTERED=0,           
    REGISTERED=1,               
    REG_PENDING=-1,             
    DEREGISTERED=-2             
} ;

typedef struct _r_ipsec {
    int spi_uc;                 
    int spi_us;                 
    int spi_pc;                 
    int spi_ps;                 
    unsigned short port_uc;     
    unsigned short port_us;     
    str ealg;                   
    str r_ealg;                 
    str ck;                     
    str alg;                    
    str r_alg;              
    str ik;                     
} r_ipsec;

typedef struct _r_tls {
    unsigned short port_tls;    
    unsigned long session_hash;
} r_tls;

typedef enum _r_sec_type {
    SEC_NONE    =0,
    SEC_IPSEC   =1,
    SEC_TLS     =2,
} r_security_type;

typedef struct _r_security {
    str sec_header;             
    r_security_type type;       
    union {
        r_ipsec *ipsec;         
        r_tls *tls;             
    } data;
    float q;
} r_security;

typedef struct _r_contact {
    unsigned int hash;          
    str host;                   
    unsigned short port;        
    char transport;             
    r_security *security_temp;  
    r_security *security;       
    str uri;                    
    enum Reg_States reg_state;  
    time_t expires;             
    unsigned short service_route_cnt;
    str *service_route;         
    r_nat_dest * pinhole;       
    r_public *head;             
    r_public *tail;             
    struct _r_contact *next;    
    struct _r_contact *prev;    
} r_contact;

typedef struct {
    r_contact *head;            
    r_contact *tail;            
    gen_lock_t *lock;           
} r_hash_slot;


void r_act_time();
inline int r_valid_contact(r_contact *c);
inline int r_reg_contact(r_contact *c);


int r_storage_init(int hash_size);
void r_storage_destroy();

inline void r_lock(unsigned int hash);
inline void r_unlock(unsigned int hash);

unsigned int get_contact_hash(str aor,int port,int transport,int hash_size);

r_public* new_r_public(str aor, int is_default);
r_public* get_r_public(r_contact *c, str aor);
r_public* add_r_public(r_contact *c,str aor,int is_default);
r_public* update_r_public(r_contact *c,str aor,int *is_default);
void del_r_public(r_contact *c,r_public *p);
void free_r_public(r_public *p);

r_ipsec* new_r_ipsec(int spi_uc,int spi_us,int spi_pc,int spi_ps,int port_uc,int port_us,
    str ealg_setkey,str r_ealg, str ck_esp,str alg_setkey,str r_alg, str ik_esp);
void free_r_ipsec(r_ipsec *ipsec);

r_tls* new_r_tls(int port_tls, unsigned long session_hash);
void free_r_tls(r_tls *tls);

r_security *new_r_security(str sec_header,r_security_type type,float q);
void free_r_security(r_security *s);

r_contact* new_r_contact(str host,int port,int transport,str uri,enum Reg_States reg_state,int expires,
    str *service_route,int service_route_cnt);  
r_contact* get_r_contact(str host,int port,int transport);
r_contact* add_r_contact(str host,int port,int transport,str uri,
    enum Reg_States reg_state,int expires,str *service_route,int service_route_cnt, r_nat_dest * pinhole);
r_contact* update_r_contact(str host,int port,int transport,
    str *uri,enum Reg_States  *reg_state,int *expires,str **service_route,int *service_route_cnt, r_nat_dest ** pinhole);
r_contact* update_r_contact_sec(str host,int port,int transport,
    str *uri,enum Reg_States *reg_state,int *expires,
    r_security *s);
void del_r_contact(r_contact *c);
void free_r_contact(r_contact *c);

r_nat_dest * get_r_nat_pinhole(str host, int port, int transport);



void print_r(int log_level);



#endif //P_CSCF_REGISTRAR_STORAGE_H_

---