bin_pcscf.c File Reference

---

Detailed Description

Binary codec operations for the S-CSCF.

Author:

Dragos Vingarzan vingarzan -at- fokus dot fraunhofer dot de

Definition in file bin_pcscf.c.

#include "bin_pcscf.h"

Go to the source code of this file.

Functions
static int	str_shm_dup (str *dest, str *src)
int	bin_encode_p_dialog (bin_data *x, p_dialog *d)
	Encode an dialog into a binary form.
p_dialog *	bin_decode_p_dialog (bin_data *x)
	Decode a dialog from a binary data structure.
int	bin_encode_ipsec (bin_data *x, r_ipsec *ipsec)
	Encode an ipsec into a binary form.
int	bin_decode_ipsec (bin_data *x, r_ipsec **ipsec)
	Decode a ipsec from a binary data structure.
int	bin_encode_tls (bin_data *x, r_tls *tls)
	Encode an tls into a binary form.
int	bin_decode_tls (bin_data *x, r_tls **tls)
	Decode a tls from a binary data structure.
int	bin_encode_r_security (bin_data *x, r_security *s)
	Encode an security into a binary form.
int	bin_decode_r_security (bin_data *x, r_security **sec)
	Decode a security from a binary data structure.
int	bin_encode_pinhole (bin_data *x, r_nat_dest *pinhole)
	Encode a pinhole into a binary form.
int	bin_decode_pinhole (bin_data *x, r_nat_dest **pinhole)
	Decode a pinhole from a binary data structure.
int	bin_encode_r_public (bin_data *x, r_public *p)
	Encode a r_public into a binary form.
r_public *	bin_decode_r_public (bin_data *x)
	Decode a r_public from a binary data structure.
int	bin_encode_r_contact (bin_data *x, r_contact *c)
	Encode a r_contact into a binary form.
r_contact *	bin_decode_r_contact (bin_data *x)
	Decode a r_contact from a binary data structure.
int	bin_encode_r_subscription (bin_data *x, r_subscription *s)
	Encode a r_subscription into a binary form.
r_subscription *	bin_decode_r_subscription (bin_data *x)
	Decode a r_subscription from a binary data structure.
Variables
tm_binds	tmb
	Structure with pointers to tm funcs.
int	r_hash_size
	Size of S-CSCF registrar hash table.

---

Function Documentation

static int str_shm_dup	(	str *	dest,
		str *	src
	)			[inline, static]

Definition at line 63 of file bin_pcscf.c.

References M_NAME.

Referenced by bin_decode_auth_userdata(), bin_decode_auth_vector(), bin_decode_filter_criteria(), bin_decode_ims_subscription(), bin_decode_ipsec(), bin_decode_p_dialog(), bin_decode_public_identity(), bin_decode_r_contact(), bin_decode_r_public(), bin_decode_r_security(), bin_decode_r_subscriber(), bin_decode_r_subscription(), bin_decode_s_dialog(), and bin_decode_spt().

{
    dest->s = shm_malloc(src->len);
    if (!dest->s){
        LOG(L_ERR,"ERR:"M_NAME":str_shm_dup: Error allocating %d bytes\n",src->len);
        dest->len=0;
        return 0;
    }
    dest->len = src->len;
    memcpy(dest->s,src->s,src->len);
    return 1;
}

int bin_encode_p_dialog	(	bin_data *	x,
		p_dialog *	d
	)

Encode an dialog into a binary form.

Parameters:

	x	- binary data to append to
	u	- the dialog to encode

Returns:

1 on succcess or 0 on error

Definition at line 84 of file bin_pcscf.c.

References bin_encode_dlg_t(), bin_encode_int(), bin_encode_str(), bin_encode_time_t(), bin_encode_uchar(), bin_encode_ushort(), _p_dialog::call_id, _p_dialog::dialog_c, _p_dialog::dialog_s, _p_dialog::direction, _p_dialog::expires, _p_dialog::first_cseq, _p_dialog::host, if, _p_dialog::is_releasing, _p_dialog::last_cseq, _p_dialog::lr_session_expires, M_NAME, _p_dialog::method, _p_dialog::method_str, _p_dialog::port, _p_dialog::refresher, _p_dialog::routes, _p_dialog::routes_cnt, _p_dialog::state, _p_dialog::transport, and _p_dialog::uac_supp_timer.

Referenced by bin_cache_dump_dialogs_to_table(), and make_snapshot_dialogs().

{
    int i;
    char c;
    
    if (!bin_encode_str(x,&(d->call_id))) goto error;
    
    c = d->direction;
    if (!bin_encode_uchar(x,c)) goto error;
    
    if (!bin_encode_str(x,&(d->host))) goto error;
    if (!bin_encode_ushort(x,d->port)) goto error;
    
    c = d->transport;
    if (!bin_encode_uchar(x,c)) goto error;

    if (!bin_encode_ushort(x,d->routes_cnt)) goto error;
    for(i=0;i<d->routes_cnt;i++)
        if (!bin_encode_str(x,d->routes+i)) goto error;
    
    c = d->method;
    if (!bin_encode_uchar(x,c)) goto error;
    if (!bin_encode_str(x,&(d->method_str))) goto error;
    
    if (!bin_encode_int(x,d->first_cseq)) goto error;   
    if (!bin_encode_int(x,d->last_cseq)) goto error;    

    c = d->state;
    if (!bin_encode_uchar(x,c)) goto error; 

    if (!bin_encode_time_t(x,d->expires)) goto error;       
    if (!bin_encode_time_t(x,d->lr_session_expires)) goto error;
    if (!bin_encode_str(x,&(d->refresher))) goto error;
    if (!bin_encode_uchar(x,d->uac_supp_timer)) goto error;
    
    if (!bin_encode_uchar(x,d->is_releasing)) goto error;
    if (!bin_encode_dlg_t(x,d->dialog_c)) goto error;   
    if (!bin_encode_dlg_t(x,d->dialog_s)) goto error;
    
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_encode_p_dialog: Error while encoding.\n");
    return 0;       
}

p_dialog* bin_decode_p_dialog

(

bin_data *

x

)

Decode a dialog from a binary data structure.

Parameters:

x

- binary data to decode from

Returns:

the p_dialog* where the data has been decoded

Definition at line 134 of file bin_pcscf.c.

References bin_decode_char(), bin_decode_dlg_t(), bin_decode_int(), bin_decode_str(), bin_decode_time_t(), bin_decode_uchar(), bin_decode_ushort(), _p_dialog::call_id, _p_dialog::dialog_c, _p_dialog::dialog_s, _p_dialog::direction, _p_dialog::expires, _p_dialog::first_cseq, get_p_dialog_hash(), _p_dialog::hash, _p_dialog::host, if, _p_dialog::is_releasing, _p_dialog::last_cseq, _p_dialog::lr_session_expires, M_NAME, _bin_data::max, _p_dialog::method, _p_dialog::method_str, _p_dialog::port, _p_dialog::refresher, _p_dialog::routes, _p_dialog::routes_cnt, _p_dialog::state, str_shm_dup(), _p_dialog::transport, and _p_dialog::uac_supp_timer.

Referenced by bin_cache_load_dialogs_from_table(), and load_snapshot_dialogs().

{
    p_dialog *d=0;
    int len,i;
    str s;
    char c;
    unsigned char uc;
    
    len = sizeof(p_dialog);
    d = (p_dialog*) shm_malloc(len);
    if (!d) {
        LOG(L_ERR,"ERR:"M_NAME":bin_decode_p_dialog: Error allocating %d bytes.\n",len);
        goto error;
    }
    memset(d,0,len);

    if (!bin_decode_str(x,&s)||!str_shm_dup(&(d->call_id),&s)) goto error;

    if (!bin_decode_uchar(x,    &uc)) goto error;
    d->direction = uc;

    if (!bin_decode_str(x,&s)||!str_shm_dup(&(d->host),&s)) goto error;
    if (!bin_decode_ushort(x,   &d->port)) goto error;
    
    if (!bin_decode_uchar(x,    &uc)) goto error;
    d->transport = uc;

    if (!bin_decode_ushort(x,   &d->routes_cnt)) goto error;

    len = sizeof(str)*d->routes_cnt;
    d->routes = (str*) shm_malloc(len);
    if (!d) {
        LOG(L_ERR,"ERR:"M_NAME":bin_decode_p_dialog: Error allocating %d bytes.\n",len);
        goto error;
    }
    memset(d->routes,0,len);    
    for(i=0;i<d->routes_cnt;i++)
        if (!bin_decode_str(x,&s)||!str_shm_dup(d->routes+i,&s)) goto error;
    
    if (!bin_decode_char(x, &c)) goto error;
    d->method = c;
    if (!bin_decode_str(x,&s)||!str_shm_dup(&(d->method_str),&s)) goto error;
    
    if (!bin_decode_int(x,  &d->first_cseq)) goto error;
    if (!bin_decode_int(x,  &d->last_cseq)) goto error;

    if (!bin_decode_char(x, &c)) goto error;
    d->state = c;
    
    if (!bin_decode_time_t(x,   &d->expires)) goto error;
    
    if (!bin_decode_time_t(x, &d->lr_session_expires)) goto error;
    if (!bin_decode_str(x,&s)||!str_shm_dup(&(d->refresher),&s)) goto error;
    if (!bin_decode_uchar(x,&d->uac_supp_timer)) goto error;    

    if (!bin_decode_uchar(x, &d->is_releasing)) goto error;
    if (!bin_decode_dlg_t(x,&(d->dialog_c))) goto error;
    if (!bin_decode_dlg_t(x,&(d->dialog_s))) goto error;
    
    d->hash = get_p_dialog_hash(d->call_id);        
    
    return d;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_decode_p_dialog: Error while decoding (at %d (%04x)).\n",x->max,x->max);
    if (d) {
        if (d->call_id.s) shm_free(d->call_id.s);
        if (d->host.s) shm_free(d->host.s);
        if (d->routes_cnt){
            for(i=0;i<d->routes_cnt;i++)
                if (d->routes[i].s) shm_free(d->routes[i].s);
            shm_free(d->routes);
        }
        if (d->method_str.s) shm_free(d->method_str.s);
        if (d->refresher.s) shm_free(d->refresher.s);
        shm_free(d);
    }
    return 0;
}

int bin_encode_ipsec	(	bin_data *	x,
		r_ipsec *	ipsec
	)

Encode an ipsec into a binary form.

Parameters:

	x	- binary data to append to
	ipsec	- the r_ipsec to encode

Returns:

1 on succcess or 0 on error

Definition at line 228 of file bin_pcscf.c.

References _r_ipsec::alg, bin_encode_char(), bin_encode_int(), bin_encode_str(), bin_encode_ushort(), _r_ipsec::ck, _r_ipsec::ealg, _r_ipsec::ik, M_NAME, _r_ipsec::port_uc, _r_ipsec::port_us, _r_ipsec::r_alg, _r_ipsec::r_ealg, _r_ipsec::spi_pc, _r_ipsec::spi_ps, _r_ipsec::spi_uc, and _r_ipsec::spi_us.

Referenced by bin_encode_r_security().

{
    if (!ipsec){
        if (!bin_encode_char(x,0)) goto error;
        return 1;
    }
    
    if (!bin_encode_char(x,1)) goto error;

    if (!bin_encode_int(x,ipsec->spi_uc)) goto error;
    if (!bin_encode_int(x,ipsec->spi_us)) goto error;
    if (!bin_encode_int(x,ipsec->spi_pc)) goto error;
    if (!bin_encode_int(x,ipsec->spi_ps)) goto error;
    if (!bin_encode_ushort(x,ipsec->port_uc)) goto error;
    if (!bin_encode_ushort(x,ipsec->port_us)) goto error;
    
    if (!bin_encode_str(x,&(ipsec->ealg))) goto error;
    if (!bin_encode_str(x,&(ipsec->r_ealg))) goto error;
    if (!bin_encode_str(x,&(ipsec->ck))) goto error;
    if (!bin_encode_str(x,&(ipsec->alg))) goto error;
    if (!bin_encode_str(x,&(ipsec->r_alg))) goto error;
    if (!bin_encode_str(x,&(ipsec->ik))) goto error;
    
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_encode_ipsec: Error while encoding.\n");
    return 0;       
}

int bin_decode_ipsec	(	bin_data *	x,
		r_ipsec **	ipsec
	)

Decode a ipsec from a binary data structure.

Parameters:

	x	- binary data to decode from
	ipsec	- ** to write into

Returns:

1 on success or 0 on failure

Definition at line 263 of file bin_pcscf.c.

References bin_decode_char(), bin_decode_int(), bin_decode_str(), bin_decode_ushort(), M_NAME, _bin_data::max, and str_shm_dup().

Referenced by bin_decode_r_security().

{
    int len;
    str s;
    char c;

    if (!bin_decode_char(x, &c)) goto error;
    
    if (c==0) {
        *ipsec = 0;
        return 1;
    }
    
    len = sizeof(r_ipsec);
    *ipsec = (r_ipsec*) shm_malloc(len);
    if (!*ipsec) {
        LOG(L_ERR,"ERR:"M_NAME":bin_decode_ipsec: Error allocating %d bytes.\n",len);
        goto error;
    }
    memset(*ipsec,0,len);

    if (!bin_decode_int(x,  &(*ipsec)->spi_uc)) goto error;
    if (!bin_decode_int(x,  &(*ipsec)->spi_us)) goto error;
    if (!bin_decode_int(x,  &(*ipsec)->spi_pc)) goto error;
    if (!bin_decode_int(x,  &(*ipsec)->spi_ps)) goto error;
    if (!bin_decode_ushort(x,   &(*ipsec)->port_uc)) goto error;
    if (!bin_decode_ushort(x,   &(*ipsec)->port_us)) goto error;

    if (!bin_decode_str(x,&s)||!str_shm_dup(&((*ipsec)->ealg),&s)) goto error;
    if (!bin_decode_str(x,&s)||!str_shm_dup(&((*ipsec)->r_ealg),&s)) goto error;
    if (!bin_decode_str(x,&s)||!str_shm_dup(&((*ipsec)->ck),&s)) goto error;
    if (!bin_decode_str(x,&s)||!str_shm_dup(&((*ipsec)->alg),&s)) goto error;
    if (!bin_decode_str(x,&s)||!str_shm_dup(&((*ipsec)->r_alg),&s)) goto error;
    if (!bin_decode_str(x,&s)||!str_shm_dup(&((*ipsec)->ik),&s)) goto error;
    
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_decode_ipsec: Error while decoding (at %d (%04x)).\n",x->max,x->max);
    if (*ipsec) {
        if ((*ipsec)->ealg.s) shm_free((*ipsec)->ealg.s);
        if ((*ipsec)->r_ealg.s) shm_free((*ipsec)->r_ealg.s);
        if ((*ipsec)->ck.s) shm_free((*ipsec)->ck.s);
        if ((*ipsec)->alg.s) shm_free((*ipsec)->alg.s);
        if ((*ipsec)->r_alg.s) shm_free((*ipsec)->r_alg.s);
        if ((*ipsec)->ik.s) shm_free((*ipsec)->ik.s);
        shm_free(*ipsec);
        *ipsec = 0;
    }
    return 0;
}

int bin_encode_tls	(	bin_data *	x,
		r_tls *	tls
	)

Encode an tls into a binary form.

Parameters:

	x	- binary data to append to
	tls	- the r_tls to encode

Returns:

1 on succcess or 0 on error

Definition at line 322 of file bin_pcscf.c.

References bin_encode_char(), bin_encode_ushort(), M_NAME, and _r_tls::port_tls.

Referenced by bin_encode_r_security().

{
    if (!tls){
        if (!bin_encode_char(x,0)) goto error;
        return 1;
    }
    
    if (!bin_encode_char(x,1)) goto error;

    if (!bin_encode_ushort(x,tls->port_tls)) goto error;
    
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_encode_tls: Error while encoding.\n");
    return 0;       
}

int bin_decode_tls	(	bin_data *	x,
		r_tls **	tls
	)

Decode a tls from a binary data structure.

Parameters:

	x	- binary data to decode from
	tls	- ** to write into

Returns:

1 on success or 0 on failure

Definition at line 345 of file bin_pcscf.c.

References bin_decode_char(), bin_decode_ushort(), M_NAME, and _bin_data::max.

Referenced by bin_decode_r_security().

{
    int len;
    char c;

    if (!bin_decode_char(x, &c)) goto error;
    
    if (c==0) {
        *tls = 0;
        return 1;
    }
    
    len = sizeof(r_tls);
    *tls = (r_tls*) shm_malloc(len);
    if (!*tls) {
        LOG(L_ERR,"ERR:"M_NAME":bin_decode_tls: Error allocating %d bytes.\n",len);
        goto error;
    }
    memset(*tls,0,len);

    if (!bin_decode_ushort(x,   &(*tls)->port_tls)) goto error; 
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_decode_tls: Error while decoding (at %d (%04x)).\n",x->max,x->max);
    if (*tls) {
        shm_free(*tls);
        *tls = 0;
    }
    return 0;
}

int bin_encode_r_security	(	bin_data *	x,
		r_security *	s
	)

Encode an security into a binary form.

Parameters:

	x	- binary data to append to
	s	- the r_security to encode

Returns:

1 s succcess or 0 on error

Definition at line 385 of file bin_pcscf.c.

References bin_encode_char(), bin_encode_int(), bin_encode_ipsec(), bin_encode_str(), bin_encode_tls(), _r_security::data, _r_security::ipsec, M_NAME, _r_security::q, _r_security::sec_header, SEC_IPSEC, SEC_NONE, SEC_TLS, _r_security::tls, and _r_security::type.

Referenced by bin_encode_r_contact().

{
    if (!s){
        if (!bin_encode_char(x,0)) goto error;
        return 1;
    }
    
    if (!bin_encode_char(x,1)) goto error;

    if (!bin_encode_str(x,&(s->sec_header))) goto error;    
    if (!bin_encode_int(x,s->type)) goto error;
    switch (s->type){       
        case SEC_NONE:
            break;
        case SEC_TLS:
            if (!bin_encode_tls(x,s->data.tls)) goto error;
            break;
        case SEC_IPSEC:
            if (!bin_encode_ipsec(x,s->data.ipsec)) goto error;
            break;      
    }   
    if (!bin_encode_int(x,s->q*1000)) goto error; /* yeah yeah.... */
    
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_encode_r_security: Error while encoding.\n");
    return 0;       
}

int bin_decode_r_security	(	bin_data *	x,
		r_security **	sec
	)

Decode a security from a binary data structure.

Parameters:

	x	- binary data to decode from
	sec	- ** to write into

Returns:

1 on success or 0 on failure

Definition at line 420 of file bin_pcscf.c.

References bin_decode_char(), bin_decode_int(), bin_decode_ipsec(), bin_decode_str(), bin_decode_tls(), free_r_ipsec(), free_r_tls(), M_NAME, _bin_data::max, SEC_IPSEC, SEC_NONE, SEC_TLS, and str_shm_dup().

Referenced by bin_decode_r_contact().

{
    int len;
    str s;
    char c;
    int y;

    if (!bin_decode_char(x, &c)) goto error;
    
    if (c==0) {
        *sec = 0;
        return 1;
    }
    
    len = sizeof(r_security);
    *sec = (r_security*) shm_malloc(len);
    if (!*sec) {
        LOG(L_ERR,"ERR:"M_NAME":bin_decode_r_security: Error allocating %d bytes.\n",len);
        goto error;
    }
    memset(*sec,0,len);

    if (!bin_decode_str(x,&s)||!str_shm_dup(&((*sec)->sec_header),&s)) goto error;
    if (!bin_decode_int(x,&y)) goto error;
    (*sec)->type = y;
    switch ((*sec)->type){
        case SEC_NONE:
            break;      
        case SEC_TLS:
            if (!bin_decode_tls(x,&((*sec)->data.tls))) goto error;     
            break;
        case SEC_IPSEC:
            if (!bin_decode_ipsec(x,&((*sec)->data.ipsec))) goto error;
            break;
    }   
    if (!bin_decode_int(x,  &y)) goto error;
    (*sec)->q = ((float)y)/1000.0;
    
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_decode_r_security: Error while decoding (at %d (%04x)).\n",x->max,x->max);
    if (*sec) {
        if ((*sec)->sec_header.s) shm_free((*sec)->sec_header.s);
        switch ((*sec)->type){
            case SEC_NONE:
                break;      
            case SEC_TLS:
                if ((*sec)->data.tls) free_r_tls((*sec)->data.tls);
                break;
            case SEC_IPSEC:
                if ((*sec)->data.ipsec) free_r_ipsec((*sec)->data.ipsec); 
                break;
        }   
        shm_free(*sec);
        *sec = 0;
    }
    return 0;
}

int bin_encode_pinhole	(	bin_data *	x,
		r_nat_dest *	pinhole
	)

Encode a pinhole into a binary form.

Parameters:

	x	- binary data to append to
	u	- the dialog to encode

Returns:

1 on succcess or 0 on error

Definition at line 485 of file bin_pcscf.c.

References bin_encode_char(), bin_encode_uint(), bin_encode_ushort(), M_NAME, _r_nat_dest::nat_addr, and _r_nat_dest::nat_port.

Referenced by bin_encode_r_contact().

{
    if (!pinhole){
        if (!bin_encode_char(x,0)) goto error;
        return 1;
    }
    
    if (!bin_encode_char(x,1)) goto error;

    if (!bin_encode_uint(x,pinhole->nat_addr.af)) goto error;
    if (!bin_encode_uint(x,pinhole->nat_addr.len)) goto error;
    if (!bin_encode_uint(x,pinhole->nat_addr.u.addr32[0])) goto error;
    if (!bin_encode_uint(x,pinhole->nat_addr.u.addr32[1])) goto error;
    if (!bin_encode_uint(x,pinhole->nat_addr.u.addr32[2])) goto error;
    if (!bin_encode_uint(x,pinhole->nat_addr.u.addr32[3])) goto error;
    
    if (!bin_encode_ushort(x,pinhole->nat_port)) goto error;
    
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_encode_pinhole: Error while encoding.\n");
    return 0;       
}

int bin_decode_pinhole	(	bin_data *	x,
		r_nat_dest **	pinhole
	)

Decode a pinhole from a binary data structure.

Parameters:

	x	- binary data to decode from
	pinhole	- ** to write into

Returns:

1 on success or 0 on failure

Definition at line 515 of file bin_pcscf.c.

References bin_decode_char(), bin_decode_uint(), bin_decode_ushort(), _bin_data::len, M_NAME, and _bin_data::max.

Referenced by bin_decode_r_contact().

{
    int len;
    char c;
    
    if (!bin_decode_char(x, &c)) goto error;
    
    if (c==0) {
        *pinhole = 0;
        return 1;
    }
    
    len = sizeof(r_nat_dest);
    *pinhole = (r_nat_dest*) shm_malloc(len);
    if (!*pinhole) {
        LOG(L_ERR,"ERR:"M_NAME":bin_decode_pinhole: Error allocating %d bytes.\n",len);
        goto error;
    }
    memset(*pinhole,0,len);

    if (!bin_decode_uint(x, &(*pinhole)->nat_addr.af)) goto error;
    if (!bin_decode_uint(x, &(*pinhole)->nat_addr.len)) goto error;
    if (!bin_decode_uint(x, &(*pinhole)->nat_addr.u.addr32[0])) goto error;
    if (!bin_decode_uint(x, &(*pinhole)->nat_addr.u.addr32[1])) goto error;
    if (!bin_decode_uint(x, &(*pinhole)->nat_addr.u.addr32[2])) goto error;
    if (!bin_decode_uint(x, &(*pinhole)->nat_addr.u.addr32[3])) goto error;
    if (!bin_decode_ushort(x, &(*pinhole)->nat_port)) goto error;

    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_decode_pinhole: Error while decoding (at %d (%04x)).\n",x->max,x->max);
    if (*pinhole) {
        shm_free(*pinhole);
        *pinhole = 0;
    }
    return 0;
}

int bin_encode_r_public	(	bin_data *	x,
		r_public *	p
	)

Encode a r_public into a binary form.

Parameters:

	x	- binary data to append to
	p	- the r_public to encode

Returns:

1 on succcess or 0 on error

Definition at line 561 of file bin_pcscf.c.

Referenced by bin_encode_r_contact(), and make_snapshot_registrar().

{
    char c;
    if (!bin_encode_str(x,&(p->aor))) goto error;
    c = p->is_default;
    if (!bin_encode_char(x,c)) goto error;
    
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_encode_r_public: Error while encoding.\n");
    return 0;       
}

r_public* bin_decode_r_public

(

bin_data *

x

)

Decode a r_public from a binary data structure.

Parameters:

x

- binary data to decode from

Returns:

the new *r_public or 0 on error

Definition at line 579 of file bin_pcscf.c.

Referenced by bin_decode_r_contact(), and load_snapshot_registrar().

{
    str s;
    int len;
    char c;
    r_public *p;

    len = sizeof(r_public);
    p = (r_public*) shm_malloc(len);
    if (!p) {
        LOG(L_ERR,"ERR:"M_NAME":bin_decode_r_public: Error allocating %d bytes.\n",len);
        goto error;
    }
    memset(p,0,len);
    
    if (!bin_decode_str(x,&s)||!str_shm_dup(&(p->aor),&s)) goto error;
    if (!bin_decode_char(x, &c)) goto error;
    p->is_default = c;
    
    return p;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_decode_r_public: Error while decoding (at %d (%04x)).\n",x->max,x->max);
    if (p) {
        if (p->aor.s) shm_free(p->aor.s);
        shm_free(p);
    }
    return 0;
}

int bin_encode_r_contact	(	bin_data *	x,
		r_contact *	c
	)

Encode a r_contact into a binary form.

Parameters:

	x	- binary data to append to
	p	- the r_contact to encode

Returns:

1 on succcess or 0 on error

Definition at line 624 of file bin_pcscf.c.

Referenced by bin_cache_dump_registrar_to_table(), bin_encode_r_public(), and make_snapshot_registrar().

{
    int i;
    char k;
    unsigned short us;
    r_public *p=0;
    
    if (!bin_encode_str(x,&(c->host))) goto error;
    if (!bin_encode_ushort(x,c->port)) goto error;
    if (!bin_encode_char(x,c->transport)) goto error;
    
    if (!bin_encode_r_security(x,c->security_temp)) goto error;
    if (!bin_encode_r_security(x,c->security)) goto error;
    
    if (!bin_encode_str(x,&(c->uri))) goto error;
    
    k = c->reg_state;
    if (!bin_encode_char(x,k)) goto error;

    if (!bin_encode_time_t(x,c->expires)) goto error;
    
    if (!bin_encode_ushort(x,c->service_route_cnt)) goto error;
    for(i=0;i<c->service_route_cnt;i++)
        if (!bin_encode_str(x,c->service_route+i)) goto error;
        
    if (!bin_encode_pinhole(x,c->pinhole)) goto error;
    
    us=0;
    for(p=c->head;p;p=p->next)
        us++;
    if (!bin_encode_ushort(x,us)) goto error;
    for(p=c->head;p;p=p->next)
        if (!bin_encode_r_public(x,p)) goto error;  
    
    return 1;
error:
    LOG(L_ERR,"ERR:"M_NAME":bin_encode_r_contact: Error while encoding.\n");
    return 0;       
}

r_contact* bin_decode_r_contact

(

bin_data *

x

)

Decode a r_contact from a binary data structure.

Parameters:

x

- binary data to decode from

Returns:

the r_contact* where the data has been decoded

Definition at line 669 of file bin_pcscf.c.

Referenced by bin_cache_load_registrar_from_table(), bin_decode_r_public(), and load_snapshot_registrar().

{
    r_contact *c=0;
    r_public *p=0,*pn=0;
    int len,i;
    char k;
    unsigned short us;
    str st;
    
    len = sizeof(r_contact);
    c = (r_contact*) shm_malloc(len);
    if (!c) {
        LOG(L_ERR,"ERR:"M_NAME":bin_decode_r_contact: Error allocating %d bytes.\n",len);
        goto error;
    }
    memset(c,0,len);
    
    if (!bin_decode_str(x,&st)||!str_shm_dup(&(c->host),&st)) goto error;
    if (!bin_decode_ushort(x,&c->port)) goto error;
    if (!bin_decode_char(x,&c->transport)) goto error;

    c->hash = get_contact_hash(c->host,c->port,c->transport,r_hash_size);
    
    if (!bin_decode_r_security(x,&(c->security_temp))) goto error;
    if (!bin_decode_r_security(x,&(c->security))) goto error;
    
    if (!bin_decode_str(x,&st)||!str_shm_dup(&(c->uri),&st)) goto error;
    
    if (!bin_decode_char(x,&k)) goto error;
    c->reg_state = k;

    if (!bin_decode_time_t(x,&c->expires)) goto error;
    
    if (!bin_decode_ushort(x,   &c->service_route_cnt)) goto error;

    len = sizeof(str)*c->service_route_cnt;
    c->service_route = (str*) shm_malloc(len);
    if (!c->service_route) {
        LOG(L_ERR,"ERR:"M_NAME":bin_decode_r_contact: Error allocating %d bytes.\n",len);
        goto error;
    }
    memset(c->service_route,0,len); 
    for(i=0;i<c->service_route_cnt;i++)
        if (!bin_decode_str(x,&st)||!str_shm_dup(c->service_route+i,&st)) goto error;
    
    if (!bin_decode_pinhole(x,&(c->pinhole ))) goto error;
        
    if (!