学步园

网上很多朋友因为成本方面的原因，没有购买WAVECOM的收费插件，想自已实现远程升级，遇到一些问题，主要是数据怎么下载到模块中，其实只要能连上网，数据下载不是问题，我们即然可以创建基于TCP 的SOCKET，那么，做一个FTP Client又有何难的，甚至自己写一个基于TCP的数据传输协议又如何呢？

下面我公布我所实现的基于TCP 的FTP Client的OpenAT实现。

代码是基于 WaveCom Q26平台做的，WIP的版本高一点，Q24的WIP版本低一点，只在某些地方有点不一致，我就不列举了，这个代码是我运行正常的系统中的复制，所以我可以保证绝对没有问题，如果你在调试中出现错误，说明是你自己的问题,请先检查。

//+========================================================+<br /> //| |<br /> //| 文件描述: FTP通信 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-04 |<br /> //| |<br /> //+========================================================+</p> <p>#include "FTP.h"</p> <p>//外部引用 开始</p> <p>extern struct _device DEVICE; //基本设备配置<br /> extern DOTA_T DOTA; //用于本地更新的配置<br /> //外部引用 结束</p> <p>// 本地变量声明 开始</p> <p>wip_channel_t FTP_CHANNEL = (wip_channel_t)NULL; /*ftpChannel,ftp通道_命令*/<br /> wip_channel_t FTP_DATA_CHANNEL = (wip_channel_t)NULL; /*ftpDataChannel,ftp数据通道*/</p> <p>typedef struct _ftp_config{<br /> u8 FTP_SERVER[SERVER_CHAR_LEN]; // FTP 服务器地址<br /> u8 FTP_PORT; // FTP 服务器端口号,FTP默认为 21<br /> u8 FTP_USER[20]; // 登录 FTP 服务器所需的用户名<br /> u8 FTP_PASS[20]; // 登录 FTP 服务器所需的密码<br /> u8 FTP_FILE[50]; // 从服务器上下载的文件<br /> }FTP_CFG;</p> <p>FTP_CFG FTP; // FTP本地配置</p> <p>u32 FTP_RX_FILE_LENGTH = 0; //本地已接收的远程文件大小<br /> u32 FTP_REMOTE_FILE_LENGTH = 0; //远程文件大小</p> <p>u8 FTP_DOWN_FILE_IS_OK = 0; //FTP 下载文件是否完成</p> <p>#define FTP_DATA_TIMEOUT_ERROR_COUNT 5 //如果5秒钟还未收到从FTP传来的数据，那么说明FTP连接可能超时了<br /> u32 FTP_DATA_TIMEOUT_COUNT = 0; //FTP 从远程下载文件超时计数<br /> //u32 FTP_DATA_TIMER_COUNTER = 0; //timer 计数器</p> <p>//adl_rtcTime_t ftp_time_last; //系统时钟，最后一次同步的时间</p> <p>adl_tmr_t *ftp_data_tmr = NULL; //FTP数据传输监控timer</p> <p>//FTP 文件缓存 定义<br /> //#define FTP_FILE_BUF_LEN (1024 * 10) //FTP缓存大小 100 KB<br /> //u32 FTP_RX_FILE_BUF_LEN = 0; // FTP 已接收的缓存文件长度<br /> //u8 *FTP_RX_FILE_BUF; //FTP缓存</p> <p>// 本地变量声明 结束</p> <p>// 文件内部函数声明 开始<br /> bool FTP_CMD_SEND(u8 *data,u16 len);<br /> void FTP_Quit( void );<br /> void FTP_Login(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_Password(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_TransferData_Complete(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_PASVParse(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_NoFileOnRemote(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_ServerBusy(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_RestFile(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_Login(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_ConnectTimeout(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_SetTransferType_OK(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_StartTransferData(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_DataAbort(int argc,int cmdIndex,const u8 **argv);<br /> void FTP_Logined(int argc,int cmdIndex,const u8 **argv);</p> <p>bool Create_FTP_Client( void );<br /> void FTP_Rest( void );<br /> void FTP_Monitor_Handle(u8 id, void *context );</p> <p>void Start_FTP_Monitor( void );<br /> void Stop_FTP_Monitor( void );<br /> // 文件内部函数声明 结束</p> <p>// +-----------------------------------------------------------+<br /> // | 编写:唐登安 最后修改时间:2009-09-04 |<br /> // | |<br /> // | 功能描述:FTP回调函数 具体功能看注释 |<br /> // | |<br /> // +-----------------------------------------------------------+<br /> CMD_CALLBACK FTP_CMD[]={<br /> //TEST<br /> {"220", NULL, FTP_Login }, //发用户名<br /> {"331", NULL, FTP_Password }, //发密码<br /> {"230", NULL, FTP_Logined }, //Ftp登陆成功<br /> {"530", NULL, FTP_ConnectTimeout }, //ftp 登录超时<br /> {"200", NULL, FTP_SetTransferType_OK }, //ftp 设置传输模式OK<br /> {"150", NULL, FTP_StartTransferData }, //Ftp开始下载数据<br /> {"226", NULL, FTP_TransferData_Complete}, //ftp 下载数据完成<br /> {"227", NULL, FTP_PASVParse }, //解析被动模式的服务器端口<br /> {"550", NULL, FTP_NoFileOnRemote }, //远程服务器没有文件<br /> {"350", NULL, FTP_RestFile }, //断点续传远程文件<br /> {"425", NULL, FTP_ServerBusy }, //服务器忙<br /> {"426", NULL, FTP_DataAbort }, //数据连接中断<br /> {NULL, NULL, NULL } //最后一个，终止<br /> };</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: 初始化 FTP 配置 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-04 |<br /> //| |<br /> //| 返 回 值: void |<br /> //| |<br /> //| 参数说明: ftpServer: FTP 服务器<br /> //| ftpPort: FTP 服务端口<br /> //| ftpUser: FTP 用户名<br /> //| ftpPass: FTP 密码<br /> //| |<br /> //+========================================================+<br /> void Init_FTP( u8 *ftpServer, u8 ftpPort, u8 *ftpUser, u8 *ftpPass ,u8 *ftpFile)<br /> {<br /> u8 i;<br /> u8 fileName[11]="";<br /> //容错:如果FTP已经创建，那么不需要继续创建<br /> if ( FTP_CHANNEL != NULL )<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("Init_FTP recall/r/n");<br /> #endif<br /> Close_FTP();<br /> Close_FTP_DataClient();<br /> /*<br /> if ( FTP_RX_FILE_BUF != NULL )<br /> {<br /> adl_memRelease( FTP_RX_FILE_BUF );<br /> }*/<br /> }</p> <p> strcpy( FTP.FTP_PASS, ftpPass );<br /> strcpy( FTP.FTP_SERVER, ftpServer );<br /> strcpy( FTP.FTP_USER, ftpUser );<br /> strcpy( FTP.FTP_FILE, ftpFile );</p> <p> FTP.FTP_PORT = ftpPort;</p> <p>// //分配内存空间，用于 FTP 下载文件存储,此内存大小于 FTP_FILE_BUF_LEN 定义<br /> // FTP_RX_FILE_BUF = adl_memGet( FTP_FILE_BUF_LEN );<br /> // if ( FTP_RX_FILE_BUF == NULL )<br /> // {<br /> //#ifdef ftpDebug<br /> // Debug_Printf("Ftp memGet Fail!!!!!!!!Not Enough Memory/r/n");<br /> //#endif<br /> // return ;<br /> // }<br /> // memset( FTP_RX_FILE_BUF, 0, sizeof( FTP_RX_FILE_BUF ) );<br /> // FTP_RX_FILE_BUF_LEN = 0;</p> <p> //连接FTP服务器 -- 移至AD完成初始化后<br /> //Create_FTP_Client();</p> <p> //初始化 AD<br /> AD_Init();<br /> }</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: 关闭 FTP通道 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-07 |<br /> //| |<br /> //| 返 回 值: void |<br /> //| |<br /> //| 参数说明: void</p> <p>//+========================================================+<br /> void Close_FTP( void )<br /> {<br /> if ( FTP_CHANNEL == NULL ) return;</p> <p> wip_abort( FTP_CHANNEL );<br /> wip_close( FTP_CHANNEL );<br /> }</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: 关闭 FTP 数据通道 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-07 |<br /> //| |<br /> //| 返 回 值: void |<br /> //| |<br /> //| 参数说明: void</p> <p>//+========================================================+<br /> void Close_FTP_DataClient( void )<br /> {<br /> if ( FTP_DATA_CHANNEL == NULL ) return ;</p> <p> wip_abort( FTP_DATA_CHANNEL );<br /> wip_close( FTP_DATA_CHANNEL );<br /> }<br /> //+========================================================+<br /> //| |<br /> //| 程序用途: 关闭 FTP通道 成功回调 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-04 |<br /> //| |<br /> //| 返 回 值: void |<br /> //| |<br /> //| 参数说明: void</p> <p>//+========================================================+<br /> void FTP_Finalized( void )<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_Finalized/r/n");<br /> #endif<br /> //Create_FTP_Client();<br /> }</p> <p>// +-----------------------------------------------------------+<br /> // | 函数编写:唐登安 最后修改时间: 2009-09-04 |<br /> // | |<br /> // | 功能描述:TCP FtpClient [命令] 回调 |<br /> // | |<br /> // | 参数说明: |<br /> // | |<br /> // | 函数返回:void |<br /> // | |<br /> // | 修正问题:void |<br /> // +-----------------------------------------------------------+<br /> void FTP_CallBack(wip_event_t *ev, void *ctx)<br /> {<br /> u8 msg[1500] = "";<br /> u16 len = 0;<br /> switch(ev->kind){<br /> //读取到数据<br /> case WIP_CEV_READ:{<br /> //网络通信正常，收到数据</p> <p> #ifdef ftpDebug<br /> Debug_Printf("WIP_CEV_READ/r/n");<br /> #endif </p> <p> memset( msg, 0, sizeof( msg ) );<br /> len = wip_read( FTP_CHANNEL, msg, sizeof( msg ) );</p> <p> FTP_DATA_TIMEOUT_COUNT = 0;</p> <p> #ifdef ftpDebug<br /> Debug_Printf("RX:%s/r/n",msg);<br /> #endif<br /> //执行Ftp命令<br /> Create_CallBackHandle( FTP_CMD, msg, ' ' );<br /> break;<br /> }<br /> case WIP_CEV_WRITE:{<br /> #ifdef ftpDebug<br /> Debug_Printf("WIP_CEV_WRITE/r/n");<br /> #endif<br /> break;<br /> }<br /> case WIP_CEV_ERROR:{<br /> #ifdef ftpDebug<br /> Debug_Printf("WIP_CEV_ERROR=%d/r/n",ev->content.error.errnum);<br /> #endif<br /> break;<br /> }<br /> case WIP_CEV_PEER_CLOSE:{<br /> #ifdef ftpDebug<br /> Debug_Printf("WIP_CEV_PEER_CLOSE/r/n");<br /> #endif<br /> break;<br /> }<br /> default:{<br /> #ifdef ftpDebug<br /> Debug_Printf("TcpCallback Other Error/r/n");<br /> #endif<br /> }<br /> }</p> <p>}</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: 从命令通道向FTP发数据 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-04 |<br /> //| |<br /> //| 返 回 值: TRUE:成功 FALSE:失败 |<br /> //| |<br /> //| 参数说明: void<br /> //| |<br /> //+========================================================+<br /> bool FTP_CMD_SEND(u8 *data,u16 len)<br /> {</p> <p> int writeret = wip_write( FTP_CHANNEL, data, len );</p> <p>#ifdef ftpDebug<br /> Debug_Printf("FtpWrite=%d/r/n",writeret);<br /> #endif<br /> if( writeret < 0 ){<br /> return FALSE;<br /> }<br /> return TRUE;<br /> }</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: 创建 FTP 客户端 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-04 |<br /> //| |<br /> //| 返 回 值: TRUE:创建成功 FALSE:创建失败 |<br /> //| |<br /> //| 参数说明: void<br /> //| |<br /> //+========================================================+<br /> bool Create_FTP_Client( void )<br /> {<br /> static u8 state = 0 ;</p> <p> FTP_CHANNEL = wip_TCPClientCreateOpts(<br /> FTP.FTP_SERVER, //FTP 服务器<br /> FTP.FTP_PORT, //FTP 端口号<br /> FTP_CallBack, //FTP 回调<br /> &state,<br /> WIP_COPT_KEEPALIVE, 300, //保持连接 3 分钟<br /> WIP_COPT_FINALIZER, FTP_Finalized, //关闭 FTP 回调<br /> WIP_COPT_END<br /> );</p> <p> #ifdef ftpDebug<br /> Debug_Printf("FtpClient Create %d /r/n", FTP_CHANNEL );<br /> #endif</p> <p> if( FTP_CHANNEL == NULL )<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FtpClient Create Error /r/n");<br /> #endif</p> <p> return FALSE;<br /> }</p> <p> Start_FTP_Monitor(); //启动ftp数据传输监控<br /> return TRUE;<br /> }</p> <p>// +-----------------------------------------------------------+<br /> // | 函数编写:唐登安 最后修改时间:2009-09-04 |<br /> // | |<br /> // | 功能描述:TCP FtpDataClient [数据] 回调 |<br /> // | |<br /> // | 参数说明: |<br /> // | |<br /> // | 函数返回:void |<br /> // | |<br /> // | 修正问题:增加数据下载完成发送退出ftp命令 |<br /> // +-----------------------------------------------------------+<br /> void FTP_Data_CallBack( wip_event_t *ev, void *ctx )<br /> {<br /> u8 _tcpBuffer[2048] = "";//设置 2 Kbyte的临时空间 </p> <p> u8 cmd[100]="";<br /> s16 len = 0; /* 修正：原来这里读取的数据是无符号型，但有可能网络原因返回 <0 的值 */<br /> u8 tmp;<br /> u8 fileName[50] = "";<br /> switch(ev->kind){<br /> //读取到数据<br /> case WIP_CEV_READ:{</p> <p> memset( _tcpBuffer, 0, sizeof( _tcpBuffer ) );<br /> len = wip_read( FTP_DATA_CHANNEL, _tcpBuffer, sizeof( _tcpBuffer ) );</p> <p> if( len < 1 ) /* 容错 */<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("Ftp Data Read Error :%d/r/n",len);<br /> #endif<br /> return;<br /> }</p> <p> FTP_DATA_TIMEOUT_COUNT = 0; //FTP数据接收置0，表示收到从ftp传来的数据</p> <p> FTP_RX_FILE_LENGTH += len; //接收到的数据长度</p> <p> AD_WriteData( _tcpBuffer, len ); //向 AD 写入数据</p> <p> //如果下载的数据已经完成，即安装文件<br /> if( FTP_RX_FILE_LENGTH == FTP_REMOTE_FILE_LENGTH )<br /> {<br /> // //文件下载成功<br /> // sprintf( fileName, "//%s", FTP.FTP_FILE );<br /> // tmp = CreateFile ( fileName, FTP_RX_FILE_BUF, FTP_RX_FILE_BUF_LEN ); // 向U盘写入数据<br /> // #ifdef ftpDebug<br /> // Debug_Printf("Create %s Udisk,FileLen:%d Created:%d/r/n", fileName, FTP_RX_FILE_BUF_LEN, tmp );<br /> // #endif</p> <p> // FTP_RX_FILE_BUF_LEN = 0;<br /> // adl_memRelease( FTP_RX_FILE_BUF );</p> <p> Stop_FTP_Monitor(); //文件下载完成,可以关闭FTP监控timer</p> <p> FTP_Quit(); //退出登录</p> <p> AD_Install(); //安装程序<br /> }<br /> break;<br /> }<br /> case WIP_CEV_WRITE:{<br /> #ifdef ftpDebug<br /> Debug_Printf("FtpDataCallback:WIP_CEV_WRITE/r/n");<br /> #endif<br /> break;<br /> }<br /> case WIP_CEV_ERROR:{<br /> #ifdef ftpDebug<br /> Debug_Printf("FtpDataCallback:WIP_CEV_ERROR=%d/r/n",ev->content.error.errnum);<br /> #endif<br /> break;<br /> }<br /> case WIP_CEV_PEER_CLOSE:{<br /> #ifdef ftpDebug<br /> Debug_Printf("FtpDataCallback:WIP_CEV_PEER_CLOSE/r/n");<br /> #endif</p> <p> break;<br /> }<br /> //创建成功<br /> case WIP_CEV_OPEN:{<br /> //开始下载<br /> FTP_Rest();</p> <p> break;<br /> }<br /> default:{<br /> #ifdef ftpDebug<br /> Debug_Printf("FtpDataCallback:TcpCallback Other Error %d/r/n", ev->kind );<br /> #endif<br /> }<br /> }<br /> }</p> <p>// +-----------------------------------------------------------+<br /> // | 函数编写: 唐登安 最后修改时间:2009-09-04 |<br /> // | |<br /> // | 功能描述: 创建FTP命令TCP链接 |<br /> // | |<br /> // | 参数说明: ftpPort:数据侦听端口|<br /> // | |<br /> // | 函数返回: 是否成功 |<br /> // | |<br /> // | 修正问题: |<br /> // +-----------------------------------------------------------+</p> <p>bool Create_FTP_DataClient(u16 ftpPort)<br /> {<br /> FTP_DATA_CHANNEL = wip_TCPClientCreate(<br /> FTP.FTP_SERVER,<br /> ftpPort,<br /> FTP_Data_CallBack,<br /> NULL<br /> );</p> <p> if( FTP_DATA_CHANNEL == NULL )<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FtpDataClient Create Error/r/n");<br /> #endif<br /> return FALSE;<br /> }<br /> #ifdef tcpDebug<br /> Debug_Printf("FtpDataClient Create %d/r/n", FTP_DATA_CHANNEL );<br /> #endif</p> <p> return TRUE;<br /> }</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: FTP 退出登录 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-04 |<br /> //| |<br /> //| 返 回 值: void |<br /> //| |<br /> //| 参数说明: void |<br /> //| |<br /> //+========================================================+<br /> void FTP_Quit( void )<br /> {</p> <p> FTP_CMD_SEND( "quit", strlen( "quit" ) );</p> <p> #ifdef ftpDebug<br /> Debug_Printf( "FTP_QUIT/r/n");<br /> #endif</p> <p> //if( FTP_RX_FILE_BUF != NULL )<br /> //{<br /> // //释放由 FTP 占用的空间<br /> // adl_memRelease( FTP_RX_FILE_BUF );<br /> //}<br /> Stop_FTP_Monitor(); /* 释放 ftp 文件下载监视器 */<br /> }</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: FTP 登录 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-04 |<br /> //| |<br /> //| 返 回 值: void |<br /> //| |<br /> //| 参数说明: void |<br /> //| |<br /> //+========================================================+<br /> void FTP_Login(int argc,int cmdIndex,const u8 **argv)<br /> {</p> <p> u8 cmd[100] = "";</p> <p> wm_sprintf(cmd,"USER %s/r/n", FTP.FTP_USER );</p> <p> #ifdef ftpDebug<br /> Debug_Printf("FTP_Login/r/ncmd=%s/r/n",cmd);<br /> #endif</p> <p> FTP_CMD_SEND( cmd, strlen(cmd) );</p> <p>}</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: FTP 登录密码 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-04 |<br /> //| |<br /> //| 返 回 值: void |<br /> //| |<br /> //| 参数说明: void |<br /> //| |<br /> //+========================================================+<br /> void FTP_Password(int argc,int cmdIndex,const u8 **argv)<br /> {<br /> u8 pass[100]="";<br /> wm_sprintf(pass,"PASS %s/r/n",FTP.FTP_PASS);</p> <p> #ifdef ftpDebug<br /> Debug_Printf("FTP_Password/r/ncmd=%s/r/n",pass);<br /> #endif</p> <p> FTP_CMD_SEND(pass,strlen(pass));<br /> }</p> <p>//用户登录成功<br /> void FTP_Logined(int argc,int cmdIndex,const u8 **argv)<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_Logined/r/n");<br /> #endif<br /> //登录成功后，设置为数据状态<br /> FTP_CMD_SEND("TYPE I/r/n",strlen("TYPE I/r/n"));<br /> }<br /> //ftp 登录超时<br /> void FTP_ConnectTimeout(int argc,int cmdIndex,const u8 **argv)<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_ConnectTimeout/r/n");<br /> #endif<br /> }<br /> //ftp 设置传输模式 成功<br /> void FTP_SetTransferType_OK(int argc,int cmdIndex,const u8 **argv)<br /> {</p> <p> u8 cmd[220]="";<br /> #ifdef ftpDebug<br /> Debug_Printf("Set Transfer Type OK/r/n");<br /> #endif</p> <p> //获取服务器 端口<br /> wm_sprintf(cmd,"PASV/r/n");</p> <p> FTP_CMD_SEND(cmd,strlen(cmd));<br /> }<br /> //ftp 解析 PASV 端口<br /> void FTP_PASVParse(int argc,int cmdIndex,const u8 **argv)<br /> {</p> <p> u8 cmd[100]="",msg[100]="";<br /> u8 count=0; </p> <p> u8 *argvv[10];//只接收 10 个参数<br /> //ftp 服务器端口<br /> u16 serverPort=20;</p> <p> argv[ strlen( argv ) - 2 ] = '/0';</p> <p> wm_sprintf(cmd, "%s", argv[argc-1]);</p> <p> count = ParseArg(cmd, ',', argvv);</p> <p> #ifdef ftpDebug<br /> wm_sprintf(msg,"argv=%s/r/narglen=%d/r/n",argvv[count-1],count);<br /> Debug_Printf(msg);<br /> #endif</p> <p> serverPort = atol(argvv[count-2])*256;<br /> serverPort += atol(argvv[count-1]);</p> <p> #ifdef ftpDebug<br /> wm_sprintf(msg,"server port=%d/r/n",serverPort);<br /> Debug_Printf(msg);<br /> #endif</p> <p> //关闭数据接收客户端<br /> //close_FtpDataChannel();<br /> //创建数据接收客户端<br /> //create_FtpDataClient(DOTA.ftpServer,serverPort);<br /> Create_FTP_DataClient( serverPort );<br /> }<br /> //ftp 开始下载数据<br /> void FTP_StartTransferData(int argc,int cmdIndex,const u8 **argv)<br /> {<br /> u8 cmd[100]="",plen[15]="";</p> <p> memset(plen,0,sizeof(plen));<br /> memcpy(plen,argv[argc-2],strlen(argv[argc-2]));<br /> plen[0]='0';</p> <p> FTP_REMOTE_FILE_LENGTH = STR_TO_U32( plen,strlen( argv[argc-2] ) );</p> <p> #ifdef ftpDebug<br /> //Debug_Printf("FTP_StartTransferData/r/nParse plen=%s/r/n",plen);<br /> //wm_sprintf(cmd,"Ftp File length=%d/r/n",FTP_REMOTE_FILE_LENGTH);<br /> //Debug_Printf(cmd);<br /> Debug_Printf("FTP_StartTransferData/r/nParse plen=%s/r/nu32:%d/r/n", plen, FTP_REMOTE_FILE_LENGTH );<br /> #endif</p> <p>}<br /> //远程服务器没有文件<br /> void FTP_NoFileOnRemote(int argc,int cmdIndex,const u8 **argv)<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_NoFileOnRemote/r/n");<br /> #endif<br /> //close_FtpDataChannel();<br /> //close_FtpChannel();<br /> }<br /> //ftp 下载数据完成<br /> void FTP_TransferData_Complete(int argc,int cmdIndex,const u8 **argv)<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_TransferData_Complete/r/n Received length=%d/r/n", FTP_RX_FILE_LENGTH );<br /> #endif<br /> //DOTA.Status=FtpDataTransferEnd;//下载数据完成</p> <p> FTP_DOWN_FILE_IS_OK = 1;//文件下载完成</p> <p> /* Install the application */<br /> //AnDInstall();<br /> #ifdef adDebug<br /> if(FTP_RX_FILE_LENGTH != FTP_REMOTE_FILE_LENGTH )<br /> {<br /> Debug_Printf("Receive File Length Error/r/n");<br /> }<br /> #endif<br /> }</p> <p>//ftp 下载文件<br /> void FTP_Retr()<br /> {<br /> u8 cmd[100]="";<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_Retr/r/n");<br /> #endif</p> <p> //开始下载数据<br /> wm_sprintf(cmd,"RETR %s/r/n",FTP.FTP_FILE);<br /> FTP_CMD_SEND( cmd, strlen(cmd) );</p> <p> //开始监控ftp是否有数据传输<br /> //AddFtpWatch();<br /> }<br /> //断点续传文件<br /> void FTP_Rest( void )<br /> {<br /> u8 cmd[100]="";<br /> #ifdef ftpDebug<br /> Debug_Printf("REST()/r/n");<br /> #endif<br /> wm_sprintf(cmd,"REST %d/r/n",FTP_RX_FILE_LENGTH );</p> <p> FTP_CMD_SEND( cmd, strlen(cmd) );</p> <p>}<br /> //ftp 服务器忙 回调<br /> void FTP_ServerBusy(int argc,int cmdIndex,const u8 **argv)<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_ServerBusy()/r/n");<br /> #endif<br /> }<br /> //ftp 断点续传远程文件 回调<br /> void FTP_RestFile(int argc,int cmdIndex,const u8 **argv)<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_RestFile/r/n");<br /> #endif<br /> FTP_Retr();<br /> }<br /> //数据连接中断<br /> void FTP_DataAbort(int argc,int cmdIndex,const u8 **argv)<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_DataAbort /r/n");<br /> #endif<br /> //restart_FtpChannel();<br /> }</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-07 |<br /> //| |<br /> //| 返 回 值: TRUE:成功 FALSE:失败 |<br /> //| |<br /> //| 参数说明:<br /> //|<br /> //| |<br /> //+========================================================+<br /> void FTP_Monitor_Handle(u8 id, void *context )<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("FTP_Monitor_Handle %d/r/n", FTP_DATA_TIMEOUT_COUNT );<br /> #endif</p> <p> if( ftp_data_tmr == NULL ) return;</p> <p> //if( ( FTP_DATA_TIMER_COUNTER - FTP_DATA_TIMEOUT_COUNT ) > FTP_DATA_TIMEOUT_ERROR_COUNT )<br /> //{<br /> // //没有数据传输，超时，重新向ftp发命令<br /> // Close_FTP(); //关闭ftp命令通道<br /> // Close_FTP_DataClient(); //关闭ftp数据通道</p> <p> // //重新启动ftp<br /> // Create_FTP_Client();<br /> //<br /> // FTP_DATA_TIMEOUT_COUNT = 0; //重置监控状态<br /> // FTP_DATA_TIMER_COUNTER = 0;<br /> //}</p> <p> //传输超时<br /> if( FTP_DATA_TIMEOUT_COUNT > FTP_DATA_TIMEOUT_ERROR_COUNT )<br /> {<br /> Stop_FTP_Monitor(); //停止ftp监控timer</p> <p> Close_FTP_DataClient(); //关闭ftp数据通道<br /> Close_FTP(); //关闭ftp命令通道</p> <p> FTP_DATA_TIMEOUT_COUNT = 0;</p> <p> Create_FTP_Client(); //重新创建FTP<br /> }<br /> //FTP_DATA_TIMER_COUNTER ++;<br /> FTP_DATA_TIMEOUT_COUNT ++; //数据监控状态递增<br /> }</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: 关闭ftp数据传输监控 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-07 |<br /> //| |<br /> //| 返 回 值: void |<br /> //| |<br /> //| 参数说明: void<br /> //|<br /> //| |<br /> //+========================================================+<br /> void Stop_FTP_Monitor( void )<br /> {<br /> s8 sRet;<br /> #ifdef ftpDebug<br /> Debug_Printf("Stop_FTP_Monitor/r/n");<br /> #endif</p> <p> if ( ftp_data_tmr == NULL ) return;</p> <p> sRet = adl_tmrUnSubscribe( ftp_data_tmr, FTP_Monitor_Handle, ADL_TMR_TYPE_100MS );</p> <p> if( sRet > -1 ) //ftp monitor timer 停止成功<br /> {<br /> ftp_data_tmr = NULL; //如果撤销声明成功<br /> }<br /> #ifdef ftpDebug<br /> else{<br /> Debug_Printf("ftp monitor timer unsubscribe fail %d/r/n", sRet);<br /> }<br /> #endif<br /> }</p> <p>//+========================================================+<br /> //| |<br /> //| 程序用途: 启动ftp数据传输监控 |<br /> //| |<br /> //| 初次创建: 唐登安 2009-09-07 |<br /> //| |<br /> //| 返 回 值: void |<br /> //| |<br /> //| 参数说明: void<br /> //|<br /> //| |<br /> //+========================================================+<br /> void Start_FTP_Monitor( void )<br /> {<br /> #ifdef ftpDebug<br /> Debug_Printf("Start_FTP_Monitor/r/n");<br /> #endif<br /> if ( ftp_data_tmr != NULL ) return;<br /> ftp_data_tmr = adl_tmrSubscribe( TRUE, 10,ADL_TMR_TYPE_100MS, FTP_Monitor_Handle );<br /> }