?? cbse_set_drx.c
字號:
#include "..\sys\Include.h"
/* Set_DRX 初始化 */
int Process_Set_DRX_init(SET_DRX_t *s_SetDRX);
/* 返回確認給CBC_Proxy */
int Process_SetDRX_Return(PID_t s_Pid,unsigned char cNumberOfReturnMessage);
/* 發送消息給BSC */
int Process_Send_SETDRX_To_BSC(PID_t s_Pid, DIVIDE_CELLLIST_BUF_t *s_DivideCellListBuf);
/* 處理設置不連續接收參數 */
int Process_SET_DRX(unsigned char *MessageBuf,PID_t s_Pid)
{
int iReturnValue;
SET_DRX_t *LPm_SetDRX;
SETDRX_PROCESS_DATA_STRUCT *LPs_SetDrxProcessDataStruct;
/* 拆分小區緩沖區 */
DIVIDE_CELLLIST_BUF_t s_DivideCellListBuf;
CELLID_t s_CellId;
memset(&s_DivideCellListBuf,0,sizeof(DIVIDE_CELLLIST_BUF_t));
memset(&ProcessData[s_Pid.iProcessId][0],0,LPCB_DATA_SIZE);
LPs_SetDrxProcessDataStruct=(SETDRX_PROCESS_DATA_STRUCT *)&ProcessData[s_Pid.iProcessId][0];
/* 數據拷貝到進程數據區 */
memcpy(&LPs_SetDrxProcessDataStruct->s_CBCMessage,MessageBuf,sizeof(CBEMESSAGE_t));
/* 去掉MessageHead */
LPm_SetDRX=(SET_DRX_t *)&LPs_SetDrxProcessDataStruct->s_CBCMessage.cMessage[0];
#ifdef DEBUG_PRINT
Print_SETDRX(s_Pid,LPm_SetDRX);
#endif
/* 判斷參數 */
iReturnValue=Process_Set_DRX_init(LPm_SetDRX);
if (iReturnValue<0)
{
return iReturnValue;
}
/* 構造響應結果 */
iReturnValue=Process_Divide_CellList_AccordingToResponse(&LPm_SetDRX->p_CellList,
0,&LPs_SetDrxProcessDataStruct->s_ResponseCellList,&s_CellId);
if (iReturnValue<0)
{
return iReturnValue;
}
/* 從響應列表得到拆分列表 */
Process_Get_DividedCellList_from_ResponseCellList(&LPs_SetDrxProcessDataStruct->s_ResponseCellList,&s_DivideCellListBuf);
/* 標志是否等待響應 */
IfNeedResponse(&LPs_SetDrxProcessDataStruct->s_ResponseCellList,&s_DivideCellListBuf);
/* 此時用s_DivideCellListBuf.s_CellListOfBSC,
不用s_ResponseCellList.cNumberOfBSC
前者可能小于后者 */
LPs_SetDrxProcessDataStruct->cNoOfResponseReq=s_DivideCellListBuf.cNumberOfCellList;
/* 小區全失敗 */
if (LPs_SetDrxProcessDataStruct->cNoOfResponseReq==0)
{
return ALL_CELLS_NOT_AVAILABLE;
}
/* 記錄定時器的ID置為-1 */
LPs_SetDrxProcessDataStruct->iTimerId=-1;
Process_SetDRX_Return(s_Pid,s_DivideCellListBuf.cNumberOfCellList);
/* 發送消息給BSC */
Process_Send_SETDRX_To_BSC(s_Pid, &s_DivideCellListBuf);
/* 創建回復定時器 */
iReturnValue=create_timer(SET_DRX_RETURN_DELAY_TIME,
SET_DRX_REPORT_RETURN,(char *)&s_Pid,NULL);
/* 創建定時器失敗 */
//sys
if (iReturnValue<0)
{
printf("Create timer Error!\n");
return iReturnValue;
}
else
{
LPs_SetDrxProcessDataStruct->iTimerId=iReturnValue;
return CONTINUANCE;
}
return END;
}
/* Set_DRX 初始化 */
int Process_Set_DRX_init(SET_DRX_t *s_SetDRX)
{
//檢查必備參數
if (s_SetDRX->p_CellList.bFlag!=EXIST)
{
return NO_CELLLIST;
}
if ((s_SetDRX->p_SchedulePeriod.bFlag!=EXIST)&&(s_SetDRX->p_ReservedSlots.bFlag!=EXIST))
{
return LACK_PARA;
}
//檢查參數內容
//檢查小區識別器CellIdDisc
if ((s_SetDRX->p_CellList.cCellIdDisc!=1)&&
(s_SetDRX->p_CellList.cCellIdDisc!=2)&&
(s_SetDRX->p_CellList.cCellIdDisc!=5)&&
(s_SetDRX->p_CellList.cCellIdDisc!=6))
{
return CELLIDDISC_OUTOFRANG;
}
//對于必備參數不用判斷其存在
//檢查小區數目
if ((s_SetDRX->p_CellList.iLength<=0)||(s_SetDRX->p_CellList.iLength>MAXCELLCOUNT))
{
return NUMBEROFCELL_ERROR;
}
//檢查信道指示
if (s_SetDRX->p_ChannelIndicator.bFlag==EXIST)
{
if(s_SetDRX->p_ChannelIndicator.cChannelIndicator>1)
{
return NUMBEROFCELL_ERROR;
}
}
return SUCCESS;
}
/* 返回確認給CBC_Proxy */
int Process_SetDRX_Return(PID_t s_Pid,unsigned char cNumberOfReturnMessage)
{
CBEMESSAGE_t s_CBEMessage;
CBEMESSAGE_t *LPCBEMessage;
MESSAGE_CONFIRM_i s_MessageConfirm;
MESSAGE_HEAD_t *LPMessageHead;
memset(&s_MessageConfirm,0,sizeof(MESSAGE_CONFIRM_i));
memset(&s_CBEMessage,0,sizeof(CBEMESSAGE_t));
LPMessageHead=(MESSAGE_HEAD_t *)&ProcessData[s_Pid.iProcessId][sizeof(short)];
LPCBEMessage=(CBEMESSAGE_t *)&ProcessData[s_Pid.iProcessId][0];
s_MessageConfirm.s_MessageHead.iMessageAreaId=A;
s_MessageConfirm.s_MessageHead.iMessageType=LPMessageHead->iMessageType;
memcpy(&s_MessageConfirm.s_MessageHead.s_ReceiverPid,&LPMessageHead->s_SenderPid,sizeof(PID_t));
memcpy(&s_MessageConfirm.s_MessageHead.s_SenderPid,&s_Pid,sizeof(PID_t));
s_MessageConfirm.s_MessageHead.iMessageLength=sizeof(int);
s_MessageConfirm.NumberOfReturnMessage=cNumberOfReturnMessage;
s_CBEMessage.iLen=s_MessageConfirm.s_MessageHead.iMessageLength+sizeof(MESSAGE_HEAD_t);
memcpy(&s_CBEMessage.s_MessageHead,&s_MessageConfirm.s_MessageHead,sizeof(MESSAGE_HEAD_t));
memcpy(&s_CBEMessage.cMessage[0],&s_MessageConfirm.NumberOfReturnMessage,s_MessageConfirm.s_MessageHead.iMessageLength);
AppendCBESendMessage(&s_CBEMessage);
return SUCCESS;
}
/* 發送消息給BSC */
int Process_Send_SETDRX_To_BSC(PID_t s_Pid, DIVIDE_CELLLIST_BUF_t *s_DivideCellListBuf)
{
int len;
char *BSCID;
SET_DRX_t s_SetDRX;
BSCMESSAGE_t s_BSCMessage;
int i;
int Tid;
// CBEMESSAGE_t *LPCBEMessage;
// SET_DRX_REPORT_t s_SetDRXReport;
// CBEMESSAGE_t s_CBEMessage;
// CBEMESSAGE_t CBCProxyMessage;
memcpy(&s_SetDRX,&ProcessData[s_Pid.iProcessId][(sizeof(short)+sizeof(MESSAGE_HEAD_t))],sizeof(SET_DRX_t));
// LPCBEMessage=(CBEMESSAGE_t *)&ProcessData[s_Pid.iProcessId][0];
for(i=0;i<s_DivideCellListBuf->cNumberOfCellList;i++)
{
memset(&s_BSCMessage,0,sizeof(BSCMESSAGE_t));
memcpy(&s_SetDRX.p_CellList,&s_DivideCellListBuf->s_CellListOfBSC->s_CellList,sizeof(CELLLIST_t));
len=Pack_SET_DRX(&s_SetDRX,&s_BSCMessage.cMessage[0]);
if (len>0)
{
s_BSCMessage.iLen=len;
BSCID=&s_DivideCellListBuf->s_CellListOfBSC->BSCIdentifier[0];
Tid=GetTid(BSCID);
if (Tid!=FAILURE)
{
memcpy(&s_BSCMessage.s_Pid,&s_Pid,sizeof(PID_t));
/* 發送給BSC */
X25AppendCBESendMessage(&s_BSCMessage, Tid);
}
}
}
/*
if (s_DivideCellListBuf->s_FailureList.bFlag==EXIST)
{
//報告失敗列表給Cbc_proxy
memset(&s_SetDRXReport,0,sizeof(SET_DRX_REPORT_t));
memset(&s_CBEMessage,0,sizeof(CBEMESSAGE_t));
memcpy(&s_SetDRXReport.p_FailureList,&s_DivideCellListBuf->s_FailureList,sizeof(FAILURELIST_t));
if (s_SetDRX.p_ChannelIndicator.bFlag==EXIST)
{
memcpy(&s_SetDRXReport.p_ChannelIndicator,&s_SetDRX.p_ChannelIndicator,sizeof(CHANNELINDICATOR_t));
}
s_CBEMessage.s_MessageHead.iMessageAreaId=A;
//SET_DRX_REPORT 13
s_CBEMessage.s_MessageHead.iMessageType=13;
s_CBEMessage.s_MessageHead.s_SenderPid.cFunctionId=FUNCTIONID;
s_CBEMessage.s_MessageHead.s_SenderPid.cModuleId=MODULEID;
s_CBEMessage.s_MessageHead.iMessageLength=sizeof(SET_DRX_REPORT_t);
s_CBEMessage.iLen=sizeof(MESSAGE_HEAD_t)+s_CBEMessage.s_MessageHead.iMessageLength;
memcpy(&s_CBEMessage.cMessage[0],(char *)&s_SetDRXReport,s_CBEMessage.s_MessageHead.iMessageLength);
// s_CBEMessage.SocketHandle=LPCBEMessage->SocketHandle;
memset(&CBCProxyMessage,0,sizeof(CBEMESSAGE_t));
//壓縮列表參數
Convert_SETDRX_Report(&s_CBEMessage,&CBCProxyMessage);
AppendCBESendMessage(&CBCProxyMessage);
}
*/
return SUCCESS;
}
//將列表轉為標準格式,用于SetDRX
//in: s_CBEMessage Cbcproxy發送來的原始信息
//out: s_ProxyMessage
//返回:
// 1: 成功,
// -1:失敗
int Convert_SETDRX(CBEMESSAGE_t *s_CBEMessage,CBEMESSAGE_t *s_ProxyMessage)
{
int posi;
unsigned short iListLen;
SET_DRX_t *LPm_SetDRX;
LPm_SetDRX=(SET_DRX_t *)&s_ProxyMessage->cMessage[0];
memcpy(&s_ProxyMessage->s_MessageHead,&s_CBEMessage->s_MessageHead,sizeof(MESSAGE_HEAD_t));
memcpy(&s_ProxyMessage->cMessage[0],&s_CBEMessage->cMessage[0],
(sizeof(SET_DRX_i)-sizeof(MESSAGE_HEAD_t)));
posi=sizeof(SET_DRX_i)-sizeof(MESSAGE_HEAD_t);
/* 得到CELLLIST的長度 */
memcpy(&iListLen,&s_CBEMessage->cMessage[posi],sizeof(unsigned short));
/* 長度溢出,返回錯誤 */
if (iListLen>sizeof(CELLLIST_t))
{
return FAILURE;
}
/* 沒有該參數,返回成功 */
if (iListLen==0)
{
return SUCCESS;
}
posi=posi+sizeof(unsigned short);
/* 復制小區列表 */
memcpy(&LPm_SetDRX->p_CellList, &s_CBEMessage->cMessage[posi],iListLen);
s_ProxyMessage->iLen=sizeof(KILLMESSAGE_t)+sizeof(MESSAGE_HEAD_t);
return SUCCESS;
}
/*
處理SET_DRX回復定時器到時
返回響應列表
*/
void Process_SET_DRX_Response_timer_Expired(PID_t s_Pid)
{
int iPosi;
char ResponseBuf[3096];
SETDRX_PROCESS_DATA_STRUCT *LPs_SetDrxProcessDataStruct;
SET_DRX_t *LPm_SetDRX;
SET_DRX_RESP_i *LPs_SetDrxResp;
int i,j;
unsigned short iLen;
memset(&ResponseBuf[0],0,3096);
LPs_SetDrxProcessDataStruct=(SETDRX_PROCESS_DATA_STRUCT *)&ProcessData[s_Pid.iProcessId][0];
LPm_SetDRX=(SET_DRX_t *)&LPs_SetDrxProcessDataStruct->s_CBCMessage.cMessage[0];
LPs_SetDrxResp=(SET_DRX_RESP_i *)&ResponseBuf[sizeof(short)];
/* */
memcpy(&LPs_SetDrxResp->s_MessageHead.s_ReceiverPid,
&LPs_SetDrxProcessDataStruct->s_CBCMessage.s_MessageHead.s_SenderPid,sizeof(PID_t));
/* */
memcpy(&LPs_SetDrxResp->s_MessageHead.s_SenderPid,&s_Pid,sizeof(PID_t));
LPs_SetDrxResp->s_MessageHead.iMessageAreaId=A;
LPs_SetDrxResp->s_MessageHead.iMessageType=CBCPROXY_SET_DRX_REPORT;
/* ChannelIndicator */
memcpy(&LPs_SetDrxResp->p_ChannelIndicator,&LPm_SetDRX->p_ChannelIndicator,sizeof(CHANNELINDICATOR_t));
iPosi=sizeof(SET_DRX_RESP_i)+sizeof(short);
LPs_SetDrxResp->bReportListFlag=EXIST;
LPs_SetDrxResp->cReportListNumberOfBSC=LPs_SetDrxProcessDataStruct->s_ResponseCellList.cNumberOfBSC;
/* 沒響應置為全失敗 */
for(i=0;i<LPs_SetDrxProcessDataStruct->s_ResponseCellList.cNumberOfBSC;i++)
{
/* 如果沒響應置為全失敗 */
if(LPs_SetDrxProcessDataStruct->s_ResponseCellList.s_BSCCellList[i].bReceiveRespons==0)
{
for(j=0;LPs_SetDrxProcessDataStruct->s_ResponseCellList.s_BSCCellList[i].ilength;j++)
{
LPs_SetDrxProcessDataStruct->s_ResponseCellList.s_BSCCellList[i].s_CellReport[j].cCellStatus=PERMANENT_FAILURE;
}
}
}
/* 壓縮ReportList參數 */
for(i=0;i<LPs_SetDrxProcessDataStruct->s_ResponseCellList.cNumberOfBSC;i++)
{
memcpy(&ResponseBuf[iPosi],&LPs_SetDrxProcessDataStruct->s_ResponseCellList.s_BSCCellList[i],
LPs_SetDrxProcessDataStruct->s_ResponseCellList.s_BSCCellList[i].ilength*sizeof(CELLREPORT_i )+sizeof(short)+BSC_INDENTIFIER_LEN);
iPosi=iPosi+LPs_SetDrxProcessDataStruct->s_ResponseCellList.s_BSCCellList[i].ilength*sizeof(CELLREPORT_i )+sizeof(short)+BSC_INDENTIFIER_LEN;
}
iLen=iPosi-sizeof(short);
LPs_SetDrxResp->s_MessageHead.iMessageLength=iLen-sizeof(MESSAGE_HEAD_t);
memcpy(&ResponseBuf[0],&iLen,sizeof(short));
#ifdef DEBUG_PRINT
printf("SETDRX Return To CBCProxy. Pid=%d\n",s_Pid.iProcessId);
#endif
AppendCBESendMessage((CBEMESSAGE_t *)&ResponseBuf[0]);
}?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -