📄 tcp.c
字号:
//Tcp_Close_Wait(num);
TcpStatus[num].State=TCP_STATE_LAST_ACK;
return(0);
}
temp=Tcp_Packed.Tcp.offset>>4;
temp=temp*4; //IP首部占20字节
temp=Tcp_Packed.TcpDHead.TotalLen-temp;//数据报总长度减去TCP和IP首部长度,得到数据长度
if((temp>0)&&(TcpStatus[num].Snd_Window>=temp))
{
if(Tcp_Packed.Tcp.SeqNum>=TcpStatus[num].RecFutureAck)//??
{
for(i=0;i<temp;i++)
{
/************把接收的数据放到接收缓冲区***************/
TcpStatus[num].TcpDataQ[TcpStatus[num].TcpDataQWrPtr]=Tcp_Packed.Tcp.tcpdata[i];
if(TcpStatus[num].TcpDataQWrPtr>=(MAX_TCP_DATA-1))
TcpStatus[num].TcpDataQWrPtr=0;
else
TcpStatus[num].TcpDataQWrPtr++;
}
TcpStatus[num].Snd_Window=TcpStatus[num].Snd_Window-temp;
TcpStatus[num].SenPassAck=TcpStatus[num].SenPassAck+temp;
}
if(Tcp_Packed.Tcp.control&TCP_ACK)
{//表示这是一个3次握手的确认
if((TcpStatus[num].SenPassSeq<=Tcp_Packed.Tcp.AckNum)
&&(Tcp_Packed.Tcp.AckNum<=TcpStatus[num].RecFutureAck))
{
TcpStatus[num].RecPassAck=Tcp_Packed.Tcp.AckNum;//确认
//if(Resend_Buff.TcpFrame.SeqNum<TCP1024.Sent_UnAck);
}
TcpStatus[num].RecPassSeq=Tcp_Packed.Tcp.SeqNum;
TcpStatus[num].SenPassSeq=Tcp_Packed.Tcp.AckNum;
TcpStatus[num].SenFutureSeq=TcpStatus[num].SenFutureSeq;
TcpStatus[num].RecFutureAck=TcpStatus[num].SenPassSeq;
TcpHeadHandle(num ,0x5010);//headlength 0x20 , ack
TcpStatus[num].TcpDHeadUint8[2]=0;
TcpStatus[num].TcpDHeadUint8[3]=20;
Tcp_Packed.TcpDHead.TotalLen=20;
Tcp_Packed.Tcp.Crc=CheckSumTcp1(num,32);//12+28
TcpStatus[num].TcpHeadUint8[16]=(Tcp_Packed.Tcp.Crc&0xff00)>>8;;
TcpStatus[num].TcpHeadUint8[17]=Tcp_Packed.Tcp.Crc&0x00ff;
TxdData.STPTR=NULL;
TxdData.length=20;
TxdData.DAPTR=TcpStatus[num].TcpHeadUint8;
Send_Ip_Frame
(
&TxdData,
TcpStatus[num].Dest_Ip,
TcpStatus[num].My_Ip,
6
);
}
return (1);
}
else if(((Tcp_Packed.Tcp.control&TCP_ACK)==TCP_ACK)&&(temp>0))
{
TcpStatus[num].RecPassSeq=Tcp_Packed.Tcp.SeqNum;
TcpStatus[num].SenPassSeq=Tcp_Packed.Tcp.AckNum;
TcpStatus[num].SenFutureSeq=TcpStatus[num].SenFutureSeq;
TcpStatus[num].RecFutureAck=TcpStatus[num].SenPassSeq;
TcpHeadHandle(num ,0x5010);//headlength 0x20 , ack
TcpStatus[num].TcpDHeadUint8[2]=0;
TcpStatus[num].TcpDHeadUint8[3]=20;
Tcp_Packed.TcpDHead.TotalLen=20;
Tcp_Packed.Tcp.Crc=CheckSumTcp1(num,32);//12+28
TcpStatus[num].TcpHeadUint8[16]=(Tcp_Packed.Tcp.Crc&0xff00)>>8;;
TcpStatus[num].TcpHeadUint8[17]=Tcp_Packed.Tcp.Crc&0x00ff;
TxdData.STPTR=NULL;
TxdData.length=20;
TxdData.DAPTR=TcpStatus[num].TcpHeadUint8;
Send_Ip_Frame
(
&TxdData,
TcpStatus[num].Dest_Ip,
TcpStatus[num].My_Ip,
6
);
}
else if(((Tcp_Packed.Tcp.control&TCP_ACK)==TCP_ACK)&&(temp==0))
{//表示这是一个3次握手的确认
if((TcpStatus[num].SenPassSeq<=Tcp_Packed.Tcp.AckNum)
&&(Tcp_Packed.Tcp.AckNum<=TcpStatus[num].RecFutureAck))
{
TcpStatus[num].RecPassAck=Tcp_Packed.Tcp.AckNum;//确认
if((TcpStatus[num].StaSem&0x01)==0x01)
{
TcpStatus[num].StaSem=TcpStatus[num].StaSem&0xFE;
OSSemPost(AppSemSend[num]);
}
return (2);
}
return (3);
}
return (4);
}
void TCP_FIN_WAIT1(uint8 num)
{
if(Tcp_Packed.Tcp.control&(TCP_ACK))
{
TcpStatus[num].RecPassSeq=Tcp_Packed.Tcp.SeqNum;
TcpStatus[num].RecPassAck=Tcp_Packed.Tcp.AckNum;
TcpStatus[num].RecFutureAck=TcpStatus[num].RecPassAck;
TcpStatus[num].State=TCP_STATE_FIN_WAIT2;
}
else
OSSemPost(AppSemDisc[num]);
}
void TCP_FIN_WAIT2(uint8 num)
{
struct _pkst TxdData;
if(Tcp_Packed.Tcp.control&(TCP_FIN))
{
TcpStatus[num].RecPassSeq=Tcp_Packed.Tcp.SeqNum;
TcpStatus[num].RecPassAck=Tcp_Packed.Tcp.AckNum;
TcpStatus[num].SenPassSeq=TcpStatus[num].RecPassAck;
TcpStatus[num].SenPassAck=TcpStatus[num].RecPassSeq+1;
TcpHeadHandle(num ,0x5000+TCP_ACK);//headlength 0x20,
TcpStatus[num].TcpDHeadUint8[2]=0;
TcpStatus[num].TcpDHeadUint8[3]=20;
Tcp_Packed.TcpDHead.TotalLen=20;
Tcp_Packed.Tcp.Crc=CheckSumTcp1(num,32);//12+28
TcpStatus[num].TcpHeadUint8[16]=(Tcp_Packed.Tcp.Crc&0xff00)>>8;;
TcpStatus[num].TcpHeadUint8[17]=Tcp_Packed.Tcp.Crc&0x00ff;
TxdData.STPTR=NULL;
TxdData.length=20;
TxdData.DAPTR=TcpStatus[num].TcpHeadUint8;
Send_Ip_Frame
(
&TxdData,
TcpStatus[num].Dest_Ip,
TcpStatus[num].My_Ip,
6
);
}
OSSemPost(AppSemDisc[num]);
}
uint8 Process_Tcp1(Rec_Ptr * Tcp_Rec)
{
uint8 i,j;
uint8 * temp_ptr;
struct _pkst TxdData;
j=j;//去除编译警告
if((*Tcp_Rec).length<=(MAX_TCP_DATA+20))
{
OS_ENTER_CRITICAL();
memcpy (&(Tcp_Packed.Tcp), (*Tcp_Rec).RecDataPtr, (*Tcp_Rec).length);
OS_EXIT_CRITICAL();
}
else
{
return 0;
}
temp_ptr=(uint8 *)&(Tcp_Packed.Tcp);
Tcp_Packed.Tcp.SourcePort=Char2ToInt16(temp_ptr);
temp_ptr=temp_ptr+2;
Tcp_Packed.Tcp.DestPort=Char2ToInt16(temp_ptr);
temp_ptr=temp_ptr+2;
Tcp_Packed.Tcp.SeqNum=Char4ToInt32(temp_ptr);
temp_ptr=temp_ptr+4;
Tcp_Packed.Tcp.AckNum=Char4ToInt32(temp_ptr);
temp_ptr=temp_ptr+4;
temp_ptr=temp_ptr+2;
Tcp_Packed.Tcp.window=Char2ToInt16(temp_ptr);
temp_ptr=temp_ptr+4;
Tcp_Packed.Tcp.urg=Char2ToInt16(temp_ptr);
i=0;
j=MAX_TCP_LINKS;
Tcp_Packed.TcpDHead.TotalLen=(*Tcp_Rec).length;
for(i=0;i<MAX_TCP_LINKS;i++)
{
if(TcpStatus[i].State>=TCP_STATE_SYN_RCVD)//已经建立的连接
{
if(TcpStatus[i].Dest_Ip[0]==((Rec_Ptr*)Tcp_Rec)->ip[0])
if(TcpStatus[i].Dest_Ip[1]==((Rec_Ptr*)Tcp_Rec)->ip[1])
if(TcpStatus[i].Dest_Ip[2]==((Rec_Ptr*)Tcp_Rec)->ip[2])
if(TcpStatus[i].Dest_Ip[3]==((Rec_Ptr*)Tcp_Rec)->ip[3])
if(TcpStatus[i].My_Ip[0]==((Rec_Ptr*)Tcp_Rec)->My_Ip[0])
if(TcpStatus[i].My_Ip[1]==((Rec_Ptr*)Tcp_Rec)->My_Ip[1])
if(TcpStatus[i].My_Ip[2]==((Rec_Ptr*)Tcp_Rec)->My_Ip[2])
if(TcpStatus[i].My_Ip[3]==((Rec_Ptr*)Tcp_Rec)->My_Ip[3])
if(Tcp_Packed.Tcp.DestPort==TcpStatus[i].My_Port)
if(Tcp_Packed.Tcp.SourcePort==TcpStatus[i].Dest_Port)
{
break;
}
}
}
if(i<MAX_TCP_LINKS)
{
switch (TcpStatus[i].State)
{
case 1: //Tcp_Listen(i);
break;
case 2: Tcp_SYN_Rec(i);
break;
case 3: Tcp_SYN_Sent(i);
break;
case 4: Tcp_Established(i);
break;
case 5: TCP_FIN_WAIT1(i);
break;
case 6: TCP_FIN_WAIT2(i);
break;
case 8: //Tcp_Close_Wait();
break;
case 9: Tcp_Last_Ack(i);//关闭
break;
}
return (2);
}
else
{
for(i=0;i<MAX_TCP_LINKS;i++)
{
if(TcpStatus[i].My_Ip[0]==((Rec_Ptr*)Tcp_Rec)->My_Ip[0])
if(TcpStatus[i].My_Ip[1]==((Rec_Ptr*)Tcp_Rec)->My_Ip[1])
if(TcpStatus[i].My_Ip[2]==((Rec_Ptr*)Tcp_Rec)->My_Ip[2])
if(TcpStatus[i].My_Ip[3]==((Rec_Ptr*)Tcp_Rec)->My_Ip[3])
if(Tcp_Packed.Tcp.DestPort==TcpStatus[i].My_Port)
if(TcpStatus[i].State==TCP_STATE_LISTEN)
{
break;
}
}
if(i<MAX_TCP_LINKS)
{
TcpStatus[i].Dest_Ip[0]=((Rec_Ptr*)Tcp_Rec)->ip[0];
TcpStatus[i].Dest_Ip[1]=((Rec_Ptr*)Tcp_Rec)->ip[1];
TcpStatus[i].Dest_Ip[2]=((Rec_Ptr*)Tcp_Rec)->ip[2];
TcpStatus[i].Dest_Ip[3]=((Rec_Ptr*)Tcp_Rec)->ip[3];
Tcp_Listen(i);
return (2);
}
else
{
Tcp_Packed.TcpDHead.TotalLen=0x14;
Tcp_Packed.TcpDHead.rev=0;
Tcp_Packed.TcpDHead.NextProtocal=6;
Tcp_Packed.TcpDHead.SourceIp[0]=((Rec_Ptr*)Tcp_Rec)->My_Ip[0];
Tcp_Packed.TcpDHead.SourceIp[1]=((Rec_Ptr*)Tcp_Rec)->My_Ip[1];
Tcp_Packed.TcpDHead.SourceIp[2]=((Rec_Ptr*)Tcp_Rec)->My_Ip[2];
Tcp_Packed.TcpDHead.SourceIp[3]=((Rec_Ptr*)Tcp_Rec)->My_Ip[3];
Tcp_Packed.TcpDHead.DestId[0]=((Rec_Ptr*)Tcp_Rec)->ip[0];
Tcp_Packed.TcpDHead.DestId[1]=((Rec_Ptr*)Tcp_Rec)->ip[1];
Tcp_Packed.TcpDHead.DestId[2]=((Rec_Ptr*)Tcp_Rec)->ip[2];
Tcp_Packed.TcpDHead.DestId[3]=((Rec_Ptr*)Tcp_Rec)->ip[3];
#ifdef Little_End
Tcp_Packed.TcpDHead.TotalLen=0x1400;
Tcp_Packed.Tcp.SourcePort=swap_int16(Tcp_Packed.Tcp.SourcePort);
Tcp_Packed.Tcp.DestPort=swap_int16(Tcp_Packed.Tcp.DestPort);
#endif
Tcp_Packed.Tcp.Crc=Tcp_Packed.Tcp.DestPort;
Tcp_Packed.Tcp.DestPort=Tcp_Packed.Tcp.SourcePort;
Tcp_Packed.Tcp.SourcePort=Tcp_Packed.Tcp.Crc;
Tcp_Packed.Tcp.Crc=0;
Tcp_Packed.Tcp.AckNum=Tcp_Packed.Tcp.SeqNum+1;
#ifdef Little_End
Tcp_Packed.Tcp.AckNum=swap_int32(Tcp_Packed.Tcp.AckNum);
#endif
Tcp_Packed.Tcp.SeqNum=0;
Tcp_Packed.Tcp.offset=0x50;
Tcp_Packed.Tcp.control=0x14;
Tcp_Packed.Tcp.window=0;
Tcp_Packed.Tcp.urg=0;
Tcp_Packed.Tcp.Crc=CheckSumUdp((uint8 *)&Tcp_Packed,32);
#ifdef Little_End
Tcp_Packed.Tcp.Crc=swap_int16(Tcp_Packed.Tcp.Crc);
#endif
TxdData.STPTR=NULL;
TxdData.length=20;
TxdData.DAPTR=(uint8 *)&Tcp_Packed.Tcp;
Send_Ip_Frame
(
&TxdData,
Tcp_Packed.TcpDHead.DestId,
Tcp_Packed.TcpDHead.SourceIp,
6
);
return (1);
}
}
}
void TcpHeadHandle(uint8 num ,uint16 Tcp_headlength_Control)
{
TcpStatus[num].TcpHeadUint8[0]=(TcpStatus[num].My_Port&0xff00)>>8;
TcpStatus[num].TcpHeadUint8[1]=TcpStatus[num].My_Port&0x00ff;
TcpStatus[num].TcpHeadUint8[2]=(TcpStatus[num].Dest_Port&0xff00)>>8;
TcpStatus[num].TcpHeadUint8[3]=TcpStatus[num].Dest_Port&0x00ff;
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);
TcpStatus[num].TcpHeadUint8[8]=(TcpStatus[num].SenPassAck&0xff000000)>>24;
TcpStatus[num].TcpHeadUint8[9]=(TcpStatus[num].SenPassAck&0x00ff0000)>>16;
TcpStatus[num].TcpHeadUint8[10]=(TcpStatus[num].SenPassAck&0x0000ff00)>>8;
TcpStatus[num].TcpHeadUint8[11]=(TcpStatus[num].SenPassAck&0x000000ff);
TcpStatus[num].TcpHeadUint8[12]=(Tcp_headlength_Control&0xff00)>>8;
TcpStatus[num].TcpHeadUint8[13]=Tcp_headlength_Control&0x00ff;
TcpStatus[num].TcpHeadUint8[14]=(TcpStatus[num].Snd_Window&0xff00)>>8;
TcpStatus[num].TcpHeadUint8[15]=TcpStatus[num].Snd_Window&0x00ff;
TcpStatus[num].TcpHeadUint8[16]=0;
TcpStatus[num].TcpHeadUint8[17]=0;
TcpStatus[num].TcpHeadUint8[18]=0;
TcpStatus[num].TcpHeadUint8[19]=0;
TcpStatus[num].TcpDHeadUint8[0]=0;
TcpStatus[num].TcpDHeadUint8[1]=6;
TcpStatus[num].TcpDHeadUint8[4]=TcpStatus[num].My_Ip[0];
TcpStatus[num].TcpDHeadUint8[5]=TcpStatus[num].My_Ip[1];
TcpStatus[num].TcpDHeadUint8[6]=TcpStatus[num].My_Ip[2];
TcpStatus[num].TcpDHeadUint8[7]=TcpStatus[num].My_Ip[3];
TcpStatus[num].TcpDHeadUint8[8]=TcpStatus[num].Dest_Ip[0];
TcpStatus[num].TcpDHeadUint8[9]=TcpStatus[num].Dest_Ip[1];
TcpStatus[num].TcpDHeadUint8[10]=TcpStatus[num].Dest_Ip[2];
TcpStatus[num].TcpDHeadUint8[11]=TcpStatus[num].Dest_Ip[3];
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -