?? cli_termtelnet.c
字號:
/************************************************************************
Copyright 200X - 200X+1.
filename : CLI_Term.c
description : 1、實現命令行操作終端的任務管理
2、終端任務數據中的字符串編輯緩沖的處理
author : Woodhead
modification : Woodhead create 2004-12-07
************************************************************************/
#include "Ros.h"
#include "CLI_Private.inc"
#include "CLI_Io.h"
#include "CLI_User.inc"
#include "CLI_Intp.inc"
#include "CLI_Telnet.inc"
#include "ML.h"
#include "Sys_Ml.h"
#include "Cli_MlPriv.h"
#include "cm_sock.h"
#include "Board_Pub.h"
#include "Config\Cli_ConfigGlbVar.h"
extern _VOID CLI_MMLTaskInit(PTerm_Data_S pTermStruct);
#if CLI_TELNET_SUPPORT
/*telnet server 初始化標志 只在本文件使用*/
static _U32 m_ulTelnetInitFlag = G_FALSE;
/*==================================================================*/
/* 函數名 :CLI_TelnetTasksCreat */
/* 函數功能 :創建與Telnet相關的任務. */
/* 輸入參數 :無 */
/* 輸出參數 :無 */
/* 返回值 :_U32 0: 初始化成功 1: 初始化失敗 */
/* 被調函數 : */
/*==================================================================*/
_U32 CLI_TelnetTasksCreat(_VOID)
{
_U32 ulRet;
_U32 ulArg[2] = {0, 0};
_U32 ulTaskID;
_U32 i;
_S8 szTaskName[32];
/* telnet服務器任務創建 */
ulRet = ROS_SelfTaskCreate(PID_CLI, "CLI_TASK_TELSERVER",
EN_ROS_TASK_PRIORITY_NORMAL,
ROS_TASK_STACK_SIZE_DEFAULT,
ulArg, CLI_TelnetServer, &ulTaskID);
CLI_ASSURE_OR_FAIL(ulRet == G_SUCCESS);
/* Note: 第一個任務為命令透傳處理任務(MML) */
/* ??? LingJian_Tailor */
#if 0
ulArg[0] = 1;
EOS_Sprintf(szTaskName, "CLI_TASK_TEL%d", i);
ulRet = ROS_SelfTaskCreate(PID_CLI, szTaskName,
EN_ROS_TASK_PRIORITY_NORMAL,
ROS_TASK_STACK_SIZE_DEFAULT,
ulArg, CLI_TelnetTask, &ulTaskID );
CLI_ASSURE_OR_FAIL(ulRet == G_SUCCESS);
#endif
for (i = FIRST_TELNET_DATA; i < m_ulCliMaxOnlineUser; i++)
{
ulArg[0] = i;
EOS_Sprintf(szTaskName, "CLI_TASK_TEL%d", i);
ulRet = ROS_SelfTaskCreate(PID_CLI, szTaskName,
EN_ROS_TASK_PRIORITY_NORMAL,
ROS_TASK_STACK_SIZE_DEFAULT,
ulArg, CLI_TelnetTask, &ulTaskID );
CLI_ASSURE_OR_FAIL(ulRet == G_SUCCESS);
}
return G_SUCCESS;
}
/*==================================================================*/
/* 函數名 :CLI_TelnetServerInit */
/* 函數功能 :初始化telnet連接 */
/* 輸入參數 :無 */
/* 輸出參數 :無 */
/* 返回值 :_U32 0: 初始化成功 1: 初始化失敗 */
/* 被調函數 : */
/*==================================================================*/
_U32 CLI_TelnetServerInit (_S32 *iSocketServer)
{
struct sockaddr_in sServerAddr ;
/* 創建一TCP socket連接 */
if ( ( *iSocketServer = socket ( AF_INET, SOCK_STREAM, 0 ) ) < 0 )
{
MT_ERRLOG(0);
return G_FAILURE ;
}
/* 設置服務器端端口,并與套接字綁定 */
memset ( ( _VOID * )&sServerAddr, 0, sizeof(sServerAddr) ) ;
sServerAddr.sin_family = AF_INET ; /* TCP - 數據流 */
sServerAddr.sin_port = (_U16)htons(TELNETPORT); /* Telnet 端口號 23 */
sServerAddr.sin_addr.s_addr = (_U32)htonl(INADDR_ANY) ; /* 任意客戶IP地址 */
if ( bind ( *iSocketServer, ( struct sockaddr * )&sServerAddr,
sizeof( sServerAddr ) ) != 0 )
{
urp_close(*iSocketServer);
MT_ERRLOG(0);
return G_FAILURE ;
}
/* 偵聽TELNET CLIENT的連接請求 */
if ( listen ( *iSocketServer, (int)g_ul_CFG_CLI_MAX_TELNET_CLIENT_NUM) != 0 )
{
urp_close(*iSocketServer);
MT_ERRLOG(0);
return G_FAILURE ;
}
/* 建立TELNET狀態機 */
if(m_ulTelnetInitFlag == G_FALSE)
{
CLI_FsmBuild ( ) ;
m_ulTelnetInitFlag = G_TRUE;
}
return G_SUCCESS ;
}
/*********************************************************************/
/* 函數名稱 : CLI_TelnetInit() */
/* 函數功能 : telnet任務初始化函數 */
/* 輸入參數 : pTermStruct telnet終端任務數據 */
/* 輸出參數 : pTermStruct telnet終端任務數據 */
/* 返回 : 成功/失敗 */
/* 上層函數 : */
/* 創建者 : */
/* 修改記錄 : */
/*********************************************************************/
_U32 CLI_TelnetInit(PTerm_Data_S pTermStruct)
{
_S32 iOptVal,iOptLen;
iOptVal = 1 ;
iOptLen = sizeof ( iOptLen ) ;
setsockopt ( pTermStruct->iSocket, SOL_SOCKET, SO_OOBINLINE, ( _S8 * ) & iOptVal,iOptLen ) ;
/* telnet server的TCP_NODELAY選項, 默認應該關閉, 即 iOptVal = 0 */
iOptVal = 0 ;
iOptLen = sizeof ( iOptLen ) ;
setsockopt ( pTermStruct->iSocket, IPPROTO_TCP, 0x01, ( _S8 * ) & iOptVal, iOptLen ) ;
CLI_NegotiateOption ( pTermStruct) ;
return G_SUCCESS;
}
/*==================================================================*/
/* 函數名 :CLI_TelnetServer */
/* 函數功能 :Telnet Server任務函數體 */
/* 輸入參數 :無 */
/* 輸出參數 :無 */
/* 返回值 :無 */
/* 被調函數 : */
/*==================================================================*/
_VOID CLI_TelnetServer( _U32 ulArg1, _U32 ulArg2)
{
struct sockaddr_in sClientAddr ;
_S32 iSocket;
_S32 iNameLen, iSocketServer;
_U32 ulCount;
_S8 szTelnetIp[20];
(_VOID)ulArg1;
(_VOID)ulArg2;
/*--------------------------------------------------------------*/
/* 初始化telnet sever */
/*--------------------------------------------------------------*/
while ( CLI_TelnetServerInit(&iSocketServer) != G_SUCCESS )
{
DBG_Out(PID_CLI, CLI_DBGOUT_NOTE, "\r\n CLI: TelnetServer Initial failed!");
CLI_DELAY(200);
}
iNameLen = sizeof( sClientAddr ) ;
for ( ; ; )
{
/* 等待接收telnet client的連接 */
if( ( iSocket = accept( (int)iSocketServer, ( struct sockaddr * )&sClientAddr,
(int*)&iNameLen ) ) <= 0 )
{
CLI_DELAY(10);
continue ;
}
_IPAddrToStr(sClientAddr.sin_addr.s_addr, &szTelnetIp[0]) ;
DBG_Out(PID_CLI, MT_DBGOUT_NOTE,
"\r\n CLI: 客戶端 %s 連接到本機.", szTelnetIp);
/* 檢驗客戶端ip地址的合法性(是否在telnet訪問允許列表內)*/
#if MULTI_DEVICE_SUPPORT
if (m_CliIsMainDevice == G_TRUE)
#endif
if( CLI_AclCheck(sClientAddr.sin_addr.s_addr) != G_SUCCESS )
{
IO_SendToAllTerm(CLI_TELNET_CLIENT_REFUSED, szTelnetIp);
CLI_DELAY(200);
urp_close ( iSocket ) ;
continue ;
}
for(ulCount = FIRST_TELNET_DATA; ulCount < m_ulCliMaxOnlineUser; ulCount++)
{
if (m_TDTable[ulCount].pTermStruct->ucTermStatus == TERM_SLEEPING
&& m_TDTable[ulCount].pTermStruct->iSocket == SOCKET_NOT_INITIAL)
break;
}
if(ulCount == m_ulCliMaxOnlineUser)
{
send ( (int)iSocket, (char *)"\n\r Too many telnet users!", 26, 0 ) ;
CLI_DELAY(100);
urp_close ( iSocket ) ;
continue ;
}
/* 激活該任務的狀態 */
m_TDTable[ulCount].pTermStruct->iSocket = iSocket;
m_TDTable[ulCount].pTermStruct->ulClientIP = sClientAddr.sin_addr.s_addr;
CLI_SetTermStatus(m_TDTable[ulCount].pTermStruct, TERM_ACTIVE);
}
}
/*==================================================================*/
/* 函數名 :CLI_ReceiveFromTelnet */
/* 函數功能 :從telnet客戶端接收數據 */
/* 輸入參數 :pTermStruct 任務數據 */
/* ulSecond 接收超時時間 */
/* 輸出參數 :無 */
/* 返回值 :無 */
/*==================================================================*/
_U32 CLI_ReceiveFromTelnet ( PTerm_Data_S pTermStruct, _U32 ulSecond)
{
fd_set SocketSet ;
struct timeval stWait ;
_S32 lErr =0;
if ( G_NULL == pTermStruct || ulSecond > DEADLINE_SHORT)
{
CLI_RECORD(CLI_STAT_RECEIVE_ERR);
return G_FAILURE ;
}
stWait.tv_usec = 0 ;
stWait.tv_sec = (_S32)ulSecond;
FD_ZERO ( &SocketSet ) ;
FD_SET ( (_U32)pTermStruct->iSocket, &SocketSet ) ;
CLI_RECORD(CLI_STAT_CLIENT_GOTO_SELECT);
lErr = urp_select ( FD_SETSIZE, &SocketSet, ( fd_set * ) 0, ( fd_set * ) 0, &stWait );
CLI_RECORD(CLI_STAT_CLIENT_OVER_SELECT);
if ( lErr > 0 )
{
/* 接收來自telnet客戶端的數據 */
FD_ZERO ( &SocketSet ) ;
if (TERM_SEM_P(pTermStruct))
{
CLI_RECORD(CLI_STAT_SEM_P);
return G_FAILURE;
}
CLI_RECORD(CLI_STAT_CLIENT_GOTO_RECV);
pTermStruct->iRecvLen = recv ( pTermStruct->iSocket, pTermStruct->szRecvBuf, TERM_IO_BUFFER, 0) ;
CLI_RECORD(CLI_STAT_CLIENT_OVER_RECV);
if(TERM_SEM_V(pTermStruct))
{
CLI_RECORD(CLI_STAT_SEM_V);
DBG_Out(PID_CLI, CLI_DBGOUT_ERR, "\r\n Sem_P of Term %d Failed!", pTermStruct->ulTermId);
}
if (pTermStruct->iRecvLen> 0 )
{
return G_SUCCESS ;
}
DBG_Out(PID_CLI, CLI_DBGOUT_NOTE, "\r\n CLI_ReceiveFromeTelnet:: recv() Failed!");
}
else if(lErr == 0)
{
CLI_RECORD(CLI_STAT_CLIENT_RECV_TIMEOUT);
return G_FAILURE;
}
CLI_SetTermStatus(pTermStruct, TERM_SLEEPING);
CLI_RECORD(CLI_STAT_CLIENT_RECV_CLOSED);
return G_FAILURE ;
}
/*==================================================================*/
/* 函數名 :CLI_SendToTelnet */
/* 函數功能 :向telnet客戶端發送數據 */
/* 輸入參數 :PTerm_Data_S pTermStruct 任務數據 */
/* PTerm_Data_S pTermStruct 任務數據 */
/* 輸出參數 :無 */
/* 返回值 :_U32 0: 發送成功 1: 發送失敗 */
/* 被調函數 : */
/*==================================================================*/
_U32 CLI_SendToTelnet ( PTerm_Data_S pTermStruct )
{
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -