# HG changeset patch # User Mychaela Falconia # Date 1665532722 28800 # Node ID 0ecbc3dc8f93174c7584917a6751d41e3e2b7287 # Parent 529906fddcfa4a39301157f1fcea0bbae0007a2e sip-in: split mgw_resp.c from mgw_ops.c diff -r 529906fddcfa -r 0ecbc3dc8f93 sip-in/Makefile --- a/sip-in/Makefile Tue Oct 11 14:10:29 2022 -0800 +++ b/sip-in/Makefile Tue Oct 11 15:58:42 2022 -0800 @@ -3,8 +3,8 @@ PROG= themwi-sip-in OBJS= bye_in.o bye_out.o call_clear.o call_list.o call_setup.o cancel.o \ disconnect.o invite_dup.o invite_init.o invite_resp.o main.o mgw_ops.o \ - mgw_sock.o mncc_handle.o mncc_sock.o prack.o readconf.o retrans.o \ - shutdown.o sip_ack.o sip_log.o sip_uas.o sip_udp.o + mgw_resp.o mgw_sock.o mncc_handle.o mncc_sock.o prack.o readconf.o \ + retrans.o shutdown.o sip_ack.o sip_log.o sip_uas.o sip_udp.o LIBS= ../libnumdb/libnumdb.a ../libsip/libsip.a ../libutil/libutil.a INSTBIN=/usr/local/bin diff -r 529906fddcfa -r 0ecbc3dc8f93 sip-in/mgw_ops.c --- a/sip-in/mgw_ops.c Tue Oct 11 14:10:29 2022 -0800 +++ b/sip-in/mgw_ops.c Tue Oct 11 15:58:42 2022 -0800 @@ -13,8 +13,6 @@ #include #include #include -#include "../include/gsm48_const.h" -#include "../include/mncc.h" #include "../include/tmgw_ctrl.h" #include "../include/tmgw_const.h" #include "call.h" @@ -171,271 +169,3 @@ call->mgw_xact = TMGW_CTRL_OP_DTMF_STOP; call->mgw_xact_id = req.transact_ref; } - -static void -handle_crcx_fail(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - call->overall_state = OVERALL_STATE_TEARDOWN; - strcpy(call->invite_fail, "503 Gateway resource allocation failure"); - signal_invite_error(call); -} - -static void -crcx_response(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - if (msg->res == TMGW_RESP_OK) { - call->mgw_state = MGW_STATE_ALLOCATED; - call->mgw_ep_id = msg->ep_id; - bcopy(&msg->gsm_addr, &call->gsm_rtp_tmgw, - sizeof(struct sockaddr_storage)); - bcopy(&msg->pstn_addr, &call->pstn_rtp_local, - sizeof(struct sockaddr_in)); - switch (call->overall_state) { - case OVERALL_STATE_CRCX: - proceed_with_call_setup(call); - return; - case OVERALL_STATE_TEARDOWN: - tmgw_send_dlcx(call); - return; - default: - bad_state: - syslog(LOG_CRIT, - "FATAL: invalid overall state 0x%x on CRCX response", - call->overall_state); - exit(1); - } - } else { - switch (call->overall_state) { - case OVERALL_STATE_CRCX: - handle_crcx_fail(call, msg); - return; - case OVERALL_STATE_TEARDOWN: - transition_dead_sip(call); - return; - default: - goto bad_state; - } - } -} - -static void -handle_mdcx_connect_fail(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - call->overall_state = OVERALL_STATE_TEARDOWN; - switch (msg->res) { - case TMGW_RESP_ERR_RSRC: - disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, - GSM48_CC_CAUSE_RESOURCE_UNAVAIL); - strcpy(call->invite_fail, - "503 Gateway resource allocation failure"); - break; - case TMGW_RESP_ERR_NOTSUP: - disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, - GSM48_CC_CAUSE_BEARER_CA_UNAVAIL); - strcpy(call->invite_fail, "502 Gateway internal error"); - break; - default: - disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, - GSM48_CC_CAUSE_PROTO_ERR); - strcpy(call->invite_fail, "502 Gateway internal error"); - } - signal_invite_error(call); -} - -static void -mdcx_connect_response(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - if (msg->res == TMGW_RESP_OK) { - call->mgw_state = MGW_STATE_COMPLETE; - switch (call->overall_state) { - case OVERALL_STATE_ANSWERED: - signal_invite_200(call); - return; - case OVERALL_STATE_TEARDOWN: - tmgw_send_dlcx(call); - return; - default: - bad_state: - syslog(LOG_CRIT, - "FATAL: invalid overall state 0x%x on MDCX response", - call->overall_state); - exit(1); - } - } else { - tmgw_send_dlcx(call); - switch (call->overall_state) { - case OVERALL_STATE_ANSWERED: - handle_mdcx_connect_fail(call, msg); - return; - case OVERALL_STATE_TEARDOWN: - return; - default: - goto bad_state; - } - } -} - -static struct gsm_mncc_cause mgw_hold_retrieve_error = { - .coding = GSM48_CAUSE_CODING_GSM, - .location = GSM48_CAUSE_LOC_PRN_S_LU, - .value = GSM48_CC_CAUSE_NETWORK_OOO, -}; - -static void -mdcx_hold_response(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - if (call->overall_state == OVERALL_STATE_TEARDOWN) { - tmgw_send_dlcx(call); - return; - } - if (msg->res == TMGW_RESP_OK) { - call->mgw_state = MGW_STATE_HELD; - mncc_send_hold_ack(call); - } else { - call->overall_state = OVERALL_STATE_TEARDOWN; - tmgw_send_dlcx(call); - disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, - GSM48_CC_CAUSE_NETWORK_OOO); - disconnect_sip(call, &mgw_hold_retrieve_error); - } -} - -static void -mdcx_retrieve_response(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - if (call->overall_state == OVERALL_STATE_TEARDOWN) { - tmgw_send_dlcx(call); - return; - } - if (msg->res == TMGW_RESP_OK) { - call->mgw_state = MGW_STATE_COMPLETE; - mncc_send_retrieve_ack(call); - } else { - call->overall_state = OVERALL_STATE_TEARDOWN; - tmgw_send_dlcx(call); - disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, - GSM48_CC_CAUSE_NETWORK_OOO); - disconnect_sip(call, &mgw_hold_retrieve_error); - } -} - -static void -mdcx_response(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - switch (call->mgw_state) { - case MGW_STATE_CONNECTING: - mdcx_connect_response(call, msg); - return; - case MGW_STATE_HOLD_OP: - mdcx_hold_response(call, msg); - return; - case MGW_STATE_RETRIEVE_OP: - mdcx_retrieve_response(call, msg); - return; - default: - syslog(LOG_CRIT, - "FATAL: invalid MGW state 0x%x on MDCX response", - call->mgw_state); - exit(1); - } -} - -static void -dlcx_response(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - if (msg->res != TMGW_RESP_OK) { - syslog(LOG_CRIT, "FATAL: TMGW DLCX failed with code 0x%x", - msg->res); - exit(1); - } - call->mgw_state = MGW_STATE_NO_EXIST; - transition_dead_sip(call); -} - -static void -dtmf_start_response(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - if (call->overall_state == OVERALL_STATE_TEARDOWN) { - tmgw_send_dlcx(call); - return; - } - if (msg->res == TMGW_RESP_OK) - mncc_dtmf_start_ok(call); - else - mncc_dtmf_start_err(call); - if (call->dtmf_pending_stop) - tmgw_send_dtmf_stop(call); - else - call->mgw_state = MGW_STATE_COMPLETE; -} - -static void -dtmf_stop_response(call, msg) - struct call *call; - struct tmgw_ctrl_resp *msg; -{ - if (call->overall_state == OVERALL_STATE_TEARDOWN) { - tmgw_send_dlcx(call); - return; - } - mncc_dtmf_stop_ok(call); - call->mgw_state = MGW_STATE_COMPLETE; - call->dtmf_pending_stop = 0; -} - -void -process_tmgw_response(msg) - struct tmgw_ctrl_resp *msg; -{ - struct call *call; - unsigned opc; - - call = find_call_with_mgw_xact(msg->transact_ref); - if (!call) { - syslog(LOG_CRIT, - "FATAL: response from TMGW xact 0x%x does not match any call", - msg->transact_ref); - exit(1); - } - opc = call->mgw_xact; - call->mgw_xact = 0; - switch (opc) { - case TMGW_CTRL_OP_CRCX: - crcx_response(call, msg); - return; - case TMGW_CTRL_OP_MDCX: - mdcx_response(call, msg); - return; - case TMGW_CTRL_OP_DLCX: - dlcx_response(call, msg); - return; - case TMGW_CTRL_OP_DTMF_START: - dtmf_start_response(call, msg); - return; - case TMGW_CTRL_OP_DTMF_STOP: - dtmf_stop_response(call, msg); - return; - default: - syslog(LOG_CRIT, - "FATAL: invalid opcode 0x%x in call->msg_xact", opc); - exit(1); - } -} diff -r 529906fddcfa -r 0ecbc3dc8f93 sip-in/mgw_resp.c --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/sip-in/mgw_resp.c Tue Oct 11 15:58:42 2022 -0800 @@ -0,0 +1,290 @@ +/* + * In this module we implement our handling of all responses + * from themwi-mgw. + */ + +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include +#include "../include/gsm48_const.h" +#include "../include/mncc.h" +#include "../include/tmgw_ctrl.h" +#include "../include/tmgw_const.h" +#include "call.h" + +extern struct call *find_call_with_mgw_xact(); + +static void +handle_crcx_fail(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + call->overall_state = OVERALL_STATE_TEARDOWN; + strcpy(call->invite_fail, "503 Gateway resource allocation failure"); + signal_invite_error(call); +} + +static void +crcx_response(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + if (msg->res == TMGW_RESP_OK) { + call->mgw_state = MGW_STATE_ALLOCATED; + call->mgw_ep_id = msg->ep_id; + bcopy(&msg->gsm_addr, &call->gsm_rtp_tmgw, + sizeof(struct sockaddr_storage)); + bcopy(&msg->pstn_addr, &call->pstn_rtp_local, + sizeof(struct sockaddr_in)); + switch (call->overall_state) { + case OVERALL_STATE_CRCX: + proceed_with_call_setup(call); + return; + case OVERALL_STATE_TEARDOWN: + tmgw_send_dlcx(call); + return; + default: + bad_state: + syslog(LOG_CRIT, + "FATAL: invalid overall state 0x%x on CRCX response", + call->overall_state); + exit(1); + } + } else { + switch (call->overall_state) { + case OVERALL_STATE_CRCX: + handle_crcx_fail(call, msg); + return; + case OVERALL_STATE_TEARDOWN: + transition_dead_sip(call); + return; + default: + goto bad_state; + } + } +} + +static void +handle_mdcx_connect_fail(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + call->overall_state = OVERALL_STATE_TEARDOWN; + switch (msg->res) { + case TMGW_RESP_ERR_RSRC: + disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, + GSM48_CC_CAUSE_RESOURCE_UNAVAIL); + strcpy(call->invite_fail, + "503 Gateway resource allocation failure"); + break; + case TMGW_RESP_ERR_NOTSUP: + disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, + GSM48_CC_CAUSE_BEARER_CA_UNAVAIL); + strcpy(call->invite_fail, "502 Gateway internal error"); + break; + default: + disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, + GSM48_CC_CAUSE_PROTO_ERR); + strcpy(call->invite_fail, "502 Gateway internal error"); + } + signal_invite_error(call); +} + +static void +mdcx_connect_response(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + if (msg->res == TMGW_RESP_OK) { + call->mgw_state = MGW_STATE_COMPLETE; + switch (call->overall_state) { + case OVERALL_STATE_ANSWERED: + signal_invite_200(call); + return; + case OVERALL_STATE_TEARDOWN: + tmgw_send_dlcx(call); + return; + default: + bad_state: + syslog(LOG_CRIT, + "FATAL: invalid overall state 0x%x on MDCX response", + call->overall_state); + exit(1); + } + } else { + tmgw_send_dlcx(call); + switch (call->overall_state) { + case OVERALL_STATE_ANSWERED: + handle_mdcx_connect_fail(call, msg); + return; + case OVERALL_STATE_TEARDOWN: + return; + default: + goto bad_state; + } + } +} + +static struct gsm_mncc_cause mgw_hold_retrieve_error = { + .coding = GSM48_CAUSE_CODING_GSM, + .location = GSM48_CAUSE_LOC_PRN_S_LU, + .value = GSM48_CC_CAUSE_NETWORK_OOO, +}; + +static void +mdcx_hold_response(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + if (call->overall_state == OVERALL_STATE_TEARDOWN) { + tmgw_send_dlcx(call); + return; + } + if (msg->res == TMGW_RESP_OK) { + call->mgw_state = MGW_STATE_HELD; + mncc_send_hold_ack(call); + } else { + call->overall_state = OVERALL_STATE_TEARDOWN; + tmgw_send_dlcx(call); + disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, + GSM48_CC_CAUSE_NETWORK_OOO); + disconnect_sip(call, &mgw_hold_retrieve_error); + } +} + +static void +mdcx_retrieve_response(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + if (call->overall_state == OVERALL_STATE_TEARDOWN) { + tmgw_send_dlcx(call); + return; + } + if (msg->res == TMGW_RESP_OK) { + call->mgw_state = MGW_STATE_COMPLETE; + mncc_send_retrieve_ack(call); + } else { + call->overall_state = OVERALL_STATE_TEARDOWN; + tmgw_send_dlcx(call); + disconnect_mncc(call, GSM48_CAUSE_LOC_PRN_S_LU, + GSM48_CC_CAUSE_NETWORK_OOO); + disconnect_sip(call, &mgw_hold_retrieve_error); + } +} + +static void +mdcx_response(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + switch (call->mgw_state) { + case MGW_STATE_CONNECTING: + mdcx_connect_response(call, msg); + return; + case MGW_STATE_HOLD_OP: + mdcx_hold_response(call, msg); + return; + case MGW_STATE_RETRIEVE_OP: + mdcx_retrieve_response(call, msg); + return; + default: + syslog(LOG_CRIT, + "FATAL: invalid MGW state 0x%x on MDCX response", + call->mgw_state); + exit(1); + } +} + +static void +dlcx_response(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + if (msg->res != TMGW_RESP_OK) { + syslog(LOG_CRIT, "FATAL: TMGW DLCX failed with code 0x%x", + msg->res); + exit(1); + } + call->mgw_state = MGW_STATE_NO_EXIST; + transition_dead_sip(call); +} + +static void +dtmf_start_response(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + if (call->overall_state == OVERALL_STATE_TEARDOWN) { + tmgw_send_dlcx(call); + return; + } + if (msg->res == TMGW_RESP_OK) + mncc_dtmf_start_ok(call); + else + mncc_dtmf_start_err(call); + if (call->dtmf_pending_stop) + tmgw_send_dtmf_stop(call); + else + call->mgw_state = MGW_STATE_COMPLETE; +} + +static void +dtmf_stop_response(call, msg) + struct call *call; + struct tmgw_ctrl_resp *msg; +{ + if (call->overall_state == OVERALL_STATE_TEARDOWN) { + tmgw_send_dlcx(call); + return; + } + mncc_dtmf_stop_ok(call); + call->mgw_state = MGW_STATE_COMPLETE; + call->dtmf_pending_stop = 0; +} + +void +process_tmgw_response(msg) + struct tmgw_ctrl_resp *msg; +{ + struct call *call; + unsigned opc; + + call = find_call_with_mgw_xact(msg->transact_ref); + if (!call) { + syslog(LOG_CRIT, + "FATAL: response from TMGW xact 0x%x does not match any call", + msg->transact_ref); + exit(1); + } + opc = call->mgw_xact; + call->mgw_xact = 0; + switch (opc) { + case TMGW_CTRL_OP_CRCX: + crcx_response(call, msg); + return; + case TMGW_CTRL_OP_MDCX: + mdcx_response(call, msg); + return; + case TMGW_CTRL_OP_DLCX: + dlcx_response(call, msg); + return; + case TMGW_CTRL_OP_DTMF_START: + dtmf_start_response(call, msg); + return; + case TMGW_CTRL_OP_DTMF_STOP: + dtmf_stop_response(call, msg); + return; + default: + syslog(LOG_CRIT, + "FATAL: invalid opcode 0x%x in call->msg_xact", opc); + exit(1); + } +}