dialog: replicate cseq changes on every reqlayed request

razvancrainea · razvancrainea · commit d2c682cbf67d · 2025-06-16T11:03:43.000+03:00
diff --git a/modules/dialog/dlg_handlers.c b/modules/dialog/dlg_handlers.c
@@ -2254,6 +2254,8 @@ void dlg_onroute(struct sip_msg* req, str *route_params, void *param)
 					req->msg_flags |= FL_USE_UAC_CSEQ;
 				}
 
+				if (dialog_repl_cluster)
+					replicate_dialog_cseq_updated(dlg, dst_leg);
 				dlg_unlock( d_table, d_entry );
 
 				LM_DBG("nonACK req [%d],NULL,%d)\n",
@@ -2293,6 +2295,8 @@ void dlg_onroute(struct sip_msg* req, str *route_params, void *param)
 				else {
 					LM_DBG("update_val=[%d]\n", update_val);
 				}
+				if (dialog_repl_cluster)
+					replicate_dialog_cseq_updated(dlg, dst_leg);
 				dlg_unlock( d_table, d_entry );
 
 				if (update_val && update_msg_cseq(req,0,update_val) != 0) {

Original file line number	Diff line number	Diff line change
`@@ -2254,6 +2254,8 @@ void dlg_onroute(struct sip_msg* req, str route_params, void param)`
`2254`	`2254`	`req->msg_flags \|= FL_USE_UAC_CSEQ;`
`2255`	`2255`	`}`
`2256`	`2256`
	`2257`	`+ if (dialog_repl_cluster)`
	`2258`	`+ replicate_dialog_cseq_updated(dlg, dst_leg);`
`2257`	`2259`	`dlg_unlock( d_table, d_entry );`
`2258`	`2260`
`2259`	`2261`	`LM_DBG("nonACK req [%d],NULL,%d)\n",`
`@@ -2293,6 +2295,8 @@ void dlg_onroute(struct sip_msg* req, str route_params, void param)`
`2293`	`2295`	`else {`
`2294`	`2296`	`LM_DBG("update_val=[%d]\n", update_val);`
`2295`	`2297`	`}`
	`2298`	`+ if (dialog_repl_cluster)`
	`2299`	`+ replicate_dialog_cseq_updated(dlg, dst_leg);`
`2296`	`2300`	`dlg_unlock( d_table, d_entry );`
`2297`	`2301`
`2298`	`2302`	`if (update_val && update_msg_cseq(req,0,update_val) != 0) {`