p_persistency.h File Reference

---

Detailed Description

P-CSCF persistency operations.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file p_persistency.h.

#include "bin_pcscf.h"

Go to the source code of this file.

Enumerations
enum	data_type_t {   P_REGISTRAR = 1, P_DIALOGS = 2, P_SUBSCRIPTIONS = 3, S_AUTH = 4,   S_DIALOGS = 5, S_REGISTRAR = 6 }
Functions
int	make_snapshot_dialogs ()
	Creates a snapshots of the dialogs data and then calls the dumping function.
int	load_snapshot_dialogs ()
	Loads the dialogs data from the last snapshot.
void	persistency_timer_dialogs (unsigned int ticks, void *param)
	Timer callback for persistency dumps.
int	make_snapshot_registrar ()
	Creates a snapshots of the registrar and then calls the dumping function.
int	load_snapshot_registrar ()
	Loads the registrar data from the last snapshot.
void	persistency_timer_registrar (unsigned int ticks, void *param)
	Timer callback for persistency dumps.
int	make_snapshot_subscriptions ()
	Creates a snapshots of the subscriptions and then calls the dumping function.
int	load_snapshot_subscriptions ()
	Loads the subscriptions data from the last snapshot.
void	persistency_timer_subscriptions (unsigned int ticks, void *param)
	Timer callback for persistency dumps.

---

Enumeration Type Documentation

enum data_type_t

Enumerator:

P_REGISTRAR
P_DIALOGS
P_SUBSCRIPTIONS
S_AUTH
S_DIALOGS
S_REGISTRAR

Definition at line 62 of file p_persistency.h.

             {
    P_REGISTRAR=1,
    P_DIALOGS=2,
    P_SUBSCRIPTIONS=3
} data_type_t;

---

Function Documentation

int make_snapshot_dialogs

(

)

Creates a snapshots of the dialogs data and then calls the dumping function.

Returns:

1 on success or 0 on failure

Definition at line 104 of file p_persistency.c.

{
    bin_data x;
    p_dialog *d;
    int i;  
    
    /*In WITH_DATABASE_CACHE mode, serialize each hashtable element separately */
    if(pcscf_persistency_mode!=WITH_DATABASE_CACHE){
        if (!bin_alloc(&x,256)) goto error;     
        for(i=0;i<p_dialogs_hash_size;i++){
            d_lock(i);
            d = p_dialogs[i].head;
            while(d){
                if (!bin_encode_p_dialog(&x,d)) goto error;
                d = d->next;
            }
            d_unlock(i);
        }
        //bin_print(&x);
    }
    i = p_dump(&x,pcscf_persistency_location,"pdialogs", P_DIALOGS);
    //i = bin_dump(&x,pcscf_persistency_mode,pcscf_persistency_location,"pdialogs");
    if(pcscf_persistency_mode!=WITH_DATABASE_CACHE){        
        bin_free(&x);
    }
    return i;
error:
    return 0;
}  

int load_snapshot_dialogs

(

)

Loads the dialogs data from the last snapshot.

Returns:

1 on success or 0 on failure

Definition at line 138 of file p_persistency.c.

{
    bin_data x;
    p_dialog *d;
    
    if (!p_load(&x,pcscf_persistency_location,"pdialogs",P_DIALOGS)) goto error;
    //if (!bin_load(&x,pcscf_persistency_mode,pcscf_persistency_location,"pdialogs")) goto error;
    
    if(pcscf_persistency_mode!=WITH_DATABASE_CACHE){
        //bin_print(&x);
        x.max=0;
        LOG(L_INFO,"INFO:"M_NAME":load_snapshot_dlg: max %d len %d\n",x.max,x.len);
        while(x.max<x.len){
            d = bin_decode_p_dialog(&x);
            if (!d) return 0;
            LOG(L_INFO,"INFO:"M_NAME":load_snapshot_dlg: Loaded p_dialog for <%.*s>\n",d->host.len,d->host.s);
            d_lock(d->hash);
            d->prev = p_dialogs[d->hash].tail;
            d->next = 0;
            if (p_dialogs[d->hash].tail) p_dialogs[d->hash].tail->next = d;
            p_dialogs[d->hash].tail = d;
            if (!p_dialogs[d->hash].head) p_dialogs[d->hash].head = d;
            d_unlock(d->hash);
        }
        bin_free(&x);
    }
    return 1;
error:
    return 0;
    
}

void persistency_timer_dialogs	(	unsigned int	ticks,
		void *	param
	)

Timer callback for persistency dumps.

Parameters:

	ticks	- what's the time
	param	- a given parameter to be called with

Definition at line 176 of file p_persistency.c.

{
    make_snapshot_dialogs();
    
    if(dialogs_snapshot_version) (*dialogs_snapshot_version)++;         
}

int make_snapshot_registrar

(

)

Creates a snapshots of the registrar and then calls the dumping function.

Returns:

1 on success or 0 on failure

Definition at line 192 of file p_persistency.c.

{
    bin_data x;
    r_contact *c;
    int i;  
    
    /*In WITH_DATABASE_CACHE mode, serialize each hashtable element separately */
    if(pcscf_persistency_mode!=WITH_DATABASE_CACHE){
        if (!bin_alloc(&x,256)) goto error;     
        for(i=0;i<r_hash_size;i++){
            r_lock(i);
            c = registrar[i].head;
            while(c){
                if (!bin_encode_r_contact(&x,c)) goto error;
                c = c->next;
            }
            r_unlock(i);
        }
        //bin_print(&x);
    }
    i = p_dump(&x,pcscf_persistency_location,"pregistrar", P_REGISTRAR);
    //i = bin_dump(&x,pcscf_persistency_mode,pcscf_persistency_location,"pregistrar");
    if(pcscf_persistency_mode!=WITH_DATABASE_CACHE){        
        bin_free(&x);
    }
    return i;
error:
    return 0;
}  

int load_snapshot_registrar

(

)

Loads the registrar data from the last snapshot.

Returns:

1 on success or 0 on failure

Definition at line 226 of file p_persistency.c.

{
    bin_data x;
    r_contact *c;
    
    if (!p_load(&x,pcscf_persistency_location,"pregistrar",P_REGISTRAR)) goto error;
    //if (!bin_load(&x,pcscf_persistency_mode,pcscf_persistency_location,"pregistrar")) goto error;
    
    if(pcscf_persistency_mode!=WITH_DATABASE_CACHE){
        //bin_print(&x);
        x.max=0;
        LOG(L_INFO,"INFO:"M_NAME":load_snapshot_registrar: max %d len %d\n",x.max,x.len);
        while(x.max<x.len){
            c = bin_decode_r_contact(&x);
            if (!c) return 0;
            LOG(L_INFO,"INFO:"M_NAME":load_snapshot_registrar: Loaded r_contact for <%.*s>\n",c->uri.len,c->uri.s);
            r_lock(c->hash);
            c->prev = registrar[c->hash].tail;
            c->next = 0;
            if (registrar[c->hash].tail) registrar[c->hash].tail->next = c;
            registrar[c->hash].tail = c;
            if (!registrar[c->hash].head) registrar[c->hash].head = c;
            r_unlock(c->hash);
        }
        bin_free(&x);
    }
    return 1;
error:
    return 0;
    
}

void persistency_timer_registrar	(	unsigned int	ticks,
		void *	param
	)

Timer callback for persistency dumps.

Parameters:

	ticks	- what's the time
	param	- a given parameter to be called with

Definition at line 264 of file p_persistency.c.

{
    make_snapshot_registrar();   
    
    if(registrar_snapshot_version) (*registrar_snapshot_version)++; 
}

int make_snapshot_subscriptions

(

)

Creates a snapshots of the subscriptions and then calls the dumping function.

Returns:

1 on success or 0 on failure

Definition at line 282 of file p_persistency.c.

References bin_alloc(), bin_encode_r_subscription(), bin_free(), r_subscription_hash_slot::head, _r_subscription::next, p_dump(), P_SUBSCRIPTIONS, pcscf_persistency_location, pcscf_persistency_mode, subs_lock(), subs_unlock(), subscriptions, subscriptions_hash_size, and WITH_DATABASE_CACHE.

Referenced by mod_destroy(), and persistency_timer_subscriptions().

{
    bin_data x;
    r_subscription *s;
    int i;  
    
    /*In WITH_DATABASE_CACHE mode, serialize each hashtable element separately */
    if(pcscf_persistency_mode!=WITH_DATABASE_CACHE){
        if (!bin_alloc(&x,256)) goto error;     
        for(i=0;i<subscriptions_hash_size;i++){
            subs_lock(i);
            s = subscriptions[i].head;
            while(s){
                if (!bin_encode_r_subscription(&x,s)) goto error;
                s = s->next;
            }
            subs_unlock(i);
        }
        //bin_print(&x);
    }
    i = p_dump(&x,pcscf_persistency_location,"psubscriptions", P_SUBSCRIPTIONS);
    //i = bin_dump(&x,pcscf_persistency_mode,pcscf_persistency_location,"psubscriptions");      
    if(pcscf_persistency_mode!=WITH_DATABASE_CACHE){
        bin_free(&x);
    }
    return i;
error:
    return 0;
}  

int load_snapshot_subscriptions

(

)

Loads the subscriptions data from the last snapshot.

Returns:

1 on success or 0 on failure

Definition at line 316 of file p_persistency.c.

References bin_decode_r_subscription(), bin_free(), _r_subscription::hash, r_subscription_hash_slot::head, _bin_data::len, M_NAME, _bin_data::max, _r_subscription::next, p_load(), P_SUBSCRIPTIONS, pcscf_persistency_location, pcscf_persistency_mode, _r_subscription::prev, _r_subscription::req_uri, subs_lock(), subs_unlock(), subscriptions, r_subscription_hash_slot::tail, and WITH_DATABASE_CACHE.

Referenced by mod_init().

{
    bin_data x;
    r_subscription *s;
    
    if (!p_load(&x,pcscf_persistency_location,"psubscriptions",P_SUBSCRIPTIONS)) goto error;
    //if (!bin_load(&x,pcscf_persistency_mode,pcscf_persistency_location,"psubscriptions")) goto error;
    
    if(pcscf_persistency_mode!=WITH_DATABASE_CACHE){
        //bin_print(&x);
        x.max=0;
        LOG(L_INFO,"INFO:"M_NAME":load_snapshot_subscriptions: max %d len %d\n",x.max,x.len);
        while(x.max<x.len){
            s = bin_decode_r_subscription(&x);
            if (!s) return 0;
            LOG(L_INFO,"INFO:"M_NAME":load_snapshot_subscriptions: Loaded r_subscription for <%.*s>\n",s->req_uri.len,s->req_uri.s);
            subs_lock(s->hash);
            s->prev = subscriptions[s->hash].tail;
            s->next = 0;
            if (subscriptions[s->hash].tail) subscriptions[s->hash].tail->next = s;
            subscriptions[s->hash].tail = s;
            if (!subscriptions[s->hash].head) subscriptions[s->hash].head = s;
            subs_unlock(s->hash);
        }   
        bin_free(&x);
    }
    return 1;
error:
    return 0;
    
}

void persistency_timer_subscriptions	(	unsigned int	ticks,
		void *	param
	)

Timer callback for persistency dumps.

Parameters:

	ticks	- what's the time
	param	- a given parameter to be called with

Definition at line 354 of file p_persistency.c.

References make_snapshot_subscriptions(), and subs_snapshot_version.

Referenced by mod_init().

{
    make_snapshot_subscriptions();   
    
    if(subs_snapshot_version) (*subs_snapshot_version)++;   
}

---