]> git.proxmox.com Git - mirror_edk2.git/blame - MdeModulePkg/Universal/Network/Tcp4Dxe/Tcp4Dispatcher.c
projects / mirror_edk2.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
Refine the comments in PciSegmentLib
[mirror_edk2.git] / MdeModulePkg / Universal / Network / Tcp4Dxe / Tcp4Dispatcher.c
CommitLineData
8a67d61d 1/** @file\r
2\r
3Copyright (c) 2005 - 2006, Intel Corporation\r
4All rights reserved. This program and the accompanying materials\r
5are licensed and made available under the terms and conditions of the BSD License\r
6which accompanies this distribution. The full text of the license may be found at\r
7http://opensource.org/licenses/bsd-license.php\r
8\r
9THE PROGRAM IS DISTRIBUTED UNDER THE BSD LICENSE ON AN "AS IS" BASIS,\r
10WITHOUT WARRANTIES OR REPRESENTATIONS OF ANY KIND, EITHER EXPRESS OR IMPLIED.\r
11\r
12Module Name:\r
13\r
14 Tcp4Dispatcher.c\r
15\r
16Abstract:\r
17\r
18\r
19**/\r
20\r
21#include "Tcp4Main.h"\r
22\r
23#define TCP_COMP_VAL(Min, Max, Default, Val) \\r
24 ((((Val) <= (Max)) && ((Val) >= (Min))) ? (Val) : (Default))\r
25\r
8a67d61d 26EFI_STATUS\r
27Tcp4Route (\r
28 IN TCP_CB *Tcb,\r
29 IN TCP4_ROUTE_INFO *RouteInfo\r
30 )\r
31/*++\r
32\r
33Routine Description:\r
34\r
35 Add or remove a route entry in the IP route table associated\r
36 with this TCP instance.\r
37\r
38Arguments:\r
39\r
40 Tcb - Pointer to the TCP_CB of this TCP instance.\r
41 RouteInfo - Pointer to the route info to be processed.\r
42\r
43Returns:\r
44\r
45 EFI_SUCCESS - The operation completed successfully.\r
46 EFI_NOT_STARTED - The driver instance has not been started.\r
47 EFI_NO_MAPPING - When using the default address, configuration(DHCP,\r
48 BOOTP, RARP, etc.) is not finished yet.\r
49 EFI_OUT_OF_RESOURCES - Could not add the entry to the routing table.\r
50 EFI_NOT_FOUND - This route is not in the routing table\r
51 (when RouteInfo->DeleteRoute is TRUE).\r
52 EFI_ACCESS_DENIED - The route is already defined in the routing table\r
53 (when RouteInfo->DeleteRoute is FALSE).\r
54\r
55--*/\r
56{\r
57 EFI_IP4_PROTOCOL *Ip;\r
58\r
59 Ip = Tcb->IpInfo->Ip;\r
60\r
61 ASSERT (Ip);\r
62\r
63 return Ip->Routes (\r
64 Ip,\r
65 RouteInfo->DeleteRoute,\r
66 RouteInfo->SubnetAddress,\r
67 RouteInfo->SubnetMask,\r
68 RouteInfo->GatewayAddress\r
69 );\r
70\r
71}\r
72\r
73\r
74/**\r
75 Get the operational settings of this TCP instance.\r
76\r
77 @param Tcb Pointer to the TCP_CB of this TCP instance.\r
78 @param Mode Pointer to the buffer to store the operational\r
79 settings.\r
80\r
81 @retval EFI_SUCCESS The mode data is read.\r
82 @retval EFI_NOT_STARTED No configuration data is available because this\r
83 instance hasn't been started.\r
84\r
85**/\r
8a67d61d 86EFI_STATUS\r
87Tcp4GetMode (\r
88 IN TCP_CB *Tcb,\r
89 IN TCP4_MODE_DATA *Mode\r
90 )\r
91{\r
92 SOCKET *Sock;\r
93 EFI_TCP4_CONFIG_DATA *ConfigData;\r
94 EFI_TCP4_ACCESS_POINT *AccessPoint;\r
95 EFI_TCP4_OPTION *Option;\r
96 EFI_IP4_PROTOCOL *Ip;\r
97\r
98 Sock = Tcb->Sk;\r
99\r
100 if (!SOCK_IS_CONFIGURED (Sock) && (Mode->Tcp4ConfigData != NULL)) {\r
101 return EFI_NOT_STARTED;\r
102 }\r
103\r
104 if (Mode->Tcp4State) {\r
4eb65aff 105 *(Mode->Tcp4State) = (EFI_TCP4_CONNECTION_STATE) Tcb->State;\r
8a67d61d 106 }\r
107\r
108 if (Mode->Tcp4ConfigData) {\r
109\r
110 ConfigData = Mode->Tcp4ConfigData;\r
111 AccessPoint = &(ConfigData->AccessPoint);\r
112 Option = ConfigData->ControlOption;\r
113\r
114 ConfigData->TypeOfService = Tcb->TOS;\r
115 ConfigData->TimeToLive = Tcb->TTL;\r
116\r
117 AccessPoint->UseDefaultAddress = Tcb->UseDefaultAddr;\r
118\r
e48e37fc 119 CopyMem (&AccessPoint->StationAddress, &Tcb->LocalEnd.Ip, sizeof (EFI_IPv4_ADDRESS));\r
8a67d61d 120 AccessPoint->SubnetMask = Tcb->SubnetMask;\r
121 AccessPoint->StationPort = NTOHS (Tcb->LocalEnd.Port);\r
122\r
e48e37fc 123 CopyMem (&AccessPoint->RemoteAddress, &Tcb->RemoteEnd.Ip, sizeof (EFI_IPv4_ADDRESS));\r
8a67d61d 124 AccessPoint->RemotePort = NTOHS (Tcb->RemoteEnd.Port);\r
125 AccessPoint->ActiveFlag = (BOOLEAN) (Tcb->State != TCP_LISTEN);\r
126\r
127 if (Option != NULL) {\r
128 Option->ReceiveBufferSize = GET_RCV_BUFFSIZE (Tcb->Sk);\r
129 Option->SendBufferSize = GET_SND_BUFFSIZE (Tcb->Sk);\r
130 Option->MaxSynBackLog = GET_BACKLOG (Tcb->Sk);\r
131\r
132 Option->ConnectionTimeout = Tcb->ConnectTimeout / TCP_TICK_HZ;\r
133 Option->DataRetries = Tcb->MaxRexmit;\r
134 Option->FinTimeout = Tcb->FinWait2Timeout / TCP_TICK_HZ;\r
135 Option->TimeWaitTimeout = Tcb->TimeWaitTimeout / TCP_TICK_HZ;\r
136 Option->KeepAliveProbes = Tcb->MaxKeepAlive;\r
137 Option->KeepAliveTime = Tcb->KeepAliveIdle / TCP_TICK_HZ;\r
138 Option->KeepAliveInterval = Tcb->KeepAlivePeriod / TCP_TICK_HZ;\r
139\r
4eb65aff 140 Option->EnableNagle = (BOOLEAN) (!TCP_FLG_ON (Tcb->CtrlFlag, TCP_CTRL_NO_NAGLE));\r
141 Option->EnableTimeStamp = (BOOLEAN) (!TCP_FLG_ON (Tcb->CtrlFlag, TCP_CTRL_NO_TS));\r
ed66e1bc 142 Option->EnableWindowScaling = (BOOLEAN) (!TCP_FLG_ON (Tcb->CtrlFlag, TCP_CTRL_NO_WS));\r
8a67d61d 143\r
144 Option->EnableSelectiveAck = FALSE;\r
145 Option->EnablePathMtuDiscovery = FALSE;\r
146 }\r
147 }\r
148\r
149 Ip = Tcb->IpInfo->Ip;\r
150 ASSERT (Ip);\r
151\r
152 return Ip->GetModeData (Ip, Mode->Ip4ModeData, Mode->MnpConfigData, Mode->SnpModeData);\r
153}\r
154\r
155\r
156/**\r
157 If AP->StationPort isn't zero, check whether the access point\r
158 is registered, else generate a random station port for this\r
159 access point.\r
160\r
161 @param AP Pointer to the access point.\r
162\r
163 @retval EFI_SUCCESS The check is passed or the port is assigned.\r
164 @retval EFI_INVALID_PARAMETER The non-zero station port is already used.\r
165 @retval EFI_OUT_OF_RESOURCES No port can be allocated.\r
166\r
167**/\r
8a67d61d 168EFI_STATUS\r
169Tcp4Bind (\r
170 IN EFI_TCP4_ACCESS_POINT *AP\r
171 )\r
172{\r
173 BOOLEAN Cycle;\r
174\r
175 if (0 != AP->StationPort) {\r
176 //\r
177 // check if a same endpoint is bound\r
178 //\r
179 if (TcpFindTcbByPeer (&AP->StationAddress, AP->StationPort)) {\r
180\r
181 return EFI_INVALID_PARAMETER;\r
182 }\r
183 } else {\r
184 //\r
185 // generate a random port\r
186 //\r
187 Cycle = FALSE;\r
188\r
189 if (TCP4_PORT_USER_RESERVED == mTcp4RandomPort) {\r
190 mTcp4RandomPort = TCP4_PORT_KNOWN;\r
191 }\r
192\r
193 mTcp4RandomPort++;\r
194\r
195 while (TcpFindTcbByPeer (&AP->StationAddress, mTcp4RandomPort)) {\r
196\r
197 mTcp4RandomPort++;\r
198\r
199 if (mTcp4RandomPort <= TCP4_PORT_KNOWN) {\r
200\r
201 if (Cycle) {\r
e48e37fc 202 DEBUG ((EFI_D_ERROR, "Tcp4Bind: no port can be allocated "\r
8a67d61d 203 "for this pcb\n"));\r
204\r
205 return EFI_OUT_OF_RESOURCES;\r
206 }\r
207\r
208 mTcp4RandomPort = TCP4_PORT_KNOWN + 1;\r
209\r
210 Cycle = TRUE;\r
211 }\r
212\r
213 }\r
214\r
215 AP->StationPort = mTcp4RandomPort;\r
216 }\r
217\r
218 return EFI_SUCCESS;\r
219}\r
220\r
221\r
222/**\r
223 Flush the Tcb add its associated protocols..\r
224\r
225 @param Tcb Pointer to the TCP_CB to be flushed.\r
226\r
227 @retval EFI_SUCCESS The operation is completed successfully.\r
228\r
229**/\r
8a67d61d 230VOID\r
231Tcp4FlushPcb (\r
232 IN TCP_CB *Tcb\r
233 )\r
234{\r
235 SOCKET *Sock;\r
236 TCP4_PROTO_DATA *TcpProto;\r
237\r
238 IpIoConfigIp (Tcb->IpInfo, NULL);\r
239\r
240 Sock = Tcb->Sk;\r
241 TcpProto = (TCP4_PROTO_DATA *) Sock->ProtoReserved;\r
242\r
243 if (SOCK_IS_CONFIGURED (Sock)) {\r
e48e37fc 244 RemoveEntryList (&Tcb->List);\r
8a67d61d 245\r
e5e12de7 246 //\r
247 // Uninstall the device path protocl.\r
248 //\r
249 gBS->UninstallProtocolInterface (\r
250 Sock->SockHandle,\r
251 &gEfiDevicePathProtocolGuid,\r
252 Sock->DevicePath\r
253 );\r
e48e37fc 254 gBS->FreePool (Sock->DevicePath);\r
e5e12de7 255\r
8a67d61d 256 TcpSetVariableData (TcpProto->TcpService);\r
257 }\r
258\r
259 NetbufFreeList (&Tcb->SndQue);\r
260 NetbufFreeList (&Tcb->RcvQue);\r
261}\r
262\r
8a67d61d 263EFI_STATUS\r
264Tcp4AttachPcb (\r
265 IN SOCKET *Sk\r
266 )\r
267{\r
268 TCP_CB *Tcb;\r
269 TCP4_PROTO_DATA *ProtoData;\r
270 IP_IO *IpIo;\r
271\r
e48e37fc 272 Tcb = AllocateZeroPool (sizeof (TCP_CB));\r
8a67d61d 273\r
274 if (Tcb == NULL) {\r
275\r
e48e37fc 276 DEBUG ((EFI_D_ERROR, "Tcp4ConfigurePcb: failed to allocate a TCB\n"));\r
8a67d61d 277\r
278 return EFI_OUT_OF_RESOURCES;\r
279 }\r
280\r
281 ProtoData = (TCP4_PROTO_DATA *) Sk->ProtoReserved;\r
282 IpIo = ProtoData->TcpService->IpIo;\r
283\r
284 //\r
285 // Create an IpInfo for this Tcb.\r
286 //\r
287 Tcb->IpInfo = IpIoAddIp (IpIo);\r
288 if (Tcb->IpInfo == NULL) {\r
289\r
e48e37fc 290 gBS->FreePool (Tcb);\r
8a67d61d 291 return EFI_OUT_OF_RESOURCES;\r
292 }\r
293\r
e48e37fc 294 InitializeListHead (&Tcb->List);\r
295 InitializeListHead (&Tcb->SndQue);\r
296 InitializeListHead (&Tcb->RcvQue);\r
8a67d61d 297\r
298 Tcb->State = TCP_CLOSED;\r
299 Tcb->Sk = Sk;\r
300 ProtoData->TcpPcb = Tcb;\r
301\r
302 return EFI_SUCCESS;\r
303}\r
304\r
8a67d61d 305VOID\r
306Tcp4DetachPcb (\r
307 IN SOCKET *Sk\r
308 )\r
309{\r
310 TCP4_PROTO_DATA *ProtoData;\r
311 TCP_CB *Tcb;\r
312\r
313 ProtoData = (TCP4_PROTO_DATA *) Sk->ProtoReserved;\r
314 Tcb = ProtoData->TcpPcb;\r
315\r
316 ASSERT (Tcb != NULL);\r
317\r
318 Tcp4FlushPcb (Tcb);\r
319\r
320 IpIoRemoveIp (ProtoData->TcpService->IpIo, Tcb->IpInfo);\r
321\r
e48e37fc 322 gBS->FreePool (Tcb);\r
8a67d61d 323\r
324 ProtoData->TcpPcb = NULL;\r
325}\r
326\r
327\r
328/**\r
329 Configure the Tcb using CfgData.\r
330\r
331 @param Sk Pointer to the socket of this TCP instance.\r
332 @param SkTcb Pointer to the TCP_CB of this TCP instance.\r
333 @param CfgData Pointer to the TCP configuration data.\r
334\r
335 @retval EFI_SUCCESS The operation is completed successfully.\r
336 @retval EFI_INVALID_PARAMETER A same access point has been configured in\r
337 another TCP instance.\r
338 @retval EFI_OUT_OF_RESOURCES Failed due to resource limit.\r
339\r
340**/\r
8a67d61d 341EFI_STATUS\r
342Tcp4ConfigurePcb (\r
343 IN SOCKET *Sk,\r
344 IN EFI_TCP4_CONFIG_DATA *CfgData\r
345 )\r
346{\r
8a67d61d 347 EFI_IP4_CONFIG_DATA IpCfgData;\r
348 EFI_STATUS Status;\r
349 EFI_TCP4_OPTION *Option;\r
350 TCP4_PROTO_DATA *TcpProto;\r
351 TCP_CB *Tcb;\r
352\r
353 ASSERT (CfgData && Sk && Sk->SockHandle);\r
354\r
355 TcpProto = (TCP4_PROTO_DATA *) Sk->ProtoReserved;\r
356 Tcb = TcpProto->TcpPcb;\r
8a67d61d 357\r
358 ASSERT (Tcb != NULL);\r
359\r
360 //\r
361 // Add Ip for send pkt to the peer\r
362 //\r
687a2e5f 363 CopyMem (&IpCfgData, &mIpIoDefaultIpConfigData, sizeof (IpCfgData));\r
8a67d61d 364 IpCfgData.DefaultProtocol = EFI_IP_PROTO_TCP;\r
365 IpCfgData.UseDefaultAddress = CfgData->AccessPoint.UseDefaultAddress;\r
366 IpCfgData.StationAddress = CfgData->AccessPoint.StationAddress;\r
367 IpCfgData.SubnetMask = CfgData->AccessPoint.SubnetMask;\r
368 IpCfgData.ReceiveTimeout = (UINT32) (-1);\r
369\r
370 //\r
371 // Configure the IP instance this Tcb consumes.\r
372 //\r
373 Status = IpIoConfigIp (Tcb->IpInfo, &IpCfgData);\r
374 if (EFI_ERROR (Status)) {\r
375 goto OnExit;\r
376 }\r
377\r
378 //\r
379 // Get the default address info if the instance is configured to use default address.\r
380 //\r
381 if (CfgData->AccessPoint.UseDefaultAddress) {\r
382 CfgData->AccessPoint.StationAddress = IpCfgData.StationAddress;\r
383 CfgData->AccessPoint.SubnetMask = IpCfgData.SubnetMask;\r
384 }\r
385\r
386 //\r
387 // check if we can bind this endpoint in CfgData\r
388 //\r
389 Status = Tcp4Bind (&(CfgData->AccessPoint));\r
390\r
391 if (EFI_ERROR (Status)) {\r
e48e37fc 392 DEBUG ((EFI_D_ERROR, "Tcp4ConfigurePcb: Bind endpoint failed "\r
8a67d61d 393 "with %r\n", Status));\r
394\r
395 goto OnExit;\r
396 }\r
397\r
398 //\r
399 // Initalize the operating information in this Tcb\r
400 //\r
401 ASSERT (Tcb->State == TCP_CLOSED &&\r
e48e37fc 402 IsListEmpty (&Tcb->SndQue) &&\r
403 IsListEmpty (&Tcb->RcvQue));\r
8a67d61d 404\r
405 TCP_SET_FLG (Tcb->CtrlFlag, TCP_CTRL_NO_KEEPALIVE);\r
406 Tcb->State = TCP_CLOSED;\r
407\r
408 Tcb->SndMss = 536;\r
409 Tcb->RcvMss = TcpGetRcvMss (Sk);\r
410\r
411 Tcb->SRtt = 0;\r
412 Tcb->Rto = 3 * TCP_TICK_HZ;\r
413\r
414 Tcb->CWnd = Tcb->SndMss;\r
415 Tcb->Ssthresh = 0xffffffff;\r
416\r
417 Tcb->CongestState = TCP_CONGEST_OPEN;\r
418\r
419 Tcb->KeepAliveIdle = TCP_KEEPALIVE_IDLE_MIN;\r
420 Tcb->KeepAlivePeriod = TCP_KEEPALIVE_PERIOD;\r
421 Tcb->MaxKeepAlive = TCP_MAX_KEEPALIVE;\r
422 Tcb->MaxRexmit = TCP_MAX_LOSS;\r
423 Tcb->FinWait2Timeout = TCP_FIN_WAIT2_TIME;\r
424 Tcb->TimeWaitTimeout = TCP_TIME_WAIT_TIME;\r
425 Tcb->ConnectTimeout = TCP_CONNECT_TIME;\r
426\r
427 //\r
428 // initialize Tcb in the light of CfgData\r
429 //\r
430 Tcb->TTL = CfgData->TimeToLive;\r
431 Tcb->TOS = CfgData->TypeOfService;\r
432\r
e5e12de7 433 Tcb->UseDefaultAddr = CfgData->AccessPoint.UseDefaultAddress;\r
434\r
e48e37fc 435 CopyMem (&Tcb->LocalEnd.Ip, &CfgData->AccessPoint.StationAddress, sizeof (IP4_ADDR));\r
8a67d61d 436 Tcb->LocalEnd.Port = HTONS (CfgData->AccessPoint.StationPort);\r
437 Tcb->SubnetMask = CfgData->AccessPoint.SubnetMask;\r
438\r
e5e12de7 439 if (CfgData->AccessPoint.ActiveFlag) {\r
e48e37fc 440 CopyMem (&Tcb->RemoteEnd.Ip, &CfgData->AccessPoint.RemoteAddress, sizeof (IP4_ADDR));\r
e5e12de7 441 Tcb->RemoteEnd.Port = HTONS (CfgData->AccessPoint.RemotePort);\r
442 } else {\r
443 Tcb->RemoteEnd.Ip = 0;\r
444 Tcb->RemoteEnd.Port = 0;\r
445 }\r
8a67d61d 446\r
447 Option = CfgData->ControlOption;\r
448\r
449 if (Option != NULL) {\r
450 SET_RCV_BUFFSIZE (\r
451 Sk,\r
4eb65aff 452 (UINT32) (TCP_COMP_VAL (\r
453 TCP_RCV_BUF_SIZE_MIN,\r
454 TCP_RCV_BUF_SIZE,\r
455 TCP_RCV_BUF_SIZE,\r
456 Option->ReceiveBufferSize\r
457 )\r
458 )\r
8a67d61d 459 );\r
460 SET_SND_BUFFSIZE (\r
461 Sk,\r
4eb65aff 462 (UINT32) (TCP_COMP_VAL (\r
463 TCP_SND_BUF_SIZE_MIN,\r
464 TCP_SND_BUF_SIZE,\r
465 TCP_SND_BUF_SIZE,\r
466 Option->SendBufferSize\r
467 )\r
468 )\r
8a67d61d 469 );\r
470\r
471 SET_BACKLOG (\r
472 Sk,\r
4eb65aff 473 (UINT32) (TCP_COMP_VAL (\r
474 TCP_BACKLOG_MIN,\r
475 TCP_BACKLOG,\r
476 TCP_BACKLOG,\r
477 Option->MaxSynBackLog\r
478 )\r
479 )\r
8a67d61d 480 );\r
481\r
482 Tcb->MaxRexmit = (UINT16) TCP_COMP_VAL (\r
483 TCP_MAX_LOSS_MIN,\r
484 TCP_MAX_LOSS,\r
485 TCP_MAX_LOSS,\r
486 Option->DataRetries\r
487 );\r
488 Tcb->FinWait2Timeout = TCP_COMP_VAL (\r
489 TCP_FIN_WAIT2_TIME,\r
490 TCP_FIN_WAIT2_TIME_MAX,\r
491 TCP_FIN_WAIT2_TIME,\r
4eb65aff 492 (UINT32) (Option->FinTimeout * TCP_TICK_HZ)\r
8a67d61d 493 );\r
494\r
495 if (Option->TimeWaitTimeout != 0) {\r
496 Tcb->TimeWaitTimeout = TCP_COMP_VAL (\r
497 TCP_TIME_WAIT_TIME,\r
498 TCP_TIME_WAIT_TIME_MAX,\r
499 TCP_TIME_WAIT_TIME,\r
4eb65aff 500 (UINT32) (Option->TimeWaitTimeout * TCP_TICK_HZ)\r
8a67d61d 501 );\r
502 } else {\r
503 Tcb->TimeWaitTimeout = 0;\r
504 }\r
505\r
506 if (Option->KeepAliveProbes != 0) {\r
507 TCP_CLEAR_FLG (Tcb->CtrlFlag, TCP_CTRL_NO_KEEPALIVE);\r
508\r
509 Tcb->MaxKeepAlive = (UINT8) TCP_COMP_VAL (\r
510 TCP_MAX_KEEPALIVE_MIN,\r
511 TCP_MAX_KEEPALIVE,\r
512 TCP_MAX_KEEPALIVE,\r
513 Option->KeepAliveProbes\r
514 );\r
515 Tcb->KeepAliveIdle = TCP_COMP_VAL (\r
516 TCP_KEEPALIVE_IDLE_MIN,\r
517 TCP_KEEPALIVE_IDLE_MAX,\r
518 TCP_KEEPALIVE_IDLE_MIN,\r
4eb65aff 519 (UINT32) (Option->KeepAliveTime * TCP_TICK_HZ)\r
8a67d61d 520 );\r
521 Tcb->KeepAlivePeriod = TCP_COMP_VAL (\r
522 TCP_KEEPALIVE_PERIOD_MIN,\r
523 TCP_KEEPALIVE_PERIOD,\r
524 TCP_KEEPALIVE_PERIOD,\r
4eb65aff 525 (UINT32) (Option->KeepAliveInterval * TCP_TICK_HZ)\r
8a67d61d 526 );\r
527 }\r
528\r
529 Tcb->ConnectTimeout = TCP_COMP_VAL (\r
530 TCP_CONNECT_TIME_MIN,\r
531 TCP_CONNECT_TIME,\r
532 TCP_CONNECT_TIME,\r
4eb65aff 533 (UINT32) (Option->ConnectionTimeout * TCP_TICK_HZ)\r
8a67d61d 534 );\r
535\r
536 if (Option->EnableNagle == FALSE) {\r
537 TCP_SET_FLG (Tcb->CtrlFlag, TCP_CTRL_NO_NAGLE);\r
538 }\r
539\r
540 if (Option->EnableTimeStamp == FALSE) {\r
541 TCP_SET_FLG (Tcb->CtrlFlag, TCP_CTRL_NO_TS);\r
542 }\r
543\r
544 if (Option->EnableWindowScaling == FALSE) {\r
545 TCP_SET_FLG (Tcb->CtrlFlag, TCP_CTRL_NO_WS);\r
546 }\r
547 }\r
548\r
e5e12de7 549 //\r
550 // The socket is bound, the <SrcIp, SrcPort, DstIp, DstPort> is\r
551 // determined, construct the IP device path and install it.\r
552 //\r
553 Status = TcpInstallDevicePath (Sk);\r
554 if (EFI_ERROR (Status)) {\r
555 goto OnExit;\r
556 }\r
557\r
8a67d61d 558 //\r
559 // update state of Tcb and socket\r
560 //\r
561 if (CfgData->AccessPoint.ActiveFlag == FALSE) {\r
562\r
563 TcpSetState (Tcb, TCP_LISTEN);\r
564 SockSetState (Sk, SO_LISTENING);\r
565\r
566 Sk->ConfigureState = SO_CONFIGURED_PASSIVE;\r
567 } else {\r
568\r
569 Sk->ConfigureState = SO_CONFIGURED_ACTIVE;\r
570 }\r
571\r
572 TcpInsertTcb (Tcb);\r
573\r
574OnExit:\r
575\r
576 return Status;\r
577}\r
578\r
579\r
580/**\r
581 The procotol handler provided to the socket layer, used to\r
582 dispatch the socket level requests by calling the corresponding\r
583 TCP layer functions.\r
584\r
585 @param Sock Pointer to the socket of this TCP instance.\r
586 @param Request The code of this operation request.\r
587 @param Data Pointer to the operation specific data passed in\r
588 together with the operation request.\r
589\r
590 @retval EFI_SUCCESS The socket request is completed successfully.\r
591 @retval other The error status returned by the corresponding TCP\r
592 layer function.\r
593\r
594**/\r
595EFI_STATUS\r
596Tcp4Dispatcher (\r
597 IN SOCKET *Sock,\r
598 IN SOCK_REQUEST Request,\r
599 IN VOID *Data OPTIONAL\r
600 )\r
601{\r
602 TCP_CB *Tcb;\r
603 TCP4_PROTO_DATA *ProtoData;\r
604 EFI_IP4_PROTOCOL *Ip;\r
605\r
606 ProtoData = (TCP4_PROTO_DATA *) Sock->ProtoReserved;\r
607 Tcb = ProtoData->TcpPcb;\r
608\r
609 switch (Request) {\r
610 case SOCK_POLL:\r
611 Ip = ProtoData->TcpService->IpIo->Ip;\r
612 Ip->Poll (Ip);\r
613 break;\r
614\r
615 case SOCK_CONSUMED:\r
616 //\r
617 // After user received data from socket buffer, socket will\r
618 // notify TCP using this message to give it a chance to send out\r
619 // window update information\r
620 //\r
621 ASSERT (Tcb);\r
622 TcpOnAppConsume (Tcb);\r
623 break;\r
624\r
625 case SOCK_SND:\r
626\r
627 ASSERT (Tcb);\r
628 TcpOnAppSend (Tcb);\r
629 break;\r
630\r
631 case SOCK_CLOSE:\r
632\r
633 TcpOnAppClose (Tcb);\r
634\r
635 break;\r
636\r
637 case SOCK_ABORT:\r
638\r
639 TcpOnAppAbort (Tcb);\r
640\r
641 break;\r
642\r
643 case SOCK_SNDPUSH:\r
644 Tcb->SndPsh = TcpGetMaxSndNxt (Tcb) + GET_SND_DATASIZE (Tcb->Sk);\r
645 TCP_SET_FLG (Tcb->CtrlFlag, TCP_CTRL_SND_PSH);\r
646\r
647 break;\r
648\r
649 case SOCK_SNDURG:\r
650 Tcb->SndUp = TcpGetMaxSndNxt (Tcb) + GET_SND_DATASIZE (Tcb->Sk) - 1;\r
651 TCP_SET_FLG (Tcb->CtrlFlag, TCP_CTRL_SND_URG);\r
652\r
653 break;\r
654\r
655 case SOCK_CONNECT:\r
656\r
657 TcpOnAppConnect (Tcb);\r
658\r
659 break;\r
660\r
661 case SOCK_ATTACH:\r
662\r
663 return Tcp4AttachPcb (Sock);\r
664\r
665 break;\r
666\r
667 case SOCK_FLUSH:\r
668\r
669 Tcp4FlushPcb (Tcb);\r
670\r
671 break;\r
672\r
673 case SOCK_DETACH:\r
674\r
675 Tcp4DetachPcb (Sock);\r
676\r
677 break;\r
678\r
679 case SOCK_CONFIGURE:\r
680\r
681 return Tcp4ConfigurePcb (\r
682 Sock,\r
683 (EFI_TCP4_CONFIG_DATA *) Data\r
684 );\r
685\r
686 break;\r
687\r
688 case SOCK_MODE:\r
689\r
690 ASSERT (Data && Tcb);\r
691\r
692 return Tcp4GetMode (Tcb, (TCP4_MODE_DATA *) Data);\r
693\r
694 break;\r
695\r
696 case SOCK_ROUTE:\r
697\r
698 ASSERT (Data && Tcb);\r
699\r
700 return Tcp4Route (Tcb, (TCP4_ROUTE_INFO *) Data);\r
701\r
b61439a7 702 default:\r
703 return EFI_UNSUPPORTED;\r
8a67d61d 704 }\r
705\r
706 return EFI_SUCCESS;\r
707\r
708}\r
EFI Development Kit II mirror for PVE