27 Jan
2011
27 Jan
'11
10:04 a.m.
Module: sip-router
Branch: carstenbock/ims
Commit: f98c79f1bb109460a9dfeee0fdd71093c6c3490c
URL:
http://git.sip-router.org/cgi-bin/gitweb.cgi/sip-router/?a=commit;h=f98c79f…
Author: Carsten Bock <carsten(a)bock.info>
Committer: Carsten Bock <carsten(a)bock.info>
Date: Thu Jan 27 09:04:13 2011 +0100
- more fixes to the configuration
---
modules/pcscf/pcscf.cfg | 79 ++++++++++++++++++-----------------------------
1 files changed, 30 insertions(+), 49 deletions(-)
diff --git a/modules/pcscf/pcscf.cfg b/modules/pcscf/pcscf.cfg
index 104e2ac..0427216 100644
--- a/modules/pcscf/pcscf.cfg
+++ b/modules/pcscf/pcscf.cfg
@@ -153,6 +153,7 @@ loadmodule "pv.so"
loadmodule "xlog.so"
loadmodule "textops.so"
loadmodule "path.so"
+loadmodule "siputils.so"
#!ifdef K_TESTING
loadmodule "sst.so"
loadmodule "dialog.so"
@@ -329,12 +330,11 @@ modparam("tls", "config",
"/etc/kamailio/tls.cfg")
# main routing logic
route {
- xlog("L_ERR", "$rm $ru (From $fu to $tu)\n");
+ xlog("L_ERR", "$rm $ru (From $fu / $si)\n");
# Basic checks for Sanity of the request and Request flooding.
route(Sanity_Checks);
- # Add-
# Thus P_check_via_sent_by/P_add_via_received is no longer required.
route(NAT);
@@ -358,13 +358,13 @@ route {
break;
}
- xlog("L_ERR", "$$route_uri = $route_uri\n");
+ xlog("L_ERR", "$$route_uri = $route_uri\n");
if !($route_uri =~
"sip:term@"+HOSTNAME_ESC+"."+NETWORKNAME_ESC+".*") {
# Request Initiated by the UE
#!ifdef K_TESTING
if (is_in_profile("orig")){
#!else
- if (P_is_in_dialog("orig")){
+ if (P_is_in_dialog("orig") || has_totag()){
#!endif
if (!is_method("CANCEL")) route(Orig_Subsequent);
else route(Orig_Standalone);
@@ -373,12 +373,13 @@ route {
#!ifdef K_TESTING
if (is_in_profile("term")){
#!else
- if (P_is_in_dialog("term")){
+ if (P_is_in_dialog("term") || has_totag()){
#!endif
if (!is_method("CANCEL")) route(Term_Subsequent);
else route(Orig_Standalone);
break;
- }
+ }
+ xlog("L_ERR", "No dialog yet\n");
# No dialog yet - ACK not relayed as hop-to-hop
if (is_method("ACK"))
break;
@@ -543,7 +544,7 @@ route[REGISTER_494]
route[add_charging_vector]
{
- $var(charging_vector) =
"icid-value=\""+ICID_VALUE_PREFIX+$(Ts{s.encode.hexa})+$(shv(charging_icid_value_counter){s.encode.hexa})+"\";icid-generated-at="+ICID_VALUE_PREFIX+";orig-ioi=\""+ORIG_IOI+"\"";
+ $var(charging_vector) =
"icid-value=\""+ICID_VALUE_PREFIX+$(Ts{s.encode.hexa})+$(shv(charging_icid_value_counter){s.encode.hexa})+"\";icid-generated-at="+ICID_GENERATOR_ADDR+";orig-ioi=\""+ORIG_IOI+"\"";
append_hf("P-Charging-Vector: $var(charging_vector)\r\n");
# Increase counter by one:
@@ -681,9 +682,8 @@ onreply_route[REGISTER_reply]
else P_AAR("register");
}
#!ifdef WITH_TLS
- if (!P_security_relay())
+ P_security_relay();
#!endif
- P_NAT_relay();
}
failure_route[REGISTER_failure]
@@ -706,7 +706,6 @@ route[NOTIFY]
####### ORIGINATING
route[Orig_Initial]
{
- xlog("L_ERR", "route[Orig_Initial]\n");
if (P_emergency_ruri()){
route(Orig_Initial_Emergency);
break;
@@ -722,7 +721,6 @@ route[Orig_Initial]
};
# add IBCF/THIG route here if required
loose_route();
- xlog("L_ERR", "1) $$du = $du\n");
if (!P_follows_service_routes()){
#Variant 1 - deny access to the network
#send_reply("400","Bad Request - Not following indicated
Service-Routes");
@@ -730,10 +728,8 @@ route[Orig_Initial]
#Variant 2 - enforce routes and let the dialog continue
P_enforce_service_routes();
}
- xlog("L_ERR", "2) $$du = $du\n");
P_record_route("orig");
- xlog("L_ERR", "3) $$du = $du\n");
# Check for "sec-agree" in the Require header:
if ($hdr(Require)) {
@@ -765,14 +761,11 @@ route[Orig_Initial]
send_reply("514","Originating dialog save failure - P-CSCF maximum
dialog count reached!");
exit;
}
- xlog("L_ERR", "10) $$du = $du\n");
- if (is_method("INVITE")){
+ if (isflagset(NAT_FLAG) && is_method("INVITE")){
#P_local_policy(); #check, if sdp is allowed, if not return with allowed sdp
- P_NAT_relay();
route(RTPPROXY);
}
- xlog("L_ERR", "11) $$du = $du\n");
t_on_reply("Orig_Initial_reply");
t_on_failure("Orig_Initial_failure");
@@ -834,7 +827,7 @@ route[Orig_Initial_Emergency]
exit;
}
- if (method=="INVITE"){
+ if (isflagset(NAT_FLAG) && is_method("INVITE")){
route(RTPPROXY);
}
@@ -944,6 +937,7 @@ route[Orig_Subsequent]
log(1,">> Orig_Subsequent\n");
if (P_is_registered()){
if (!P_assert_identity("non-emerg")){
+ xlog("L_ERR", "Not registered!\n");
send_reply("403","Forbidden - You must register first with a
S-CSCF");
break;
};
@@ -954,13 +948,6 @@ route[Orig_Subsequent]
};
}
-# else{
- # let it continue as this probably does not come from an UE
- #send_reply("403","Forbidden - Not Registered! You must register
first with a S-CSCF");
- #break;
-
-# }
-
loose_route();
if (method!="CANCEL" &&
!P_follows_dialog_routes("orig")){
@@ -988,7 +975,6 @@ route[Orig_Subsequent]
}
if (method=="BYE" || method=="CANCEL"){
- #end_media_session();
P_STR("orig");
}
@@ -999,8 +985,9 @@ route[Orig_Subsequent]
# reply routes unused as empty at the moment
t_on_reply("Orig_Subsequensend_reply");
#t_on_failure("Orig_Subsequent_failure");
-
+ xlog("L_ERR", "$rm: Forward to $ru ($du)\n");
if (!t_relay()) {
+ xlog("L_ERR", "Could not forward\n");
send_reply("500","Error forwarding originating subsequent
request");
break;
};
@@ -1010,14 +997,11 @@ onreply_route[Orig_Subsequensend_reply]
{
if (t_check_status("[1-2]..")){
P_update_dialog("orig");
- # P_replace_contact();???
}
if (t_check_status("2..") && P_generates_aar("orig")){
if (!P_AAR("orig")) {
P_release_call_onreply("orig");
- #end_media_session();
-
}
}
@@ -1114,8 +1098,6 @@ failure_route[Orig_Standalone_failure]
route[Term_Initial]
{
- xlog("L_ERR", "Term_Initial\n");
-
P_record_route("term");
route(Check_Session_Expires);
@@ -1124,20 +1106,18 @@ route[Term_Initial]
send_reply("514","Terminating dialog save failure - P-CSCF maximum
dialog count reached!");
exit;
}
- xlog("L_ERR", "Route: $hdr(Route)\n");
loose_route();
- xlog("L_ERR", "1) $$du = $du\n");
+ if (check_route_param("received=.*")) setflag(NAT_FLAG);
+ if (isflagset(NAT_FLAG)) xlog("L_ERR", "Callee is behind NAT!\n");
t_on_reply("Term_Initial_reply");
#t_on_failure("Term_Initial_failure");
- if (method=="INVITE") {
+ if (is_method("INVITE") && isflagset(NAT_FLAG)) {
route(RTPPROXY);
}
- if (!P_security_relay())
- P_NAT_relay();
+ P_security_relay();
- xlog("L_ERR", "2) $$du = $du\n");
t_on_reply("Term_Initial_reply");
t_on_failure("Term_Initial_failure");
if (!t_relay()) {
@@ -1151,14 +1131,16 @@ route[Term_Initial]
onreply_route[Term_Initial_reply]
{
if (t_check_status("(180)|(183)|([2-9]..)")){
- route(RTPPROXY_REPLY);
+ if (isflagset(NAT_FLAG)) {
+ # Fix Contact Header in Reply to INVITE
+ fix_nated_contact();
+ # Use RTP-Proxy, if required:
+ route(RTPPROXY_REPLY);
+ }
if(P_generates_aar("term")){
# check if QoS is ok, orig - originating, term - terminating
if (!P_AAR("term")) {
P_release_call_onreply("term");
- # end_media_session();
- #} else {
- # use_media_proxy();
}
}
}
@@ -1206,6 +1188,8 @@ failure_route[Term_Initial_failure]
route[Term_Subsequent]
{
+ log(1,">> Term_Subsequent\n");
+
route(Check_Session_Expires);
P_update_dialog("term");
@@ -1220,7 +1204,6 @@ route[Term_Subsequent]
if (method=="BYE") {
P_STR("term"); # terminate authorization session
- #end_media_session();
}
# Check for "sec-agree" in the Require header:
@@ -1247,9 +1230,9 @@ route[Term_Subsequent]
t_on_reply("Term_Subsequensend_reply");
#t_on_failure("Term_Subsequent_failure");
- if (!P_security_relay())
- P_NAT_relay();
- xlog("L_ERR", "$$du = $du\n");
+ P_security_relay();
+
+ xlog("L_ERR", "$rm: Forward to $ru ($du)\n");
if (!t_relay()) {
send_reply("500","Error forwarding terminating subsequent
request");
break;
@@ -1298,9 +1281,7 @@ route[Term_Standalone]
t_on_reply("Term_Standalone_reply");
#t_on_failure("Term_Standalone_failure");
- if (!P_security_relay())
- P_NAT_relay();
- xlog("L_ERR", "$$du = $du\n");
+ P_security_relay();
if (!t_relay()) {
send_reply("500","Error forwarding terminating standalone
request");
break;