?? cli_init.c
字號:
/************************************************************************
Copyright 200X - 200X+1.
filename : CLI_Init.c
description : 本文件實現命令行模塊主要部分的初始化操作
author : Woodhead
modification : Woodhead create 2004-12-07
************************************************************************/
#include "Ros.h"
#include "ML.h"
#include "Cli_MlPriv.h"
#include "Cli_Private.inc"
#include "CLI_Intp.inc"
#include "..\include\Cli_IO.h"
#include "CLI_Telnet.inc"
#include "CLI_User.inc"
#include "Cli_Log.inc"
#include "CLI_Cmd.inc"
#include "Board_Pub.h"
#include "Config\Cli_ConfigGlbVar.h"
/*任務數據表(表項數目為m_ulCliMaxTermNum)*/
/*說明: 該任務數據表為靜態表，其中前兩個分別為串口任務和MML終端 */
/* 的服務器端，后四個為telnet任務, 終端任務ID即取該表下標+1 */
/* 若為從設備，則由終端1到的6分別對應主設備的終端，終端0、7 */
/* 分別為從設備自己的串口和telnet任務接收函數 */
struct TD_S *m_TDTable = G_NULL;
CT_MODE_RECORD_T *m_sModeMutex[CTM_TOTAL]; /* 模式互斥結構 */
_S8 m_szHostName[HOSTNAME_LENGTH] ; /* 主機設備名 */
TIMER_ID m_CliSecTimer; /* 命令行定時器 */
_U32 m_ulCliStat[CLI_STAT_BUTT]; /* 命令行統計信息 */
/* 串口波特率 */
_U32 m_ulSerialBaudrate = 0;
/* 最大終端個數, 包括各種終端類型(com/telnet/web等), 表m_TDTable的大小 */
_U32 m_ulCliMaxTermNum = 0;
/* 命令行最大在線用戶個數 */
_U32 m_ulCliMaxOnlineUser = 0;
/* Web網管終端在m_TDTable的起始索引和終止索引 */
#if ( CLI_WEB_SUPPORT == G_YES )
_U32 m_ulCliWebTermFirstIndex = G_NULL_DWORD;
_U32 m_ulCliWebTermLastIndex = G_NULL_DWORD;
#endif /* #if ( CLI_WEB_SUPPORT == G_YES ) */
#if MULTI_DEVICE_SUPPORT
_U8 m_CliIsMainDevice;
extern _U32 BOARD_IsMainDevice(_VOID);
#endif
/* 命令行模塊的多語種字符串ID的枚舉值的最大值 */
_U32 g_ul_EN_CLI_ML_PRIV_SID_BUTT = EN_CLI_ML_PRIV_SID_BUTT;
/*==================================================================*/
/* 函數名 :CLI_ProcessMsg */
/* 函數功能 :命令行通用消息處理 */
/* 輸入參數 :PTerm_Data_S pTermStruct 任務數據指針 */
/* 輸出參數 :PTerm_Data_S pTermStruct 任務數據指針 */
/* 返回值 :無 */
/* 調用函數 :無 */
/* 備注 :環境變量的初始化不在該函數中進行 */
/*==================================================================*/
_VOID CLI_ProcessMsg(ST_MSG *pMsg)
{
ST_DBG_MSG* pDbgMsg;
ST_TIMER_NOTIFY_MSG *pstNotify;
#if MULTI_DEVICE_SUPPORT
PNMS_MSG_S pNmsMsg;
PST_MSCLI_MSG pstMsCliMsg;
PTerm_Data_S pTermStruct;
#endif
if (pMsg == G_NULL || pMsg->usDstPid != PID_CLI)
{
DBG_Out(PID_CLI, CLI_DBGOUT_ERR, "\r\n!CLI:recieved error message!");
MT_ERRLOG(0);
return ;
}
DBG_Out(PID_CLI, EN_DBG_OUT_CHN_31,
"\r\n CLI_ProcessMsg:: Received msg (Code:%x)", pMsg->usMsgCode);
switch (pMsg->usSrcPid)
{
case PID_DEBUG:
if( G_NULL != g_pfn_CFG_CLI_CmdTestProc )
{
pDbgMsg = (ST_DBG_MSG *)&( pMsg->ucData[pMsg->usDataOffset] );
(_VOID)g_pfn_CFG_CLI_CmdTestProc(pDbgMsg);
}
break;
case PID_ROS_TIMER:
pstNotify = (ST_TIMER_NOTIFY_MSG*)&( pMsg->ucData[pMsg->usDataOffset]);
if (pstNotify->TimerId == m_CliSecTimer)
{
CLI_PeriodProc();
}
break;
#if MULTI_DEVICE_SUPPORT
/* 主從設備命令行之間的交互消息 */
case PID_AGENT:
// here no break
case PID_CLI:
if (pMsg->usSrcPid == PID_CLI)
{
pstMsCliMsg = (PST_MSCLI_MSG)&( pMsg->ucData[pMsg->usDataOffset]);
if (!CLI_IS_TERMID_VALIDE(pstMsCliMsg->ucTermID))
{
CLI_RECORD(CLI_STAT_RECEIVED_UNWANTED);
DBG_Out(PID_CLI, CLI_DBGOUT_ERR, "\r\n! CLI:recieved error message from other device!");
break;
}
pTermStruct = m_TDTable[pstMsCliMsg->ucTermID - 1].pTermStruct;
}
else
{
pNmsMsg = (PNMS_MSG_S)&( pMsg->ucData[pMsg->usDataOffset]);
pstMsCliMsg = (PST_MSCLI_MSG)pNmsMsg->ucData;
pTermStruct = m_TDTable[1].pTermStruct; // 網管分配的終端為第二個
}
switch (pMsg->usMsgCode)
{
/* 接收透傳上層設備下發的透傳命令 */
case MSG_CODE_AGENT_SEND_CMD:
case MSG_CODE_CLI_TRANSCMD:
/* 如果該終端的接收狀態不正確，直接返回 */
if (pTermStruct->iSocket != SOCKET_FOR_MML || pTermStruct->ucTermStatus != TERM_LOGED)
{
DBG_Out(PID_CLI, CLI_DBGOUT_ERR,
"\r\n CLI: Term %d cannot process this command",pTermStruct->ulTermId);
break;
}
/* 如果命令超長，直接返回 */
if (EOS_StrLen((_S8 *)(pstMsCliMsg->ucData)) > CT_MAX_CMDBUF)
{
DBG_Out(PID_CLI, CLI_DBGOUT_ERR,
"\r\n CLI: Term %d received too long Command:\r\n %s",pTermStruct->ulTermId, pTermStruct->szRecvBuf);
break;
}
/* 設置該終端的語種與上層終端一致 */
ML_SetLanguage(pTermStruct->ulTermId, pstMsCliMsg->ucLan);
/* 從消息包中接收命令串 */
EOS_StrNCpy(pTermStruct->szRecvBuf, (_S8 *)(pstMsCliMsg->ucData), TERM_IO_BUFFER);
if (pTermStruct->ulTermId == 2)
EOS_StrCat(pTermStruct->szRecvBuf, "\r\n");
pTermStruct->iRecvLen = (_S32)EOS_StrLen(pTermStruct->szRecvBuf);
/* 注意命令的執行必須告知模式，否則無法使用現有命令解釋機制 */
pTermStruct->pWS->ulCurrentMode =
(_U32)(pstMsCliMsg->ucMode < CTM_TOTAL ? pstMsCliMsg->ucMode: 0);
DBG_Out(PID_CLI, CLI_DBGOUT_NOTE,
"\r\n CLI: Term %d received Command:%s",pTermStruct->ulTermId, pTermStruct->szRecvBuf);
break;
case MSG_CODE_CLI_FEEDBACK:
/* 接收反饋信息的終端狀態不正確，直接返回 */
if (pTermStruct->ucTermStatus != TERM_WAIT_RESPONSE)
{
DBG_Out(PID_CLI, CLI_DBGOUT_NOTE,
"\r\n CLI: Term %d Cannot Output the feedback info",pstMsCliMsg->ucTermID);
}
else if ((EOS_StrLen(pTermStruct->szSendBuf) + EOS_StrLen((_S8*)(pstMsCliMsg->ucData)))
< (TERM_IO_BUFFER - TERM_OUT_FOR_RESPONSE))
{
/* 復制反饋內容到發送緩沖區 */
DBG_Out(PID_CLI, CLI_DBGOUT_NOTE,
"\r\n CLI: Term %d received Output info:%s",pstMsCliMsg->ucTermID, pTermStruct->szSendBuf);
/* 注意: 應當保證從此處到該信息的輸出之前不調用IO_OutToTerm */
EOS_StrCat(pTermStruct->szSendBuf, (_S8*)(pstMsCliMsg->ucData));
pTermStruct->iSendLen = (_S32)EOS_StrLen(pTermStruct->szSendBuf);
}
break;
case MSG_CODE_CLI_EXECRESP:
if (pTermStruct->ucTermStatus == TERM_WAIT_RESPONSE)
{
DBG_Out(PID_CLI, CLI_DBGOUT_NOTE,
"\r\n CLI: Term %d received excute response",pstMsCliMsg->ucTermID, pTermStruct->szSendBuf);
/* 注意: 應當保證從此處到該信息的輸出之前不調用IO_OutToTerm */
EOS_StrCat(pTermStruct->szSendBuf, CMD_RESPONED_END);
break;
}
//else分支直接往下走
default:
CLI_RECORD(CLI_STAT_RECEIVED_UNWANTED);
DBG_Out(PID_CLI, CLI_DBGOUT_ERR,
"\r\n CLI: No process for message:Code-%d!", pMsg->usMsgCode);
break;
}
break;
#endif
default:
CLI_RECORD(CLI_STAT_RECEIVED_UNWANTED);
DBG_Out(PID_CLI, CLI_DBGOUT_ERR,
"\r\n CLI: No process for message from PID:%d!", pMsg->usSrcPid);
break;
}
}
#if MULTI_DEVICE_SUPPORT
/*==================================================================*/
/* 函數名 :CLI_MSMsgCreat */
/* 函數功能 :主從命令的消息構建函數 */
/* 輸入參數 :PTerm_Data_S pTermStruct 任務數據指針 */
/* 輸出參數 :PTerm_Data_S pTermStruct 任務數據指針 */
/* 返回值 :無 */
/* 調用函數 :無 */
/* 備注 :環境變量的初始化不在該函數中進行 */
/*==================================================================*/
ST_MSG* CLI_MSMsgCreat(_U32 usDeviceID, _U32 ulTermID, _U16 usMSmsgType, _S8 *szSend)
{
_U32 ulSize;
PST_MSCLI_MSG pstCliMsg;
ST_MSG *pstMsg;
if (szSend == G_NULL)
ulSize = sizeof(ST_MSCLI_MSG);
else
ulSize = sizeof(ST_MSCLI_MSG) + EOS_StrLen(szSend);
pstMsg = ROS_MsgAlloc(PUBLIC_LENS_TOTAL + ulSize, ROS_MSG_ALLOC_OPT_LEAK_CHECK );
if (pstMsg == G_NULL)
{
DBG_Out(PID_CLI, CLI_DBGOUT_ERR, "\r\n CLI(error return): CLI_MSMsgCreat:: ROS_MsgAlloc");
MT_ERRLOG(0);
return G_NULL;
}
/* 填充消息包的內容 */
pstMsg->usSrcBid = g_usTransLocalBID;
pstMsg->usDstBid = g_usTransLocalBID;
pstMsg->usSrcPid = PID_CLI;
pstMsg->usDstPid = PID_CLI;
pstMsg->usMsgCode = usMSmsgType;
pstMsg->usDataOffset = 0;
pstMsg->usDataLens = (_U16)ulSize;
pstCliMsg = (PST_MSCLI_MSG)&( pstMsg->ucData[pstMsg->usDataOffset] );
pstCliMsg->ucLan = ML_GetLanguage(ulTermID);
/* 由于主從命令行的終端ID不是完全對應的，因此需要作算術映射 */
if (m_CliIsMainDevice != G_TRUE && ulTermID >= 2)
ulTermID -= 2;
else if (m_CliIsMainDevice == G_TRUE)
ulTermID += 2;
pstCliMsg->ucTermID = (_U8)ulTermID;
if (szSend != G_NULL)
EOS_StrCpy((_S8 *)(pstCliMsg->ucData), szSend);
return pstMsg;
}
#endif
/*********************************************************************/
/* 函數名稱 : CLI_CfgGlbVarInit() */
/* 函數功能 : 與配置相關的模塊變量的初始化 */
/* 輸入參數 : */
/* 輸出參數 : */
/* 返回 : */
/* 上層函數 : CLI_ConfigInit() */
/* 創建者 : */
/* 修改記錄 : */
/*********************************************************************/
_U32 CLI_CfgGlbVarInit( _VOID )
{
_U32 i, ulSize;
_U8 *pucMem;
/* 命令行最大在線用戶個數( 最前兩個分別為串口任務和MML終端的服務器端, 保留 ) */
m_ulCliMaxOnlineUser = 2 + g_ul_CFG_CLI_MAX_TELNET_CLIENT_NUM;
#if MULTI_DEVICE_SUPPORT
{
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -