[sr-dev] git:master:a1a1b548: topos_redis: store context field

Daniel-Constantin Mierla miconda at gmail.com
Mon May 3 08:00:55 CEST 2021


Module: kamailio
Branch: master
Commit: a1a1b548e9362b2b478e0551042e86e294249ddc
URL: https://github.com/kamailio/kamailio/commit/a1a1b548e9362b2b478e0551042e86e294249ddc

Author: Daniel-Constantin Mierla <miconda at gmail.com>
Committer: Daniel-Constantin Mierla <miconda at gmail.com>
Date: 2021-05-03T08:00:32+02:00

topos_redis: store context field

---

Modified: src/modules/topos_redis/topos_redis_storage.c

---

Diff:  https://github.com/kamailio/kamailio/commit/a1a1b548e9362b2b478e0551042e86e294249ddc.diff
Patch: https://github.com/kamailio/kamailio/commit/a1a1b548e9362b2b478e0551042e86e294249ddc.patch

---

diff --git a/src/modules/topos_redis/topos_redis_storage.c b/src/modules/topos_redis/topos_redis_storage.c
index c2d43b4c33..0d21cbc2d1 100644
--- a/src/modules/topos_redis/topos_redis_storage.c
+++ b/src/modules/topos_redis/topos_redis_storage.c
@@ -78,6 +78,7 @@ str td_key_a_srcaddr = str_init("a_srcaddr");
 str td_key_b_srcaddr = str_init("b_srcaddr");
 str td_key_s_method = str_init("s_method");
 str td_key_s_cseq = str_init("s_cseq");
+str td_key_x_context = str_init("x_context");
 
 str tt_key_rectime = str_init("rectime");
 str tt_key_a_callid = str_init("a_callid");
@@ -99,6 +100,7 @@ str tt_key_a_tag = str_init("a_tag");
 str tt_key_b_tag = str_init("b_tag");
 str tt_key_s_method = str_init("s_method");
 str tt_key_s_cseq = str_init("s_cseq");
+str tt_key_x_context = str_init("x_context");
 
 #define TPS_REDIS_SET_ARGSV(sval, argc, argv, argvlen) \
 	do { \
@@ -242,6 +244,8 @@ int tps_redis_insert_dialog(tps_data_t *td)
 	TPS_REDIS_SET_ARGS(&td->s_method, argc, &td_key_s_method, argv, argvlen);
 	TPS_REDIS_SET_ARGS(&td->s_cseq, argc, &td_key_s_cseq, argv, argvlen);
 
+	TPS_REDIS_SET_ARGS(&td->x_context, argc, &td_key_x_context, argv, argvlen);
+
 	rrpl = _tps_redis_api.exec_argv(rsrv, argc, (const char **)argv, argvlen);
 	if(rrpl==NULL) {
 		LM_ERR("failed to execute redis command\n");
@@ -502,6 +506,8 @@ int tps_redis_insert_branch(tps_data_t *td)
 	TPS_REDIS_SET_ARGS(&td->a_tag, argc, &tt_key_a_tag, argv, argvlen);
 	TPS_REDIS_SET_ARGS(&td->b_tag, argc, &tt_key_b_tag, argv, argvlen);
 
+	TPS_REDIS_SET_ARGS(&td->x_context, argc, &tt_key_x_context, argv, argvlen);
+
 	rrpl = _tps_redis_api.exec_argv(rsrv, argc, (const char **)argv, argvlen);
 	if(rrpl==NULL) {
 		LM_ERR("failed to execute redis command\n");
@@ -929,6 +935,9 @@ int tps_redis_load_branch(sip_msg_t *msg, tps_data_t *md, tps_data_t *sd,
 		} else if(skey.len==tt_key_b_tag.len
 				&& strncmp(skey.s, tt_key_b_tag.s, skey.len)==0) {
 			TPS_REDIS_DATA_APPEND(sd, &skey, &sval, &sd->b_tag);
+		} else if(skey.len==tt_key_x_context.len
+				&& strncmp(skey.s, tt_key_x_context.s, skey.len)==0) {
+			TPS_REDIS_DATA_APPEND(sd, &skey, &sval, &sd->x_context);
 		} else {
 			LM_WARN("unknown key[%.*s]\n", skey.len, skey.s);
 		}
@@ -1134,6 +1143,9 @@ int tps_redis_load_dialog(sip_msg_t *msg, tps_data_t *md, tps_data_t *sd)
 		} else if(skey.len==td_key_s_cseq.len
 				&& strncmp(skey.s, td_key_s_cseq.s, skey.len)==0) {
 			TPS_REDIS_DATA_APPEND(sd, &skey, &sval, &sd->s_cseq);
+		} else if(skey.len==td_key_x_context.len
+				&& strncmp(skey.s, td_key_x_context.s, skey.len)==0) {
+			TPS_REDIS_DATA_APPEND(sd, &skey, &sval, &sd->x_context);
 		} else {
 			LM_WARN("unknown key[%.*s]\n", skey.len, skey.s);
 		}




More information about the sr-dev mailing list