Module: kamailio Branch: master Commit: 5b2b06ceff61144c5f0cbddacdfcaee18a2e8eff URL: https://github.com/kamailio/kamailio/commit/5b2b06ceff61144c5f0cbddacdfcaee1...
Author: Daniel-Constantin Mierla miconda@gmail.com Committer: Daniel-Constantin Mierla miconda@gmail.com Date: 2018-01-15T16:34:46+01:00
topos: store and load tags in transaction record
---
Modified: src/modules/topos/tps_storage.c
---
Diff: https://github.com/kamailio/kamailio/commit/5b2b06ceff61144c5f0cbddacdfcaee1... Patch: https://github.com/kamailio/kamailio/commit/5b2b06ceff61144c5f0cbddacdfcaee1...
---
diff --git a/src/modules/topos/tps_storage.c b/src/modules/topos/tps_storage.c index 6502f491f3..27231bec38 100644 --- a/src/modules/topos/tps_storage.c +++ b/src/modules/topos/tps_storage.c @@ -748,6 +748,16 @@ int tps_db_insert_branch(tps_data_t *td) db_vals[nr_keys].val.str_val = TPS_STRZ(td->bs_contact); nr_keys++;
+ db_keys[nr_keys] = &tt_col_a_tag; + db_vals[nr_keys].type = DB1_STR; + db_vals[nr_keys].val.str_val = TPS_STRZ(td->a_tag); + nr_keys++; + + db_keys[nr_keys] = &tt_col_b_tag; + db_vals[nr_keys].type = DB1_STR; + db_vals[nr_keys].val.str_val = TPS_STRZ(td->b_tag); + nr_keys++; + if (_tpsdbf.use_table(_tps_db_handle, &tt_table_name) < 0) { LM_ERR("failed to perform use table\n"); return -1; @@ -920,6 +930,8 @@ int tps_db_load_branch(sip_msg_t *msg, tps_data_t *md, tps_data_t *sd, db_cols[nr_cols++] = &tt_col_b_contact; db_cols[nr_cols++] = &tt_col_as_contact; db_cols[nr_cols++] = &tt_col_bs_contact; + db_cols[nr_cols++] = &tt_col_a_tag; + db_cols[nr_cols++] = &tt_col_b_tag;
if (_tpsdbf.use_table(_tps_db_handle, &tt_table_name) < 0) { LM_ERR("failed to perform use table\n"); @@ -966,6 +978,8 @@ int tps_db_load_branch(sip_msg_t *msg, tps_data_t *md, tps_data_t *sd, TPS_DATA_APPEND_DB(sd, db_res, n, &sd->b_contact); n++; TPS_DATA_APPEND_DB(sd, db_res, n, &sd->as_contact); n++; TPS_DATA_APPEND_DB(sd, db_res, n, &sd->bs_contact); n++; + TPS_DATA_APPEND_DB(sd, db_res, n, &sd->a_tag); n++; + TPS_DATA_APPEND_DB(sd, db_res, n, &sd->b_tag); n++;
done: if ((db_res!=NULL) && _tpsdbf.free_result(_tps_db_handle, db_res)<0)