基于LPC2132的ZLG的IP协议包，包括SOCKET，UDP以及TCP协议等.zip

#define TCP_GLOBALS #include "config.h" #include "../include/cfg_net.h" OS_EVENT *AppSemSend[MAX_TCP_LINKS]; OS_EVENT *AppSemCon[MAX_TCP_LINKS]; OS_EVENT *AppSemDisc[MAX_TCP_LINKS]; struct Socket_Type TcpStatus[MAX_TCP_LINKS]; tcp_send Tcp_Packed; /********************************************************************** **函数原型: unsigned int CheckSum(unsigned int xdata *check,unsigned int length) **入口参数:� check : 被校验数据起始地址 length : 被校验数据长度，单位字 **出口参数: 无 **返 回 值: ~((sum)&0xffff)) **说 明: 计算校验和 ************************************************************************/ //================================================================================= uint16 CheckSumTcp1(uint8 num,uint16 length) { uint32 sum=0; uint16 i; for (i=0;i<6;i++) { sum = sum + ((uint32)TcpStatus[num].TcpDHeadUint8[2*i]<<8)+(uint32)TcpStatus[num].TcpDHeadUint8[2*i+1]; } length=length-12; i=0; while(i<(length/2)) { sum = sum + ((uint32)TcpStatus[num].TcpHeadUint8[2*i]<<8)+(uint32)TcpStatus[num].TcpHeadUint8[2*i+1]; i++; } if(length&0x0001)//长度为奇数个时，要进行该操作 { //sum = sum + (uint32)(TcpStatus[num].TcpHeadUint8[2*i])<<8; sum = sum + (uint32)(TcpStatus[num].TcpHeadUint8[2*i])*256; } sum = (sum&0x0000ffff) + ((sum>>16)&0x0000ffff);//高16位和低16位相加 if(sum & 0xffff0000) {//表示有进位 sum++; if(sum & 0xffff0000) {//表示有进位 sum++; } } return ( (uint16)(~((sum)&0xffff)) ); } void Tcp_Initial(void) { uint8 i; for(i=0;i<MAX_TCP_LINKS;i++) { TcpStatus[i].Dest_Port=0; TcpStatus[i].My_Port=0; TcpStatus[i].State=TCP_STATE_CLOSED; TcpStatus[i].StaSem=0; TcpStatus[i].Send_Next=0; TcpStatus[i].ResendTime=0; TcpStatus[i].ResendState=0; TcpStatus[i].RecPassSeq=0; TcpStatus[i].SenPassSeq=0; TcpStatus[i].SenFutureSeq=0; TcpStatus[i].RecPassAck=0; TcpStatus[i].SenPassAck=0; TcpStatus[i].RecFutureAck=0; TcpStatus[i].Snd_Window=MAX_TCP_DATA; TcpStatus[i].TcpDataQWrPtr=0; TcpStatus[i].TcpDataQRdPtr=0; AppSemSend[i]= OSSemCreate(0); AppSemCon[i]= OSSemCreate(0); AppSemDisc[i]= OSSemCreate(0); } Tcp_Packed.TcpDHead.rev=0; Tcp_Packed.TcpDHead.NextProtocal=6; } /********************************************************************** **函数原型： void Send_Reset() **入口参数: 无 **出口参数: 无 **返 回 值: 无 **功能说明: 发送TCP_RST数据报文,复位对方连接 ******************************************************************/ void Send_Reset(uint8 num) { uint16 i; struct _pkst TxdData; i=Tcp_Packed.Tcp.SourcePort; Tcp_Packed.Tcp.SourcePort=Tcp_Packed.Tcp.DestPort; Tcp_Packed.Tcp.DestPort=i; Tcp_Packed.Tcp.offset=0x50; Tcp_Packed.Tcp.window=TcpStatus[num].Snd_Window; Tcp_Packed.Tcp.urg=0; Tcp_Packed.Tcp.Crc=0; /* Tcp_Packed.Tcp.tcpdata[0]=0X02; Tcp_Packed.Tcp.tcpdata[1]=0X04; Tcp_Packed.Tcp.tcpdata[2]=MAX_TCP_DATA/256; Tcp_Packed.Tcp.tcpdata[3]=MAX_TCP_DATA%256; Tcp_Packed.Tcp.tcpdata[4]=0X01; Tcp_Packed.Tcp.tcpdata[5]=0X01; Tcp_Packed.Tcp.tcpdata[6]=0X01; Tcp_Packed.Tcp.tcpdata[7]=0X01;*/ //*********添加TCP假头**********// Tcp_Packed.TcpDHead.rev=0; Tcp_Packed.TcpDHead.NextProtocal=6; Tcp_Packed.TcpDHead.TotalLen=20; //Tcp_Packed.Tcp.Crc=CheckSumTcp((uint16 EX_RAM *)&Tcp_Packed,Tcp_Packed.TcpDHead.TotalLen+12); TxdData.STPTR=NULL; TxdData.length=Tcp_Packed.TcpDHead.TotalLen; TxdData.DAPTR=(uint8 EX_RAM *)&Tcp_Packed.Tcp; Send_Ip_Frame ( &TxdData, TcpStatus[num].Dest_Ip, TcpStatus[num].My_Ip, 6 ); //memcpy (&(TcpStatus[num].resend_data),&(Tcp_Packed.Tcp) , Tcp_Packed.TcpDHead.TotalLen); TcpStatus[num].ResendLength=Tcp_Packed.TcpDHead.TotalLen; } /********************************************************************** **函数原型： void Delete_Socket() **入口参数: 无 **出口参数: 无 **返 回 值： 无 **功能说明: 撤销本地连接，并清空重发缓冲区 ******************************************************************/ void Delete_Socket(uint8 num) { uint16 i; OS_ENTER_CRITICAL(); if((TcpStatus[num].StaSem&0x80)==0x80) { TcpStatus[num].State=TCP_STATE_LISTEN; TcpStatus[num].StaSem=0x82; } else { TcpStatus[num].State=TCP_STATE_CLOSED; TcpStatus[num].StaSem=0; TcpStatus[num].My_Port=0; TcpStatus[num].My_Ip[0]=0; TcpStatus[num].My_Ip[1]=0; TcpStatus[num].My_Ip[2]=0; TcpStatus[num].My_Ip[3]=0; } do { i=OSSemAccept(AppSemCon[num]); }while(i!=0); do { i=OSSemAccept(AppSemSend[num]); }while(i!=0); do { i=OSSemAccept(AppSemDisc[num]); }while(i!=0); TcpStatus[num].RecPassSeq=0; TcpStatus[num].RecPassAck=0; TcpStatus[num].SenPassSeq=0; TcpStatus[num].SenPassAck=0; TcpStatus[num].RecFutureAck=0; TcpStatus[num].SenFutureSeq=0; TcpStatus[num].ResendState=0;//表示该重发缓冲区没有数据 TcpStatus[num].ResendTime=0; TcpStatus[num].Dest_Port=0; TcpStatus[num].Dest_Ip[0]=0; TcpStatus[num].Dest_Ip[1]=0; TcpStatus[num].Dest_Ip[2]=0; TcpStatus[num].Dest_Ip[3]=0; TcpStatus[num].TcpDataQWrPtr=0; TcpStatus[num].TcpDataQRdPtr=0; OS_EXIT_CRITICAL(); } void Tcp_Listen(uint8 num) { static uint32 initalseq=32451; struct _pkst TxdData; if(Tcp_Packed.Tcp.control&TCP_SYN) { TcpStatus[num].State=TCP_STATE_SYN_RCVD;//TCP_STATE_SYN_RCVD;//Tcp_SYN_Rec; //TcpStatus[num].Dest_Ip[0]=Tcp_Packed.TcpDHead.DestId[0]; //TcpStatus[num].Dest_Ip[1]=Tcp_Packed.TcpDHead.DestId[1]; //TcpStatus[num].Dest_Ip[2]=Tcp_Packed.TcpDHead.DestId[2]; //TcpStatus[num].Dest_Ip[3]=Tcp_Packed.TcpDHead.DestId[3]; TcpStatus[num].Dest_Port=Tcp_Packed.Tcp.SourcePort;//对方端口 //TcpStatus[num].My_Port=Tcp_Packed.Tcp.DestPort; TcpStatus[num].IRS=Tcp_Packed.Tcp.SeqNum;//对方的初始化顺序号 TcpStatus[num].RecPassSeq=Tcp_Packed.Tcp.SeqNum; TcpStatus[num].RecPassAck=0; TcpStatus[num].SenPassSeq=initalseq; TcpStatus[num].SenPassAck=TcpStatus[num].RecPassSeq+1; TcpStatus[num].RecFutureAck=initalseq+1; TcpStatus[num].SenFutureSeq=initalseq+1; TcpStatus[num].Rcv_Next=Tcp_Packed.Tcp.SeqNum+1;//对方的顺序号,用于确认 TcpStatus[num].ISS=TcpStatus[num].Send_Next;//我的初始化顺序号 TcpStatus[num].Sent_UnAck=TcpStatus[num].ISS;//我的未确认得序号 TcpStatus[num].Send_Next=TcpStatus[num].ISS+1;//我的顺序号,用于发送 TcpStatus[num].My_Wl1=Tcp_Packed.Tcp.SeqNum;//seq TcpStatus[num].My_Wl2=TcpStatus[num].Send_Next; TcpStatus[num].Rcv_Window=Tcp_Packed.Tcp.window;//对方的WINDOW大小 TcpStatus[num].Snd_Window=MAX_TCP_DATA;//通知对方本地最大接收1024字节的包,用于流控 TcpStatus[num].Dest_Max_Seg_Size=MAX_TCP_DATA;//默认为560 if(Tcp_Packed.Tcp.offset>50) if(Tcp_Packed.Tcp.tcpdata[0]==0x02) if(Tcp_Packed.Tcp.tcpdata[1]==0x04) //0204为最大segment选项 { TcpStatus[num].Dest_Max_Seg_Size=Tcp_Packed.Tcp.tcpdata[2]*256+Tcp_Packed.Tcp.tcpdata[3]; } TcpStatus[num].My_Max_Seg_Size=MAX_TCP_DATA;//本地机可以接受最大的以太网数据包 //********************************************// TcpStatus[num].TcpHeadUint8[0]=(TcpStatus[num].My_Port&0xff00)>>8; TcpStatus[num].TcpHeadUint8[1]=TcpStatus[num].My_Port&0x00ff; Tcp_Packed.Tcp.SourcePort=TcpStatus[num].My_Port; TcpStatus[num].TcpHeadUint8[2]=(TcpStatus[num].Dest_Port&0xff00)>>8; TcpStatus[num].TcpHeadUint8[3]=TcpStatus[num].Dest_Port&0x00ff; Tcp_Packed.Tcp.DestPort=TcpStatus[num].Dest_Port; TcpStatus[num].TcpHeadUint8[4]=(TcpStatus[num].SenPassSeq&0xff000000)>>24; TcpStatus[num].TcpHeadUint8[5]=(TcpStatus[num].SenPassSeq&0x00ff0000)>>16; TcpStatus[num].TcpHeadUint8[6]=(TcpStatus[num].SenPassSeq&0x0000ff00)>>8; TcpStatus[num].TcpHeadUint8[7]=(TcpStatus[num].SenPassSeq&0x000000ff); Tcp_Packed.Tcp.SeqNum=TcpStatus[num].ISS; TcpStatus[num].TcpHeadUint8[8]=(TcpStatus[num].SenPassAck&0xff000000)>>24; TcpStatus[num].TcpHeadUint8[9]=(TcpStatus[num].SenPassAck&0x00ff0000)>>16; TcpStatus[num].TcpHeadUint8[10]=(TcpStatus[num].SenPass