📄 tcp.lst
字号:
C51 COMPILER V7.06 TCP 11/06/2008 08:54:10 PAGE 1
C51 COMPILER V7.06, COMPILATION OF MODULE TCP
OBJECT MODULE PLACED IN .\TCP.obj
COMPILER INVOKED BY: C:\Keil\C51\BIN\C51.EXE ..\TCPIP\TCP.c BROWSE DEBUG OBJECTEXTEND PRINT(.\TCP.lst) OBJECT(.\TCP.obj)
stmt level source
1 #include "..\GloblDef\GloblDef.h"
2 #include "..\TCPIP\TCPIPmem.h"
3 #include "..\TCPIP\IP.h"
4 #include "..\TCPIP\Netif.h"
5 #include "..\TCPIP\TCP.h"
6
7 struct STCB DT_XDATA TCBPool[TCP_CONNECTION_MAX_NUM];
8 struct STCB DT_XDATA * DT_XDATA TCBFreeList; /* free list */
9 struct STCB DT_XDATA * DT_XDATA TCBList; /* tcb in use */
10
11 struct SPacketQueue DT_XDATA QPool[TCP_QUEUE_MAX_NUM];
12 struct SPacketQueue DT_XDATA * DT_XDATA QFreeList;
13
14 struct STCB DT_XDATA *TCPGetTCB() REENTRANT_SIG
15 {
16 1 struct STCB DT_XDATA * pTCB;
17 1 if((pTCB = TCBFreeList) != NULL)
18 1 {
19 2 TCBFreeList = TCBFreeList->pNext;
20 2 }
21 1 return pTCB;
22 1 }
23
24 void TCPInsertTCB(struct STCB DT_XDATA *pTCB) REENTRANT_SIG
25 {
26 1 pTCB->pNext = TCBList;
27 1 TCBList = pTCB;
28 1 }
29
30 struct SPacketQueue DT_XDATA * TCPGetQ() REENTRANT_SIG
31 {
32 1 struct SPacketQueue DT_XDATA * pQ;
33 1 if((pQ = QFreeList) != NULL)
34 1 {
35 2 QFreeList = QFreeList->pNext;
36 2 }
37 1 return pQ;
38 1 }
39
40 /* insert to the head of *ppQ. Q is a double link chain */
41 BOOL TCPInsertQ(struct SPacketQueue DT_XDATA * DT_XDATA * ppQ,struct SMemHead DT_XDATA *MemHead,
42 DWORD Seq) REENTRANT_SIG
43 {
44 1 struct SPacketQueue DT_XDATA *pNewQ;
45 1 struct SPacketQueue DT_XDATA *pQ;
46 1
47 1 /* allocate a queue to it */
48 1 if((pNewQ = TCPGetQ()) == NULL)
49 1 return FALSE;
50 1
51 1 /* write content */
52 1 pNewQ->Seq = Seq;
53 1 pNewQ->MemHead = MemHead;
54 1
55 1 /*
C51 COMPILER V7.06 TCP 11/06/2008 08:54:10 PAGE 2
56 1 * link in the queue
57 1 */
58 1
59 1 /* if is a empty queue */
60 1 if(*ppQ == NULL)
61 1 {
62 2 *ppQ = pNewQ;
63 2
64 2 /* pNext pPre point to itself when no others in queue */
65 2 pNewQ->pNext = pNewQ;
66 2 pNewQ->pPre = pNewQ;
67 2 }
68 1 else
69 1 {
70 2 pQ = *ppQ;
71 2
72 2 /* pNext link */
73 2 pNewQ->pNext = pQ->pNext;
74 2 pQ->pNext = pNewQ;
75 2
76 2 /* pPre link */
77 2 pNewQ->pNext->pPre = pNewQ;
78 2 pNewQ->pPre = pQ;
79 2 }
80 1 return TRUE;
81 1 }
82
83 /* move the last unit in queue outof queue,if the queue
84 is empty return FALSE.actrually last unit is *ppQ */
85 struct SPacketQueue DT_XDATA * TCPOutQ(struct SPacketQueue DT_XDATA * DT_XDATA * ppQ) REENTRANT_SIG
86 {
87 1 struct SPacketQueue DT_XDATA *pQ;
88 1
89 1 /* a empty queue? */
90 1 if((pQ = *ppQ) == NULL)
91 1 return NULL;
92 1
93 1 /* after remove it, the queue is empty? */
94 1 if(pQ->pNext == pQ)
95 1 *ppQ = NULL;
96 1 else
97 1 {
98 2 /* relink */
99 2 pQ->pPre->pNext = pQ->pNext;
100 2 pQ->pNext->pPre = pQ->pPre;
101 2
102 2 /* and the queue head *ppQ point to pQ->pPre */
103 2 *ppQ = pQ->pPre;
104 2 }
105 1
106 1 /* relaim it. link to QFreeList */
107 1 pQ->pNext = QFreeList;
108 1 QFreeList = pQ;
109 1 return pQ;
110 1 }
111
112 void TCPInit() REENTRANT_MUL
113 {
114 1 WORD i;
115 1
116 1 /* move TCBPool to TCBFreeList */
117 1 for(i = 0, TCBFreeList = NULL; i<TCP_CONNECTION_MAX_NUM; i++)
C51 COMPILER V7.06 TCP 11/06/2008 08:54:10 PAGE 3
118 1 {
119 2 TCBPool[i].pNext = TCBFreeList;
120 2 TCBFreeList = &TCBPool[i];
121 2 }
122 1
123 1 /* move QPool to QFreeList */
124 1 for(i = 0, QFreeList = NULL; i<TCP_QUEUE_MAX_NUM; i++)
125 1 {
126 2 QPool[i].pNext = QFreeList;
127 2 QFreeList = &QPool[i];
128 2 }
129 1
130 1 TCBList = NULL;
131 1 }
132
133
134 /* tcp check sum. return check sum. TCPSize = TCPDataSize + TCPHeadSize*/
135 WORD TCPCheckSum(struct SIPHead DT_XDATA * pIPHead,WORD TCPSize) REENTRANT_SIG
136 {
137 1 DWORD sum = 0;
138 1 WORD DT_XDATA * p;
139 1 BYTE i;
140 1
141 1 /* clac pseudo-header CheckSum. pseudo-header is:
142 1 source ip, destination ip, pad 8 bits, protocol, TCP lendth */
143 1 sum = 0;
144 1
145 1 /* source ip and dest ip */
146 1 p = (WORD DT_XDATA *)(&(pIPHead->IPScr));
147 1 for(i=0; i < sizeof(DWORD)/sizeof(WORD)*2; i++,p++)
148 1 sum += *p;
149 1
150 1 /* pad 8 and protocol */
151 1 sum += pIPHead->Protocol;
152 1
153 1 /* tcp lendth */
154 1 sum += TCPSize;
155 1
156 1 return CheckSum((WORD DT_XDATA *)((BYTE DT_XDATA *)pIPHead + IP_HEAD_MIN_LEN),TCPSize,sum);
157 1 }
158
159 /* this funtion should be called periodically */
160 void TCPTimer() REENTRANT_MUL
161 {
162 1 struct STCB DT_XDATA *pTCB;
163 1
164 1 /* go through all tcbs to see if any time out */
165 1 for(pTCB = TCBList; pTCB != NULL; pTCB = pTCB->pNext)
166 1 {
167 2 /* delayed ack need send now? */
168 2 if(pTCB->bNeedAck == TRUE)
169 2 {
170 3 if(pTCB->DelayAckTimer == 0)
171 3 {
172 4 /* send a ack. bNeedAck will set FLASE in TCPOutput*/
173 4 TCPSendSeg(pTCB,TCPAllocate(0),TCP_ACK);
174 4 }
175 3 else
176 3 pTCB->DelayAckTimer--;
177 3 }
178 2
179 2 /* TCP_STATE_LASTACK TCP_STATE_TIMEWAIT state time out? */
C51 COMPILER V7.06 TCP 11/06/2008 08:54:10 PAGE 4
180 2 if(pTCB->TCPState == TCP_STATE_LASTACK ||
181 2 pTCB->TCPState == TCP_STATE_TIMEWAIT)
182 2 {
183 3 if(pTCB->LastAckTimer == 0)
184 3 {
185 4 pTCB->TCPState = TCP_STATE_CLOSED;
186 4
187 4 /* release buf queue and call user close */
188 4 TCPRelease(pTCB);
189 4 /* let pTCB->close(); to be call when they send a fin when we at established */
190 4 }
191 3 else
192 3 pTCB->LastAckTimer--;
193 3 }
194 2
195 2 /* if retransmit timer out? */
196 2 if(pTCB->QUnacked != NULL)
197 2 {
198 3 if(pTCB->RetranTimer == 0)
199 3 {
200 4 /* retransmit,pStart set to tcpdata */
201 4 IPOutput(pTCB->QUnacked->MemHead);
202 4
203 4 /* timer restart and retransmit times inc */
204 4 if(pTCB->RetranTimes == TCP_RETRAN_MAX_TIME)
205 4 {
206 5 pTCB->TCPState = TCP_STATE_CLOSED;
207 5
208 5 /* closed by countpart shut down */
209 5 TCPRelease(pTCB);
210 5 }
211 4 else
212 4 {
213 5 pTCB->RetranTimes++;
214 5 pTCB->RetranTimer = TCP_RETRAN_TIME_OUT;
215 5 }
216 4 }
217 3 else
218 3 pTCB->RetranTimer--;
219 3 }
220 2 }
221 1 }
222 /* when a TCP close, send too much packet but no replay,
223 connection fail. TCPIP will call TCPRelease to release packet
224 and queue, but will not reclaim TCB. in other word user
225 can use this socket again. */
226 void TCPRelease(struct STCB DT_XDATA *pTCB) REENTRANT_SIG
227 {
228 1 struct SPacketQueue DT_XDATA *pQ;
229 1
230 1 /* reclaim Q, and free packet in queue */
231 1 while(pQ = TCPOutQ(&(pTCB->QExceedSeq)))
232 1 MemFree(pQ->MemHead);
233 1 while(pQ = TCPOutQ(&(pTCB->QUnacked)))
234 1 MemFree(pQ->MemHead);
235 1 while(pQ = TCPOutQ(&(pTCB->QUnSend)))
236 1 MemFree(pQ->MemHead);
237 1 }
238
239 /* fill a segment and send it,NOTE MemHead->pStart point to TCPData */
240 BOOL TCPSendSeg(struct STCB DT_XDATA *pTCB,struct SMemHead DT_XDATA *MemHead,BYTE TCPFlag) REENTRANT_SIG
241 {
C51 COMPILER V7.06 TCP 11/06/2008 08:54:10 PAGE 5
242 1 struct STCPHead DT_XDATA *pTCPHead;
243 1 struct SIPHead DT_XDATA *pIPHead;
244 1 WORD SeqInc;
245 1
246 1 /* mem insufficient? */
247 1 if(MemHead == NULL)
248 1 return FALSE;
249 1
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -