?? cli_termtelnet.c
字號:
fd_set SocketSet ;
struct timeval stWait;
_S32 ulErr = 0;
CLI_ASSURE_OR_FAIL( G_NULL != pTermStruct );
if ( pTermStruct->iSendLen == 0)
return G_SUCCESS;
stWait.tv_sec = 10;
stWait.tv_usec = 0 ;
FD_ZERO ( &SocketSet ) ;
FD_SET ( (_U32)pTermStruct->iSocket, &SocketSet ) ;
if (TERM_SEM_P(pTermStruct))
{
CLI_RECORD(CLI_STAT_SEM_P);
return G_FAILURE;
}
CLI_RECORD(CLI_STAT_CLIENT_GOTO_SELECT_S);
ulErr = urp_select( (_U32)(pTermStruct->iSocket + 1), ( fd_set * ) 0, &SocketSet, ( fd_set * ) 0, &stWait );
CLI_RECORD(CLI_STAT_CLIENT_OVER_SELECT_S);
if (ulErr > 0 )
{
FD_ZERO ( &SocketSet );
CLI_RECORD(CLI_STAT_CLIENT_GOTO_SEND);
ulErr = send ( pTermStruct->iSocket, pTermStruct->szSendBuf, pTermStruct->iSendLen, 0 );
CLI_RECORD(CLI_STAT_CLIENT_OVER_SEND);
if(TERM_SEM_V(pTermStruct))
{
CLI_RECORD(CLI_STAT_SEM_V);
DBG_Out(PID_CLI, CLI_DBGOUT_ERR, "\r\n Sem_V_1 of Term %d Failed!", pTermStruct->ulTermId);
}
if ( ulErr>= 0 )
{
pTermStruct->iSendLen = 0 ;
pTermStruct->szSendBuf[ 0 ] = '\0' ;
return G_SUCCESS;
}
else
{
DBG_Out(PID_CLI, CLI_DBGOUT_NOTE, "\r\n CLI_SendToTelnet:: send() Failed!");
return G_FAILURE;
}
}
if(TERM_SEM_V(pTermStruct))
{
CLI_RECORD(CLI_STAT_SEM_V);
DBG_Out(PID_CLI, CLI_DBGOUT_ERR, "\r\n Sem_V_2 of Term %d Failed!", pTermStruct->ulTermId);
}
CLI_SetTermStatus(pTermStruct, TERM_SLEEPING);
CLI_RECORD(CLI_STAT_CLIENT_SEND_CLOSED);
return G_FAILURE;
}
_U32 CLI_CloseSocket(PTerm_Data_S pTermStruct)
{
urp_close (pTermStruct->iSocket);
pTermStruct->iSocket = SOCKET_NOT_INITIAL;
return G_SUCCESS;
}
/*********************************************************************/
/* 函數(shù)名稱 : CLI_TelnetTask() */
/* 函數(shù)功能 : telnet任務體，根據(jù)狀態(tài)實現(xiàn)telnet功能 */
/* 輸入?yún)?shù) : 無 */
/* 輸出參數(shù) : 無 */
/* 返回 : 無 */
/* 上層函數(shù) : 任務調度函數(shù) */
/* 創(chuàng)建者 : */
/* 修改記錄 : */
/*********************************************************************/
_VOID CLI_TelnetTask( _U32 ulArg1, _U32 ulArg2)
{
PTerm_Data_S pTermStruct ;
#if MULTI_DEVICE_SUPPORT
_U32 ulTimeDes[5] = {0,0,0,0,0};
#endif
(void)ulArg2;
if (ulArg1 >= m_ulCliMaxOnlineUser)
{
DBG_Out(PID_CLI, CLI_DBGOUT_ERR, "\r\n CLI: telnet task id invalid!", ulArg1);
MT_ERRLOG(ulArg1);
return;
}
pTermStruct = m_TDTable[ulArg1].pTermStruct;
if (EOS_TaskGetSelfID(&m_TDTable[ulArg1].lTaskid) != G_SUCCESS)
{
CLI_RECORD(CLI_STAT_GET_TID_FAILD);
DBG_Out(PID_CLI, CLI_DBGOUT_ERR, "\r\n CLI: Get task id of tel%d failed!", ulArg1);
MT_ERRLOG(0);
}
/* 第一個創(chuàng)建的任務或由從設備創(chuàng)建的任務，均作為命令透傳處理任務 */
if (ulArg1 == 1)
{
CLI_MMLTaskInit(pTermStruct);
}
#if MULTI_DEVICE_SUPPORT
if (m_CliIsMainDevice != G_TRUE && ulArg1 + 1 < m_ulCliMaxOnlineUser )
{
CLI_MMLTaskInit(pTermStruct);
}
#endif
for (; ;)
{
switch (pTermStruct->ucTermStatus)
{
case TERM_SLEEPING:
CLI_DELAY(20);
break;
case TERM_ACTIVE:
CLI_TelnetInit(pTermStruct);
CLI_TermLogin(pTermStruct);
break;
case TERM_LOGED:
CLI_TermTaskProc(pTermStruct);
if (!IS_TERM_NORMAL(pTermStruct))
{
CLI_TermLogout(pTermStruct);
}
break;
#if MULTI_DEVICE_SUPPORT
case TERM_WAIT_RESPONSE:
{
if (ulTimeDes[ulArg1 - 1] == 0)
{
ulTimeDes[ulArg1 - 1] = WAIT_RESPONSE_TIME;
}
else if (ulTimeDes[ulArg1 - 1] == 1)
{
IO_Print(CLI_WAIT_RESP_TIMEOUT);
CLI_SetTermStatus(pTermStruct, TERM_LOGED);
}
if (m_CliIsMainDevice != G_TRUE)
{
CLI_SetTermStatus(pTermStruct, TERM_LOGED);
ulTimeDes[ulArg1 - 1] = 0;
continue;
}
if (pTermStruct->szSendBuf[0] != '\0')
{
_S8 *pcPos = G_NULL;
ulTimeDes[ulArg1 - 1] = WAIT_RESPONSE_TIME;
pTermStruct->ulTimeLeft
= (pTermStruct->ucTimeOutFlag == TIMEOUT_ON ? DEADLINE_SHORT : DEADLINE_LONG);
if ((pcPos = strstr(pTermStruct->szSendBuf, CMD_RESPONED_END)) != G_NULL)
{
*pcPos = '\0';
CLI_SendToTerm(pTermStruct);
CLI_SetTermStatus(pTermStruct, TERM_LOGED);
ulTimeDes[ulArg1 - 1] = 0;
}
else
CLI_SendToTerm(pTermStruct);
}
else
{
ulTimeDes[ulArg1 - 1]--;
CLI_DELAY(10);
}
break;
}
#endif
default:
CLI_SetTermStatus(pTermStruct, TERM_SLEEPING);
break;
}
}
}
/*==================================================================*/
/* 函數(shù)名 :CLI_TelnetEditString */
/* 函數(shù)功能 :Telnet掃描接收緩沖區(qū),并編輯字符串編輯緩沖區(qū) */
/* 輸入?yún)?shù) :PTerm_Data_S pTermStruct 任務數(shù)據(jù)指針 */
/* 輸出參數(shù) :PTerm_Data_S pTermStruct 任務數(shù)據(jù)指針 */
/* 返回值 :_U32 0: 接收到一完整命令行并準備提交該命令 */
/* 1: 只接收到一字符并準備繼續(xù)接收字符 */
/* 調用函數(shù) : CLI_EditString() */
/* 被調函數(shù) : */
/*==================================================================*/
_U32 CLI_TelnetEditString( PTerm_Data_S pTermStruct )
{
_U32 ulTmp ;
_U8 ucTmp ;
_U32 jTmp;
struct Fsm_Trans_S * pt ;
CLI_ASSURE_OR_FAIL( G_NULL != pTermStruct );
CLI_ASSURE_OR_FAIL ( pTermStruct->iSocket != SOCKET_FOR_SERIAL )
/* 接收字符串來自telnet terminal client,利用telnet的有限狀態(tài)機 */
for ( ulTmp = 0 ; ulTmp < (_U32)pTermStruct->iRecvLen ; ulTmp ++ )
{
ucTmp = (_U8)pTermStruct->szRecvBuf[ ulTmp ] ;
jTmp = ucTmp ;
jTmp = TTFsm[ pTermStruct->TelnetParam.TTState ][ jTmp ] ;
if(jTmp != TINVALID)
{
pt = &TTStab[ jTmp ] ;
pTermStruct->TelnetParam.TTState = pt->Ft_Next ;
if ( ! ( pt->Ft_Action ) ( pTermStruct, ucTmp ) )
return G_SUCCESS ;
}
}
return G_FAILURE ;
}
#endif /* #if CLI_TELNET_SUPPORT */
/*==================================================================*/
/* 函數(shù)名 :CLI_MMLTaskInit */
/* 函數(shù)功能 :MML類型的終端任務數(shù)據(jù)初始化 */
/* 輸入?yún)?shù) :pTermStruct 終端任務結構 */
/* 輸出參數(shù) :無 */
/* 返回值 :無 */
/* 被調函數(shù) : */
/*==================================================================*/
_VOID CLI_MMLTaskInit(PTerm_Data_S pTermStruct)
{
pTermStruct->iSocket = SOCKET_FOR_MML;
pTermStruct->ucTermStatus = TERM_LOGED;
pTermStruct->ucScroll = SCROLL_AUTO;
pTermStruct->pWS->ulSmart = SMART_OFF;
pTermStruct->pWS->ulLevel = CT_AL_DEBUG;
pTermStruct->ucUserLevel = CT_AL_DEBUG;
return;
}
/*┏━━━━━━━━━━Telnet調試命令實現(xiàn)━━━━━━━━━┓*/
/*┗━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛*/
_U32 CLI_CmdTelnetDiag(_U32 Param1, _U32 Param2, _U32 Param3, _U32 Param4)
{
extern _U32 CLI_DispStatInfo(_U32 ulTermID);
_S8 szIpaddr[20], szMask[20] = "255.255.0.0";
_U32 ulIpaddr, ulMask;
_U32 ulRet = G_SUCCESS;
PTerm_Data_S pTermStruct;
(_VOID)Param4;
switch(Param1)
{
case 0:
DBG_Out(PID_CLI, CLI_DBGOUT_ERR,
"\r\n param1 -- 調試類型: 1. 打開一個telnet訪問允許(IP:param2.param3.0.0/16)"
"\r\n 2. 查看telnet終端信息"
"\r\n 3. 踢掉一個終端(ID = param2)"
"\r\n 4. 查詢統(tǒng)計信息");
break;
case 1:
EOS_Sprintf(szIpaddr, "%d.%d.0.0", Param2, Param3);
if ((_StrToIPAddr(szIpaddr, &ulIpaddr) != G_SUCCESS)
|| (_StrToIPAddr(szMask, &ulMask) != G_SUCCESS))
return G_FAILURE;
ulRet = CLI_AclAdd(ulIpaddr, ulMask);
break;
case 2:
break;
case 3:
if (!CLI_IS_TERMID_VALIDE(Param2))
return G_FAILURE;
//強行注銷該終端
CLI_TermLogout(m_TDTable[Param3].pTermStruct);
break;
case 4:
CLI_DispStatInfo(1);
break;
case 5:
if (!CLI_IS_TERMID_VALIDE(Param2))
return G_FAILURE;
pTermStruct = m_TDTable[Param2 - 1].pTermStruct;
DBG_Out(PID_CLI, CLI_DBGOUT_MUST, "\r\n Term Data: (address = 0x%x)\r\n"
"\r\n socket = 0x%x"
"\r\n username = %s"
"\r\n ulTimeLeft = %d"
"\r\n ucTermStatus = %d"
"\r\n ucUserLevel = %d"
"\r\n pWS data: (address = 0x%x)"
"\r\n szCmd = %s"
"\r\n ulLevel = %d"
"\r\n ulStatus = %d",
(_U32)pTermStruct, pTermStruct->iSocket,
pTermStruct->szCurUserName, pTermStruct->ulTimeLeft,
pTermStruct->ucTermStatus, pTermStruct->ucUserLevel,
(_U32)pTermStruct->pWS, pTermStruct->pWS->szCmdString,
pTermStruct->pWS->ulLevel, pTermStruct->pWS->ulStatus);
break;
default:
return G_FAILURE;
}
return ulRet;
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -