src/mme-app/actionHandlers/s1releaseActionHandlers.cpp

/*
 * Copyright 2019-present Infosys Limited
 *
 * SPDX-License-Identifier: Apache-2.0
 */

/******************************************************************************
 *
 * This file has both generated and manual code.
 *
 * File template used for code generation:
 * <TOP-DIR/scripts/SMCodeGen/templates/stateMachineTmpls/actionHandlers.cpp.tt>
 *
 ******************************************************************************/

#include <typeinfo>
#include "actionHandlers/actionHandlers.h"
#include "controlBlock.h"
#include "msgType.h"
#include "contextManager/subsDataGroupManager.h"
#include "contextManager/dataBlocks.h"
#include "procedureStats.h"
#include "log.h"
#include "secUtils.h"
#include "state.h"
#include <string.h>
#include <sstream>
#include <smTypes.h>

#include <ipcTypes.h>
#include <tipcTypes.h>
#include <msgBuffer.h>
#include <interfaces/mmeIpcInterface.h>
#include <utils/mmeContextManagerUtils.h>

using namespace SM;
using namespace mme;
using namespace cmn::utils;

extern MmeIpcInterface* mmeIpcIf_g;

ActStatus ActionHandlers:: send_rel_ab_req_to_sgw(SM::ControlBlock& cb)
{
	log_msg(LOG_DEBUG, "Inside send_rel_ab_req_to_sgw \n");

	UEContext *ue_ctxt = dynamic_cast<UEContext*>(cb.getPermDataBlock());
	if (ue_ctxt == NULL)
	{
		log_msg(LOG_DEBUG, "send_rel_ab_req_to_sgw: ue ctxt is NULL \n");
		return ActStatus::HALT;
	}
	
	SessionContext* sessionCtxt = ue_ctxt->getSessionContext();
	if (sessionCtxt == NULL)
	{
		log_msg(LOG_DEBUG, " send_rel_ab_req_to_sgw: session ctxt is NULL \n");
		return ActStatus::HALT;
	}

	BearerContext* bearerCtxt = sessionCtxt->getBearerContext();
	if (bearerCtxt == NULL)
	{
		log_msg(LOG_DEBUG, " send_rel_ab_req_to_sgw: bearer ctxt is NULL \n");
		return ActStatus::HALT;
	}

	struct RB_Q_msg rb_msg;
	rb_msg.msg_type = release_bearer_request;
	rb_msg.ue_idx = ue_ctxt->getContextID();
	memset(rb_msg.indication, 0 , S11_RB_INDICATION_FLAG_SIZE);
	rb_msg.bearer_id = bearerCtxt->getBearerId();
	memcpy(&(rb_msg.s11_sgw_c_fteid), &(sessionCtxt->getS11SgwCtrlFteid()),
			sizeof(struct fteid));
	memcpy(&(rb_msg.s1u_enb_fteid), &(bearerCtxt->getS1uEnbUserFteid()),
			sizeof(struct fteid));
			
	cmn::ipc::IpcAddress destAddr;
	destAddr.u32 = TipcServiceInstance::s11AppInstanceNum_c;
	mmeIpcIf_g->dispatchIpcMsg((char *) &rb_msg, sizeof(rb_msg), destAddr);

	ProcedureStats::num_of_rel_access_bearer_req_sent ++;
	
	log_msg(LOG_DEBUG, "Inside send_rel_ab_req_to_sgw \n");

	return ActStatus::PROCEED;
}

ActStatus ActionHandlers:: process_rel_ab_resp_from_sgw(SM::ControlBlock& cb)
{
	log_msg(LOG_DEBUG, "process_rel_ab_resp_from_sgw \n");

	ProcedureStats::num_of_rel_access_bearer_resp_received ++;

	return ActStatus::PROCEED;
}

ActStatus ActionHandlers:: send_s1_rel_cmd_to_ue(SM::ControlBlock& cb)
{
	log_msg(LOG_DEBUG, "Inside send_s1_rel_cmd_to_ue\n");

	UEContext *ue_ctxt = dynamic_cast<UEContext*>(cb.getPermDataBlock());
	if(ue_ctxt == NULL)
	{
		log_msg(LOG_DEBUG, "send_s1_rel_cmd_to_ue: ue context is NULL \n");

		return ActStatus::HALT;
	}
	
	struct s1relcmd_info s1relcmd;
	s1relcmd.msg_type = s1_release_command;
	s1relcmd.ue_idx = ue_ctxt->getContextID();
	s1relcmd.enb_fd = ue_ctxt->getEnbFd();
	s1relcmd.enb_s1ap_ue_id = ue_ctxt->getS1apEnbUeId();
	s1relcmd.cause.present = s1apCause_PR_radioNetwork;
    	s1relcmd.cause.choice.radioNetwork = s1apCauseRadioNetwork_user_inactivity;

	/*Send message to S1AP-APP*/
	cmn::ipc::IpcAddress destAddr;
	destAddr.u32 = TipcServiceInstance::s1apAppInstanceNum_c;
	mmeIpcIf_g->dispatchIpcMsg((char *) &s1relcmd, sizeof(s1relcmd), destAddr);
	
	ProcedureStats::num_of_s1_rel_cmd_sent ++;
	
	log_msg(LOG_DEBUG,"Leaving send_s1_rel_cmd_to_ue \n");

	return ActStatus::PROCEED;
}

ActStatus ActionHandlers:: process_ue_ctxt_rel_comp(SM::ControlBlock& cb)
{
	log_msg(LOG_DEBUG, "Inside handle_ctxt_rel_comp \n");

	UEContext *ue_ctxt = dynamic_cast<UEContext*>(cb.getPermDataBlock());
	if (ue_ctxt == NULL)
	{
		log_msg(LOG_DEBUG, "process_ue_ctxt_rel_comp: ue context is NULL\n");

		return ActStatus::HALT;
	}

	MmeContextManagerUtils::deallocateProcedureCtxt(cb, s1Release_c);

	ProcedureStats::num_of_s1_rel_comp_received++;

    	log_msg(LOG_DEBUG, "Leaving process_ue_ctxt_rel_comp \n");

    	return ActStatus::PROCEED;
}