Module: kamailio Branch: master Commit: f591b7e0b0c71648a9ac62dd9604955d7c2acb75 URL: https://github.com/kamailio/kamailio/commit/f591b7e0b0c71648a9ac62dd9604955… Author: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Committer: Daniel-Constantin Mierla &lt;miconda(a)gmail.com&gt; Date: 2016-03-18T15:19:18+01:00 topos: cseq number and method linked to db --- Modified: modules/topos/tps_storage.c Modified: modules/topos/tps_storage.h --- Diff: https://github.com/kamailio/kamailio/commit/f591b7e0b0c71648a9ac62dd9604955… Patch: https://github.com/kamailio/kamailio/commit/f591b7e0b0c71648a9ac62dd9604955… --- diff --git a/modules/topos/tps_storage.c b/modules/topos/tps_storage.c index d6dbabc..c5a767b 100644 --- a/modules/topos/tps_storage.c +++ b/modules/topos/tps_storage.c @@ -292,6 +292,12 @@ int tps_storage_link_msg(sip_msg_t *msg, tps_data_t *td, int dir) td->b_contact = ((contact_body_t*)msg->contact->parsed)->contacts->uri; } td->x_via = td->x_via2; + if(parse_headers(msg, HDR_CSEQ_F, 0)!=0 || msg->cseq==NULL) { + LM_ERR("cannot parse cseq header\n"); + return -1; /* should it be 0 ?!?! */ + } + td->s_method = get_cseq(msg)->method; + td->s_cseq = get_cseq(msg)->number; return 0; error: @@ -477,8 +483,8 @@ int tps_db_insert_dialog(tps_data_t *td) nr_keys++; db_keys[nr_keys] = &td_col_s_cseq; - db_vals[nr_keys].type = DB1_INT; - db_vals[nr_keys].val.int_val = (int)td->s_cseq; + db_vals[nr_keys].type = DB1_STR; + db_vals[nr_keys].val.str_val = TPS_STRZ(td->s_cseq); nr_keys++; if (_tpsdbf.use_table(_tps_db_handle, &td_table_name) < 0) { @@ -597,8 +603,8 @@ int tps_db_insert_branch(tps_data_t *td) nr_keys++; db_keys[nr_keys] = &tt_col_s_cseq; - db_vals[nr_keys].type = DB1_INT; - db_vals[nr_keys].val.int_val = (int)td->s_cseq; + db_vals[nr_keys].type = DB1_STR; + db_vals[nr_keys].val.str_val = TPS_STRZ(td->s_cseq); nr_keys++; if (_tpsdbf.use_table(_tps_db_handle, &tt_table_name) < 0) { @@ -731,6 +737,8 @@ int tps_storage_load_branch(sip_msg_t *msg, tps_data_t *md, tps_data_t *sd) db_cols[nr_cols++] = &tt_col_x_rr; db_cols[nr_cols++] = &tt_col_x_uri; db_cols[nr_cols++] = &tt_col_x_tag; + db_cols[nr_cols++] = &tt_col_s_method; + db_cols[nr_cols++] = &tt_col_s_cseq; if (_tpsdbf.use_table(_tps_db_handle, &tt_table_name) < 0) { LM_ERR("failed to perform use table\n"); @@ -762,6 +770,8 @@ int tps_storage_load_branch(sip_msg_t *msg, tps_data_t *md, tps_data_t *sd) TPS_DATA_APPEND_DB(sd, db_res, n, &sd->x_rr); n++; TPS_DATA_APPEND_DB(sd, db_res, n, &sd->x_uri); n++; TPS_DATA_APPEND_DB(sd, db_res, n, &sd->x_tag); n++; + TPS_DATA_APPEND_DB(sd, db_res, n, &sd->s_method); n++; + TPS_DATA_APPEND_DB(sd, db_res, n, &sd->s_cseq); n++; if ((db_res!=NULL) && _tpsdbf.free_result(_tps_db_handle, db_res)<0) LM_ERR("failed to free result of query\n"); @@ -820,6 +830,8 @@ int tps_storage_load_dialog(sip_msg_t *msg, tps_data_t *md, tps_data_t *sd) db_cols[nr_cols++] = &td_col_r_uri; db_cols[nr_cols++] = &td_col_a_srcip; db_cols[nr_cols++] = &td_col_b_srcip; + db_cols[nr_cols++] = &td_col_s_method; + db_cols[nr_cols++] = &td_col_s_cseq; if (_tpsdbf.use_table(_tps_db_handle, &td_table_name) < 0) { @@ -860,6 +872,8 @@ int tps_storage_load_dialog(sip_msg_t *msg, tps_data_t *md, tps_data_t *sd) TPS_DATA_APPEND_DB(sd, db_res, n, &sd->r_uri); n++; TPS_DATA_APPEND_DB(sd, db_res, n, &sd->a_srcip); n++; TPS_DATA_APPEND_DB(sd, db_res, n, &sd->b_srcip); n++; + TPS_DATA_APPEND_DB(sd, db_res, n, &sd->s_method); n++; + TPS_DATA_APPEND_DB(sd, db_res, n, &sd->s_cseq); n++; if ((db_res!=NULL) && _tpsdbf.free_result(_tps_db_handle, db_res)<0) LM_ERR("failed to free result of query\n"); diff --git a/modules/topos/tps_storage.h b/modules/topos/tps_storage.h index 0fca469..cd24fd9 100644 --- a/modules/topos/tps_storage.h +++ b/modules/topos/tps_storage.h @@ -62,9 +62,9 @@ typedef struct tps_data { str x_rr; str x_uri; str s_method; + str s_cseq; int32_t iflags; int32_t direction; - int32_t s_cseq; } tps_data_t; int tps_storage_dialog_find(sip_msg_t *msg, tps_data_t *td);