Loading ttcn/LibSip_Steps.ttcn +27 −21 Original line number Original line Diff line number Diff line Loading @@ -2991,7 +2991,7 @@ module LibSip_Steps { function f_awaitingREGISTER( function f_awaitingREGISTER( in template(present) REGISTER_Request p_register := ? in template(present) REGISTER_Request p_register := ? ) runs on SipComponent { ) runs on SipComponent { var Request v_request; var REGISTER_Request v_request; tc_wait.start(PX_SIP_TWAIT); tc_wait.start(PX_SIP_TWAIT); alt { alt { Loading @@ -3013,7 +3013,7 @@ module LibSip_Steps { function f_awaitingSUBSCRIBE( function f_awaitingSUBSCRIBE( in template(present) SUBSCRIBE_Request p_subscribe := ? in template(present) SUBSCRIBE_Request p_subscribe := ? ) runs on SipComponent { ) runs on SipComponent { var Request v_request; var SUBSCRIBE_Request v_request; tc_wait.start(PX_SIP_TWAIT); tc_wait.start(PX_SIP_TWAIT); alt { alt { Loading @@ -3038,7 +3038,7 @@ module LibSip_Steps { in template(present) REGISTER_Request p_register := ?, in template(present) REGISTER_Request p_register := ?, in boolean p_reply in boolean p_reply ) runs on SipComponent { ) runs on SipComponent { var Request v_request; var REGISTER_Request v_request; tc_wait.start(PX_SIP_TWAIT); tc_wait.start(PX_SIP_TWAIT); alt { alt { Loading Loading @@ -3315,7 +3315,7 @@ module LibSip_Steps { in template(present) ACK_Request p_ACK := ?, in template(present) ACK_Request p_ACK := ?, in boolean p_setHeaders in boolean p_setHeaders ) runs on SipComponent { ) runs on SipComponent { var Request v_ACK_Request; var ACK_Request v_ACK_Request; tc_ack.start; tc_ack.start; alt { alt { Loading Loading @@ -3728,9 +3728,9 @@ module LibSip_Steps { } } vc_rAck := valueof(m_RAck(vc_response.msgHeader.rSeq.responseNum, vc_cSeq.seqNumber, vc_cSeq.method)); vc_rAck := valueof(m_RAck(vc_response.msgHeader.rSeq.responseNum, vc_cSeq.seqNumber, vc_cSeq.method)); f_setHeadersGeneral(vc_cSeq, "PRACK"); // cseq, contact, branch, via f_setHeadersGeneral(vc_cSeq, "PRACK"); // cseq, contact, branch, via prackReq := m_PRACK_Request_Base(vc_requestUri, vc_callId, vc_cSeq, vc_from, vc_to, vc_via, vc_rAck); prackReq := valueof(m_PRACK_Request_Base(vc_requestUri, vc_callId, vc_cSeq, vc_from, vc_to, vc_via, vc_rAck)); if (isvalue(vc_response.msgHeader.recordRoute)){ if (isvalue(vc_response.msgHeader.recordRoute)){ prackReq.msgHeader.route := f_route(); prackReq.msgHeader.route := valueof(f_route()); } } SIPP.send(prackReq) to vc_sent_label; SIPP.send(prackReq) to vc_sent_label; } } Loading Loading @@ -4167,7 +4167,7 @@ module LibSip_Steps { function f_awaitingSubscription( function f_awaitingSubscription( template(present) SUBSCRIBE_Request p_subscribe := ? template(present) SUBSCRIBE_Request p_subscribe := ? ) runs on SipComponent { ) runs on SipComponent { var Request v_request; var SUBSCRIBE_Request v_request; tc_wait.start(2.0); // awaiting of all SUBSCRIBES tc_wait.start(2.0); // awaiting of all SUBSCRIBES alt { alt { Loading Loading @@ -4711,6 +4711,12 @@ module LibSip_Steps { ) runs on SipComponent { ) runs on SipComponent { var Response v_response; var Response v_response; var Request v_request; var Request v_request; var INFO_Request v_info_request; var NOTIFY_Request v_notify_request; var SUBSCRIBE_Request v_subscribe_request; var BYE_Request v_bye_request; var CANCEL_Request v_cancel_request; var REGISTER_Request v_register_request; var CSeq v_cSeq; var CSeq v_cSeq; [] any timer.timeout { [] any timer.timeout { setverdict(fail); setverdict(fail); Loading Loading @@ -4758,44 +4764,44 @@ module LibSip_Steps { [vc_ignore200OKinv] SIPP.receive(mw_Response_Base(c_statusLine200, vc_callId, ?)) { [vc_ignore200OKinv] SIPP.receive(mw_Response_Base(c_statusLine200, vc_callId, ?)) { repeat; repeat; } } [] SIPP.receive(mw_INFO_Request_Base(vc_callId)) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_INFO_Request_Base(vc_callId)) -> value v_info_request sender vc_sent_label { f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_info_request); f_send200OK(); f_send200OK(); repeat; repeat; } } // awaiting of Notify // awaiting of Notify [] SIPP.receive(mw_NOTIFY_Request_Base(vc_callId)) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_NOTIFY_Request_Base(vc_callId)) -> value v_notify_request sender vc_sent_label { f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_notify_request); f_send200OK(); f_send200OK(); repeat; repeat; } } // awaiting of subscribe from UE // awaiting of subscribe from UE [vc_ignore_subscribe] SIPP.receive(mw_SUBSCRIBE_Request_Base) -> value v_request sender vc_sent_label { [vc_ignore_subscribe] SIPP.receive(mw_SUBSCRIBE_Request_Base) -> value v_subscribe_request sender vc_sent_label { f_setHeadersOnReceiptOfSUBSCRIBE(v_request); f_setHeadersOnReceiptOfSUBSCRIBE(v_subscribe_request); f_send200OK(); f_send200OK(); repeat; repeat; } } // awaiting of subscribe on proxy // awaiting of subscribe on proxy [] SIPP.receive(mw_SUBSCRIBE_Request_Base) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_SUBSCRIBE_Request_Base) -> value v_subscribe_request sender vc_sent_label { f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_subscribe_request); f_sendResponse(m_Response_Contact(c_statusLine200, vc_callId, vc_cSeq, vc_callee_From, vc_callee_To, vc_via, vc_contact)); f_sendResponse(m_Response_Contact(c_statusLine200, vc_callId, vc_cSeq, vc_callee_From, vc_callee_To, vc_via, vc_contact)); // f_setHeadersGeneral(vc_cSeq, "NOTIFY"); // cseq, contact, branch, via // f_setHeadersGeneral(vc_cSeq, "NOTIFY"); // cseq, contact, branch, via // f_SendNOTIFY(m_NOTIFY_Request_contact(vc_requestUri, vc_callId, vc_cSeq, vc_from, vc_to, vc_via, vc_contact)); // f_SendNOTIFY(m_NOTIFY_Request_contact(vc_requestUri, vc_callId, vc_cSeq, vc_from, vc_to, vc_via, vc_contact)); f_SendNOTIFY(m_NOTIFY_Request_contact(v_request.msgHeader.contact.contactBody.contactAddresses[0].addressField.nameAddr.addrSpec, vc_callId, vc_cSeq, vc_callee_From, vc_callee_To, vc_via, vc_contact)); f_SendNOTIFY(m_NOTIFY_Request_contact(v_subscribe_request.msgHeader.contact.contactBody.contactAddresses[0].addressField.nameAddr.addrSpec, vc_callId, vc_cSeq, vc_callee_From, vc_callee_To, vc_via, vc_contact)); f_awaitingOkResponse(vc_cSeq); f_awaitingOkResponse(vc_cSeq); repeat; repeat; } } // unexpected BYE is acknowledged to avoid retransmissions // unexpected BYE is acknowledged to avoid retransmissions [] SIPP.receive(mw_BYE_Request_Base(?)) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_BYE_Request_Base(?)) -> value v_bye_request sender vc_sent_label { setverdict(fail); setverdict(fail); f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_bye_request); f_send200OK(); f_send200OK(); f_RemoveRegistration(vc_cSeq); f_RemoveRegistration(vc_cSeq); } } // unexpected CANCEL is acknowledged to avoid retransmissions // unexpected CANCEL is acknowledged to avoid retransmissions [] SIPP.receive(mw_CANCEL_Request_Base(?)) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_CANCEL_Request_Base(?)) -> value v_cancel_request sender vc_sent_label { setverdict(fail); setverdict(fail); f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_cancel_request); // Answer to the CANCEL // Answer to the CANCEL f_send200OK(); f_send200OK(); f_RemoveRegistration(vc_cSeq); f_RemoveRegistration(vc_cSeq); Loading Loading @@ -4823,7 +4829,7 @@ module LibSip_Steps { f_RemoveRegistration(vc_cSeq); f_RemoveRegistration(vc_cSeq); } } // catch invalid REGISTER // catch invalid REGISTER [] SIPP.receive(mw_REGISTER_Request_Base) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_REGISTER_Request_Base) -> value v_register_request sender vc_sent_label { setverdict(fail); setverdict(fail); f_componentStop(); f_componentStop(); } } Loading Loading
ttcn/LibSip_Steps.ttcn +27 −21 Original line number Original line Diff line number Diff line Loading @@ -2991,7 +2991,7 @@ module LibSip_Steps { function f_awaitingREGISTER( function f_awaitingREGISTER( in template(present) REGISTER_Request p_register := ? in template(present) REGISTER_Request p_register := ? ) runs on SipComponent { ) runs on SipComponent { var Request v_request; var REGISTER_Request v_request; tc_wait.start(PX_SIP_TWAIT); tc_wait.start(PX_SIP_TWAIT); alt { alt { Loading @@ -3013,7 +3013,7 @@ module LibSip_Steps { function f_awaitingSUBSCRIBE( function f_awaitingSUBSCRIBE( in template(present) SUBSCRIBE_Request p_subscribe := ? in template(present) SUBSCRIBE_Request p_subscribe := ? ) runs on SipComponent { ) runs on SipComponent { var Request v_request; var SUBSCRIBE_Request v_request; tc_wait.start(PX_SIP_TWAIT); tc_wait.start(PX_SIP_TWAIT); alt { alt { Loading @@ -3038,7 +3038,7 @@ module LibSip_Steps { in template(present) REGISTER_Request p_register := ?, in template(present) REGISTER_Request p_register := ?, in boolean p_reply in boolean p_reply ) runs on SipComponent { ) runs on SipComponent { var Request v_request; var REGISTER_Request v_request; tc_wait.start(PX_SIP_TWAIT); tc_wait.start(PX_SIP_TWAIT); alt { alt { Loading Loading @@ -3315,7 +3315,7 @@ module LibSip_Steps { in template(present) ACK_Request p_ACK := ?, in template(present) ACK_Request p_ACK := ?, in boolean p_setHeaders in boolean p_setHeaders ) runs on SipComponent { ) runs on SipComponent { var Request v_ACK_Request; var ACK_Request v_ACK_Request; tc_ack.start; tc_ack.start; alt { alt { Loading Loading @@ -3728,9 +3728,9 @@ module LibSip_Steps { } } vc_rAck := valueof(m_RAck(vc_response.msgHeader.rSeq.responseNum, vc_cSeq.seqNumber, vc_cSeq.method)); vc_rAck := valueof(m_RAck(vc_response.msgHeader.rSeq.responseNum, vc_cSeq.seqNumber, vc_cSeq.method)); f_setHeadersGeneral(vc_cSeq, "PRACK"); // cseq, contact, branch, via f_setHeadersGeneral(vc_cSeq, "PRACK"); // cseq, contact, branch, via prackReq := m_PRACK_Request_Base(vc_requestUri, vc_callId, vc_cSeq, vc_from, vc_to, vc_via, vc_rAck); prackReq := valueof(m_PRACK_Request_Base(vc_requestUri, vc_callId, vc_cSeq, vc_from, vc_to, vc_via, vc_rAck)); if (isvalue(vc_response.msgHeader.recordRoute)){ if (isvalue(vc_response.msgHeader.recordRoute)){ prackReq.msgHeader.route := f_route(); prackReq.msgHeader.route := valueof(f_route()); } } SIPP.send(prackReq) to vc_sent_label; SIPP.send(prackReq) to vc_sent_label; } } Loading Loading @@ -4167,7 +4167,7 @@ module LibSip_Steps { function f_awaitingSubscription( function f_awaitingSubscription( template(present) SUBSCRIBE_Request p_subscribe := ? template(present) SUBSCRIBE_Request p_subscribe := ? ) runs on SipComponent { ) runs on SipComponent { var Request v_request; var SUBSCRIBE_Request v_request; tc_wait.start(2.0); // awaiting of all SUBSCRIBES tc_wait.start(2.0); // awaiting of all SUBSCRIBES alt { alt { Loading Loading @@ -4711,6 +4711,12 @@ module LibSip_Steps { ) runs on SipComponent { ) runs on SipComponent { var Response v_response; var Response v_response; var Request v_request; var Request v_request; var INFO_Request v_info_request; var NOTIFY_Request v_notify_request; var SUBSCRIBE_Request v_subscribe_request; var BYE_Request v_bye_request; var CANCEL_Request v_cancel_request; var REGISTER_Request v_register_request; var CSeq v_cSeq; var CSeq v_cSeq; [] any timer.timeout { [] any timer.timeout { setverdict(fail); setverdict(fail); Loading Loading @@ -4758,44 +4764,44 @@ module LibSip_Steps { [vc_ignore200OKinv] SIPP.receive(mw_Response_Base(c_statusLine200, vc_callId, ?)) { [vc_ignore200OKinv] SIPP.receive(mw_Response_Base(c_statusLine200, vc_callId, ?)) { repeat; repeat; } } [] SIPP.receive(mw_INFO_Request_Base(vc_callId)) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_INFO_Request_Base(vc_callId)) -> value v_info_request sender vc_sent_label { f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_info_request); f_send200OK(); f_send200OK(); repeat; repeat; } } // awaiting of Notify // awaiting of Notify [] SIPP.receive(mw_NOTIFY_Request_Base(vc_callId)) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_NOTIFY_Request_Base(vc_callId)) -> value v_notify_request sender vc_sent_label { f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_notify_request); f_send200OK(); f_send200OK(); repeat; repeat; } } // awaiting of subscribe from UE // awaiting of subscribe from UE [vc_ignore_subscribe] SIPP.receive(mw_SUBSCRIBE_Request_Base) -> value v_request sender vc_sent_label { [vc_ignore_subscribe] SIPP.receive(mw_SUBSCRIBE_Request_Base) -> value v_subscribe_request sender vc_sent_label { f_setHeadersOnReceiptOfSUBSCRIBE(v_request); f_setHeadersOnReceiptOfSUBSCRIBE(v_subscribe_request); f_send200OK(); f_send200OK(); repeat; repeat; } } // awaiting of subscribe on proxy // awaiting of subscribe on proxy [] SIPP.receive(mw_SUBSCRIBE_Request_Base) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_SUBSCRIBE_Request_Base) -> value v_subscribe_request sender vc_sent_label { f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_subscribe_request); f_sendResponse(m_Response_Contact(c_statusLine200, vc_callId, vc_cSeq, vc_callee_From, vc_callee_To, vc_via, vc_contact)); f_sendResponse(m_Response_Contact(c_statusLine200, vc_callId, vc_cSeq, vc_callee_From, vc_callee_To, vc_via, vc_contact)); // f_setHeadersGeneral(vc_cSeq, "NOTIFY"); // cseq, contact, branch, via // f_setHeadersGeneral(vc_cSeq, "NOTIFY"); // cseq, contact, branch, via // f_SendNOTIFY(m_NOTIFY_Request_contact(vc_requestUri, vc_callId, vc_cSeq, vc_from, vc_to, vc_via, vc_contact)); // f_SendNOTIFY(m_NOTIFY_Request_contact(vc_requestUri, vc_callId, vc_cSeq, vc_from, vc_to, vc_via, vc_contact)); f_SendNOTIFY(m_NOTIFY_Request_contact(v_request.msgHeader.contact.contactBody.contactAddresses[0].addressField.nameAddr.addrSpec, vc_callId, vc_cSeq, vc_callee_From, vc_callee_To, vc_via, vc_contact)); f_SendNOTIFY(m_NOTIFY_Request_contact(v_subscribe_request.msgHeader.contact.contactBody.contactAddresses[0].addressField.nameAddr.addrSpec, vc_callId, vc_cSeq, vc_callee_From, vc_callee_To, vc_via, vc_contact)); f_awaitingOkResponse(vc_cSeq); f_awaitingOkResponse(vc_cSeq); repeat; repeat; } } // unexpected BYE is acknowledged to avoid retransmissions // unexpected BYE is acknowledged to avoid retransmissions [] SIPP.receive(mw_BYE_Request_Base(?)) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_BYE_Request_Base(?)) -> value v_bye_request sender vc_sent_label { setverdict(fail); setverdict(fail); f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_bye_request); f_send200OK(); f_send200OK(); f_RemoveRegistration(vc_cSeq); f_RemoveRegistration(vc_cSeq); } } // unexpected CANCEL is acknowledged to avoid retransmissions // unexpected CANCEL is acknowledged to avoid retransmissions [] SIPP.receive(mw_CANCEL_Request_Base(?)) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_CANCEL_Request_Base(?)) -> value v_cancel_request sender vc_sent_label { setverdict(fail); setverdict(fail); f_setHeadersOnReceiptOfRequest(v_request); f_setHeadersOnReceiptOfRequest(v_cancel_request); // Answer to the CANCEL // Answer to the CANCEL f_send200OK(); f_send200OK(); f_RemoveRegistration(vc_cSeq); f_RemoveRegistration(vc_cSeq); Loading Loading @@ -4823,7 +4829,7 @@ module LibSip_Steps { f_RemoveRegistration(vc_cSeq); f_RemoveRegistration(vc_cSeq); } } // catch invalid REGISTER // catch invalid REGISTER [] SIPP.receive(mw_REGISTER_Request_Base) -> value v_request sender vc_sent_label { [] SIPP.receive(mw_REGISTER_Request_Base) -> value v_register_request sender vc_sent_label { setverdict(fail); setverdict(fail); f_componentStop(); f_componentStop(); } } Loading