[kamailio/kamailio] error: No transaction found for CANCEL (Issue #4058) - sr-dev

6 Dec 2024


      I am using the latest version of Kamailio, but I am unsure what the problem is. My configuration does not handle the CANCEL request correctly, and it returns an error.
`#!KAMAILIO
#!define WITH_MYSQL
#!define SHM_MEMORY 64
debug=2
log_stderror=no
log_facility=LOG_LOCAL0
mpath="/usr/lib/x86_64-linux-gnu/kamailio/modules/"
loadmodule "permissions.so"
loadmodule "tm.so"
loadmodule "sl.so"
loadmodule "rr.so"
loadmodule "pv.so"
loadmodule "dispatcher.so"
loadmodule "db_mysql.so"
loadmodule "siputils.so"
loadmodule "textops.so"
loadmodule "maxfwd.so"
loadmodule "xlog.so"
loadmodule "ctl.so"
loadmodule "cfgutils.so"
loadmodule "htable.so"
loadmodule "timer.so"
loadmodule "sqlops.so"
listen=udp::5060
alias=:5060
# Database connection parameters
modparam("sqlops", "sqlcon", "ca=>mysql://kamailio:@/development")
modparam("permissions", "db_url", "mysql://kamailio@/development")
modparam("permissions", "address_table", "address")
modparam("permissions", "peer_tag_avp", "$avp(tag)")
modparam("dispatcher", "db_url", "mysql://kamailio:@/development")
modparam("dispatcher", "ds_hash_size", 2048)
modparam("dispatcher", "table_name", "dispatcher")
modparam("dispatcher", "flags", 0)
modparam("dispatcher", "force_dst", 1)
# Configure hash tables
modparam("htable", "htable", "clientLimits=>size=64;autoexpire=300")
modparam("htable", "htable", "clientCalls=>size=64;autoexpire=60")
modparam("ctl", "binrpc", "unix:/var/run/kamailio/kamailio_ctl")
modparam("cfgutils", "lock_set_size", 14)
# Transaction Module Parameters
modparam("tm", "fr_inv_timer", 180000)
modparam("tm", "fr_timer", 60000)
modparam("tm", "restart_fr_on_each_reply", 1)
modparam("tm", "auto_inv_100", 1)
# Timer for refreshing limits
modparam("timer", "declare_timer", "LIMITS_TIMER=refresh_limits,300,slow,enable")
modparam("timer", "declare_timer", "CLEANUP_TIMER=cleanup_calls,60,slow,enable")
request_route {
    if (is_method("CANCEL")) {
    xlog("L_INFO", "Received CANCEL request for $ci - Method: $rm - R-URI: $ru\n");
if (!t_check_trans()) {
            xlog("L_INFO", "No transaction found with t_check_trans(), trying t_lookup_cancel()\n");
            # Try to find the transaction using branch and Call-ID
            $var(branch) = $(hdr(Via){param.value,branch});
            if (!t_lookup_cancel()) {
                xlog("L_WARN", "No transaction found for CANCEL - $ci with branch $var(branch)\n");
                sl_reply("481", "Call Leg/Transaction Does Not Exist");
                exit;
            }
            xlog("L_INFO", "Found transaction using t_lookup_cancel()\n");
        }
# Extract destination from original request
        if ($ru != "") {
            $du = $ru;
            xlog("L_INFO", "Setting destination from R-URI: $du\n");
        } else {
            xlog("L_WARN", "No R-URI found for CANCEL\n");
        }
# Add debugging
        xlog("L_INFO", "Forwarding CANCEL to $du for call $ci\n");
if (ds_is_from_list()) {
            ds_load_unset();
            xlog("L_INFO", "Unset dispatcher load for destination\n");
        }
# Handle the client ID and call counting
        if (is_present_hf("X-VICIdial-Client-Id")) {
            $var(client_id) = $(hdr(X-VICIdial-Client-Id));
            if ($var(client_id) =~ "^(CID_[0-9]+)-[a-z]$") {
                $var(parent_id) = $(var(client_id){re.subst,/^(CID_[0-9]+)-[a-z]$/\1/});
            } else {
                $var(parent_id) = $var(client_id);
            }
if($var(parent_id) != $null) {
                lock("calls_$var(parent_id)");
                if($sht(clientCalls=>$var(parent_id)) > 0) {
                    $sht(clientCalls=>$var(parent_id)) = $sht(clientCalls=>$var(parent_id)) - 1;
                    xlog("L_INFO", "CANCEL: Decremented call count for $var(parent_id) to $sht(clientCalls=>$var(parent_id))\n");
                }
                unlock("calls_$var(parent_id)");
            }
        }
# Send 200 OK response for the CANCEL
        t_reply("200", "OK");
# Force the relay of CANCEL to the destination
        t_relay();
        exit;
    }
if(is_method("BYE")) {
        if((!allow_source_address("1") && !ds_is_from_list())) {
            xlog("L_WARN", "IP $si:$sp not in address or dispatcher list\n");
            sl_send_reply("403", "IP Not Allowed");
            exit;
        }
        route(RELAY);
        exit;
    }
    if (!allow_source_address("1") ) {
        xlog("L_WARN", "IP $si:$sp not allowed\n");
        sl_send_reply("403", "IP Not Allowed");
        exit;
    }
    if (is_method("ACK")) {
        if (t_check_trans()) {
            t_relay();
        } else {
            route(RELAY);
        }
        exit;
    }
    if (is_method("OPTIONS")) {
        options_reply();
        exit;
    }
if (!mf_process_maxfwd_header("10")) {
        sl_send_reply("483", "Too Many Hops");
        exit;
    }
if (is_method("INVITE")) {
        if (!is_present_hf("X-VICIdial-Client-Id")) {
            xlog("L_WARN", "INVITE received without X-VICIdial-Client-Id header\n");
            sl_send_reply("400", "Bad Request - Missing Client ID");
            exit;
        }
t_check_trans();
        $var(client_id) = $(hdr(X-VICIdial-Client-Id));
if ($var(client_id) =~ "^(CID_[0-9]+)-[a-z]$") {
            $var(parent_id) = $(var(client_id){re.subst,/^(CID_[0-9]+)-[a-z]$/\1/});
        } else {
            $var(parent_id) = $var(client_id);
        }
        $var(limit) = $sht(clientLimits=>$var(parent_id));
        if(!$var(limit)) {
            xlog("L_WARN", "No limit configured for client $var(parent_id)\n");
            sl_send_reply("403", "Client Not Configured");
            exit;
        }
        lock("calls_$var(parent_id)");
        $var(current_calls) = $sht(clientCalls=>$var(parent_id));
        if(!$var(current_calls)) {
            $var(current_calls) = 0;
        }
        if($var(current_calls) >= $var(limit)) {
            unlock("calls_$var(parent_id)");
            xlog("L_WARN", "Call limit exceeded for client $var(parent_id): $var(current_calls)/$var(limit)\n");
            sl_send_reply("429", "Concurrent Call Limit Exceeded");
            exit;
        }
        $sht(clientCalls=>$var(parent_id)) = $var(current_calls) + 1;
        unlock("calls_$var(parent_id)");
        route(GENERATE_SERIAL_NUMBER);
        # xlog("L_INFO", "Processing INVITE - checking load - Serial Number: $avp(serial_number)\n");
        $var(original_contact) = $ct;
        append_hf("X-Original-Contact: $var(original_contact)\r\n");
        append_hf("X-Original-IP: $si\r\n");
        append_hf("X-Original-Port: $sp\r\n");
        append_hf("X-Serial-Number: $avp(serial_number)\r\n");
if (!ds_select_dst("4", "10")) {
            xlog("L_WARN", "All destinations at max load, forwarding to dump server\n");
            $du = "sip::5060";
            record_route();
            route(RELAY);
            exit;
        }
xlog("L_INFO", "Selected destination: $du\n");
        record_route();
        ds_load_update();
        t_on_failure("MANAGE_FAILURE");
        route(RELAY);
        exit;
    }
if (is_method("BYE")) {
        t_check_trans();
        if($sht(clientCalls=>$var(parent_id)) > 0) {
            $sht(clientCalls=>$var(parent_id)) = $sht(clientCalls=>$var(parent_id)) - 1;
        }
        if (ds_is_from_list()) {
            ds_load_unset();
        }
        route(RELAY);
        exit;
    }
route(RELAY);
}
route[GENERATE_SERIAL_NUMBER] {
    $var(seconds) = $Ts;
    $var(microseconds) = $TV(u);
    $var(server_number) = "01";
    $var(seconds_str) = "" + $var(seconds);
    $var(truncated_seconds) = $(var(seconds_str){s.substr,2,0});
    $var(milliseconds_full) = "" + $var(microseconds);
    $var(milliseconds) = $(var(milliseconds_full){s.striptail,3});
    if ($var(milliseconds) < 100) {
        if ($var(milliseconds) < 10) {
            $var(milliseconds_str) = "00" + $var(milliseconds);
        } else {
            $var(milliseconds_str) = "0" + $var(milliseconds);
        }
    } else {
        $var(milliseconds_str) = "" + $var(milliseconds);
    }
    $var(random) = $RANDOM;
    if ($var(random) < 10) {
        $var(random_padded) = "0" + $var(random);
    } else {
        $var(random_str) = "" + $var(random);
        $var(random_padded) = $(var(random_str){s.substr,-2,0});
    }
    $var(serial_number) = $var(truncated_seconds) + $var(milliseconds_str) + $var(server_number) + $var(random_padded);
    $avp(serial_number) = $var(serial_number);
}
route[refresh_limits] {
    sql_query("ca", "SELECT client_id, cps_limit FROM client_limits", "ra");
    $var(rows) = $dbr(ra=>rows);
    $var(i) = 0;
    # xlog("L_INFO", "Refreshing limits for $var(rows) clients\n");
    while($var(i) < $var(rows)) {
        $var(cid) = $dbr(ra=>[$var(i),0]);
        $var(limit) = $dbr(ra=>[$var(i),1]);
        $sht(clientLimits=>$var(cid)) = $var(limit);
        # xlog("L_INFO", "Client $var(cid) limit set to $var(limit) calls/second\n");
        $var(i) = $var(i) + 1;
    }
    sql_result_free("ra");
    # xlog("L_INFO", "Finished loading client limits\n");
}
route[RELAY] {
    if (!t_relay()) {
        sl_reply_error();
    }
}
route[options_reply] {
    sl_send_reply("200", "OK");
}
reply_route {
    if (is_method("INVITE")) {
        if (ds_is_from_list()) {
            if (status=~"2[0-9][0-9]") {
                ds_load_update();
            } else if (status=~"[3-7][0-9][0-9]") {
                ds_load_unset();
            }
        }
    }
if(status=~"487|486|603") {
        if (is_present_hf("X-VICIdial-Client-Id")) {
            $var(client_id) = $(hdr(X-VICIdial-Client-Id));
            if ($var(client_id) =~ "^(CID_[0-9]+)-[a-z]$") {
                $var(parent_id) = $(var(client_id){re.subst,/^(CID_[0-9]+)-[a-z]$/\1/});
            } else {
                $var(parent_id) = $var(client_id);
            }
if($var(parent_id) != $null) {
                lock("calls_$var(parent_id)");
                if($sht(clientCalls=>$var(parent_id)) > 0) {
                    $sht(clientCalls=>$var(parent_id)) = $sht(clientCalls=>$var(parent_id)) - 1;
                    xlog("L_INFO", "Response $rs: Decremented call count for $var(parent_id)\n");
                }
                unlock("calls_$var(parent_id)");
            }
        }
    }
}
failure_route[MANAGE_FAILURE] {
    if (is_method("INVITE")) {
        if (t_check_status("403|408|480|482|483|486|487|488|501|502|503|504|603")) {
            xlog("L_WARN", "Failed response received from $du\n");
            if (!$var(attempt)) {
                $var(attempt) = 1;
            }
            if (ds_is_from_list() && $var(attempt) < 3) {
                $var(attempt) = $var(attempt) + 1;
                if (ds_next_dst()) {
                    xlog("L_INFO", "Trying destination $var(attempt): $du\n");
                    t_relay();
                    exit;
                }
            } else if ($var(attempt) == 3) {
                xlog("L_INFO", "3 destinations failed, routing to dump server\n");
                $du = "sip::5060";
                t_relay();
                exit;
            } else {
                xlog("L_ERR", "Dump server failed, rejecting call\n");
                t_reply("503", "Service Unavailable");
                exit;
            }
        }
    }
}
route[cleanup_calls] {
    sht_iterator_start("cleanup", "clientCalls");
    while(sht_iterator_next("cleanup")) {
        $var(client_id) = $shtitkey(cleanup);
        $var(current_calls) = $shtitval(cleanup);
        xlog("L_INFO", "Client $var(client_id) - Current Calls: $var(current_calls)\n");
    }
    sht_iterator_end("cleanup");
}
event_route[dispatcher:dst-down] {
    if ($du != $null) {
        xlog("L_WARN", "Destination $du went down\n");
    }
}
event_route[dispatcher:dst-up] {
    if ($du != $null) {
        if ($sht(active_calls=>$du) == $null) {
            $sht(active_calls=>$du) = 0;
            xlog("L_INFO", "Initialized counter for recovered destination $du\n");
        }
    }
}
`
-- 
Reply to this email directly or view it on GitHub:
https://github.com/kamailio/kamailio/issues/4058
You are receiving this because you are subscribed to this thread.

Message ID: kamailio/kamailio/issues/4058@github.com