]> git.proxmox.com Git - mirror_edk2.git/blame_incremental - MdeModulePkg/Universal/Network/Tcp4Dxe/SockInterface.c
Update modules to show real dependencies on the BaseMemoryLib and MemoryAllocationLib
[mirror_edk2.git] / MdeModulePkg / Universal / Network / Tcp4Dxe / SockInterface.c
... / ...
CommitLineData
1/** @file\r
2 Interface function of the Socket.\r
3\r
4Copyright (c) 2005 - 2006, Intel Corporation<BR>\r
5All rights reserved. This program and the accompanying materials\r
6are licensed and made available under the terms and conditions of the BSD License\r
7which accompanies this distribution. The full text of the license may be found at\r
8http://opensource.org/licenses/bsd-license.php<BR>\r
9\r
10THE PROGRAM IS DISTRIBUTED UNDER THE BSD LICENSE ON AN "AS IS" BASIS,\r
11WITHOUT WARRANTIES OR REPRESENTATIONS OF ANY KIND, EITHER EXPRESS OR IMPLIED.\r
12\r
13**/\r
14\r
15\r
16#include "SockImpl.h"\r
17\r
18\r
19/**\r
20 Check whether the Event is in the List.\r
21\r
22 @param List Pointer to the token list to be searched.\r
23 @param Event The event to be checked.\r
24\r
25 @retval TRUE The specific Event exists in the List. \r
26 @retval FALSE The specific Event is not in the List.\r
27\r
28**/\r
29BOOLEAN\r
30SockTokenExistedInList (\r
31 IN LIST_ENTRY *List,\r
32 IN EFI_EVENT Event\r
33 )\r
34{\r
35 LIST_ENTRY *ListEntry;\r
36 SOCK_TOKEN *SockToken;\r
37\r
38 NET_LIST_FOR_EACH (ListEntry, List) {\r
39 SockToken = NET_LIST_USER_STRUCT (\r
40 ListEntry,\r
41 SOCK_TOKEN,\r
42 TokenList\r
43 );\r
44\r
45 if (Event == SockToken->Token->Event) {\r
46 return TRUE;\r
47 }\r
48 }\r
49\r
50 return FALSE;\r
51}\r
52\r
53\r
54/**\r
55 Call SockTokenExistedInList() to check whether the Event is\r
56 in the related socket's lists.\r
57\r
58 @param Sock Pointer to the instance's socket.\r
59 @param Event The event to be checked.\r
60\r
61 @retval TRUE The Event exists in related socket's lists. \r
62 @retval FALSE The Event is not in related socket's lists.\r
63\r
64**/\r
65BOOLEAN\r
66SockTokenExisted (\r
67 IN SOCKET *Sock,\r
68 IN EFI_EVENT Event\r
69 )\r
70{\r
71\r
72 if (SockTokenExistedInList (&Sock->SndTokenList, Event) ||\r
73 SockTokenExistedInList (&Sock->ProcessingSndTokenList, Event) ||\r
74 SockTokenExistedInList (&Sock->RcvTokenList, Event) ||\r
75 SockTokenExistedInList (&Sock->ListenTokenList, Event)) {\r
76\r
77 return TRUE;\r
78 }\r
79\r
80 if ((Sock->ConnectionToken != NULL) &&\r
81 (Sock->ConnectionToken->Event == Event)) {\r
82\r
83 return TRUE;\r
84 }\r
85\r
86 if ((Sock->CloseToken != NULL) && (Sock->CloseToken->Event == Event)) {\r
87 return TRUE;\r
88 }\r
89\r
90 return FALSE;\r
91}\r
92\r
93\r
94/**\r
95 Buffer a token into the specific list of socket Sock.\r
96\r
97 @param Sock Pointer to the instance's socket.\r
98 @param List Pointer to the list to store the token.\r
99 @param Token Pointer to the token to be buffered.\r
100 @param DataLen The data length of the buffer contained in Token.\r
101\r
102 @return Pointer to the token that wraps Token. If NULL, error condition occurred.\r
103\r
104**/\r
105SOCK_TOKEN *\r
106SockBufferToken (\r
107 IN SOCKET *Sock,\r
108 IN LIST_ENTRY *List,\r
109 IN VOID *Token,\r
110 IN UINT32 DataLen\r
111 )\r
112{\r
113 SOCK_TOKEN *SockToken;\r
114\r
115 SockToken = AllocatePool (sizeof (SOCK_TOKEN));\r
116 if (NULL == SockToken) {\r
117\r
118 DEBUG ((EFI_D_ERROR, "SockBufferIOToken: No Memory "\r
119 "to allocate SockToken\n"));\r
120\r
121 return NULL;\r
122 }\r
123\r
124 SockToken->Sock = Sock;\r
125 SockToken->Token = (SOCK_COMPLETION_TOKEN *) Token;\r
126 SockToken->RemainDataLen = DataLen;\r
127 InsertTailList (List, &SockToken->TokenList);\r
128\r
129 return SockToken;\r
130}\r
131\r
132\r
133/**\r
134 Destory the socket Sock and its associated protocol control block.\r
135\r
136 @param Sock The socket to be destroyed.\r
137\r
138 @retval EFI_SUCCESS The socket Sock is destroyed successfully.\r
139 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket.\r
140\r
141**/\r
142EFI_STATUS\r
143SockDestroyChild (\r
144 IN SOCKET *Sock\r
145 )\r
146{\r
147 EFI_STATUS Status;\r
148\r
149 ASSERT ((Sock != NULL) && (Sock->ProtoHandler != NULL));\r
150\r
151 if (Sock->IsDestroyed) {\r
152 return EFI_SUCCESS;\r
153 }\r
154\r
155 Sock->IsDestroyed = TRUE;\r
156\r
157 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
158 if (EFI_ERROR (Status)) {\r
159\r
160 DEBUG ((EFI_D_ERROR, "SockDestroyChild: Get the lock to "\r
161 "access socket failed with %r\n", Status));\r
162\r
163 return EFI_ACCESS_DENIED;\r
164 }\r
165\r
166 //\r
167 // force protocol layer to detach the PCB\r
168 //\r
169 Status = Sock->ProtoHandler (Sock, SOCK_DETACH, NULL);\r
170\r
171 if (EFI_ERROR (Status)) {\r
172\r
173 DEBUG ((EFI_D_ERROR, "SockDestroyChild: Protocol detach socket"\r
174 " failed with %r\n", Status));\r
175\r
176 Sock->IsDestroyed = FALSE;\r
177 } else if (SOCK_IS_CONFIGURED (Sock)) {\r
178\r
179 SockConnFlush (Sock);\r
180 SockSetState (Sock, SO_CLOSED);\r
181\r
182 Sock->ConfigureState = SO_UNCONFIGURED;\r
183 }\r
184\r
185 EfiReleaseLock (&(Sock->Lock));\r
186\r
187 if (EFI_ERROR (Status)) {\r
188 return Status;\r
189 }\r
190\r
191 SockDestroy (Sock);\r
192 return EFI_SUCCESS;\r
193}\r
194\r
195\r
196/**\r
197 Create a socket and its associated protocol control block\r
198 with the intial data SockInitData and protocol specific\r
199 data ProtoData.\r
200\r
201 @param SockInitData Inital data to setting the socket.\r
202 \r
203 @return Pointer to the newly created socket. If NULL, error condition occured.\r
204\r
205**/\r
206SOCKET *\r
207SockCreateChild (\r
208 IN SOCK_INIT_DATA *SockInitData\r
209 )\r
210{\r
211 SOCKET *Sock;\r
212 EFI_STATUS Status;\r
213\r
214 //\r
215 // create a new socket\r
216 //\r
217 Sock = SockCreate (SockInitData);\r
218 if (NULL == Sock) {\r
219\r
220 DEBUG ((EFI_D_ERROR, "SockCreateChild: No resource to "\r
221 "create a new socket\n"));\r
222\r
223 return NULL;\r
224 }\r
225\r
226 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
227 if (EFI_ERROR (Status)) {\r
228\r
229 DEBUG ((EFI_D_ERROR, "SockCreateChild: Get the lock to "\r
230 "access socket failed with %r\n", Status));\r
231\r
232 SockDestroy (Sock);\r
233 return NULL;\r
234 }\r
235 //\r
236 // inform the protocol layer to attach the socket\r
237 // with a new protocol control block\r
238 //\r
239 Status = Sock->ProtoHandler (Sock, SOCK_ATTACH, NULL);\r
240 if (EFI_ERROR (Status)) {\r
241\r
242 DEBUG ((EFI_D_ERROR, "SockCreateChild: Protocol failed to"\r
243 " attach a socket with %r\n", Status));\r
244\r
245 SockDestroy (Sock);\r
246 Sock = NULL;\r
247 }\r
248\r
249 EfiReleaseLock (&(Sock->Lock));\r
250 return Sock;\r
251}\r
252\r
253\r
254/**\r
255 Configure the specific socket Sock using configuration data ConfigData.\r
256\r
257 @param Sock Pointer to the socket to be configured.\r
258 @param ConfigData Pointer to the configuration data.\r
259\r
260 @retval EFI_SUCCESS The socket is configured successfully.\r
261 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket or the\r
262 socket is already configured.\r
263\r
264**/\r
265EFI_STATUS\r
266SockConfigure (\r
267 IN SOCKET *Sock,\r
268 IN VOID *ConfigData\r
269 )\r
270{\r
271 EFI_STATUS Status;\r
272\r
273 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
274 if (EFI_ERROR (Status)) {\r
275\r
276 DEBUG ((EFI_D_ERROR, "SockConfigure: Get the access for "\r
277 "socket failed with %r", Status));\r
278\r
279 return EFI_ACCESS_DENIED;\r
280 }\r
281\r
282 if (SOCK_IS_CONFIGURED (Sock)) {\r
283 Status = EFI_ACCESS_DENIED;\r
284 goto OnExit;\r
285 }\r
286\r
287 ASSERT (Sock->State == SO_CLOSED);\r
288\r
289 Status = Sock->ProtoHandler (Sock, SOCK_CONFIGURE, ConfigData);\r
290\r
291OnExit:\r
292 EfiReleaseLock (&(Sock->Lock));\r
293\r
294 return Status;\r
295}\r
296\r
297\r
298/**\r
299 Initiate a connection establishment process.\r
300\r
301 @param Sock Pointer to the socket to initiate the initate the\r
302 connection.\r
303 @param Token Pointer to the token used for the connection\r
304 operation.\r
305\r
306 @retval EFI_SUCCESS The connection is initialized successfully.\r
307 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket, or the\r
308 socket is closed, or the socket is not configured to\r
309 be an active one, or the token is already in one of\r
310 this socket's lists.\r
311 @retval EFI_NO_MAPPING The IP address configuration operation is not\r
312 finished.\r
313 @retval EFI_NOT_STARTED The socket is not configured.\r
314\r
315**/\r
316EFI_STATUS\r
317SockConnect (\r
318 IN SOCKET *Sock,\r
319 IN VOID *Token\r
320 )\r
321{\r
322 EFI_STATUS Status;\r
323 EFI_EVENT Event;\r
324\r
325 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
326 if (EFI_ERROR (Status)) {\r
327\r
328 DEBUG ((EFI_D_ERROR, "SockConnect: Get the access for "\r
329 "socket failed with %r", Status));\r
330\r
331 return EFI_ACCESS_DENIED;\r
332 }\r
333\r
334 if (SOCK_IS_NO_MAPPING (Sock)) {\r
335 Status = EFI_NO_MAPPING;\r
336 goto OnExit;\r
337 }\r
338\r
339 if (SOCK_IS_UNCONFIGURED (Sock)) {\r
340\r
341 Status = EFI_NOT_STARTED;\r
342 goto OnExit;\r
343 }\r
344\r
345 if (!SOCK_IS_CLOSED (Sock) || !SOCK_IS_CONFIGURED_ACTIVE (Sock)) {\r
346\r
347 Status = EFI_ACCESS_DENIED;\r
348 goto OnExit;\r
349 }\r
350\r
351 Event = ((SOCK_COMPLETION_TOKEN *) Token)->Event;\r
352\r
353 if (SockTokenExisted (Sock, Event)) {\r
354\r
355 Status = EFI_ACCESS_DENIED;\r
356 goto OnExit;\r
357 }\r
358\r
359 Sock->ConnectionToken = (SOCK_COMPLETION_TOKEN *) Token;\r
360 SockSetState (Sock, SO_CONNECTING);\r
361 Status = Sock->ProtoHandler (Sock, SOCK_CONNECT, NULL);\r
362\r
363OnExit:\r
364 EfiReleaseLock (&(Sock->Lock));\r
365 return Status;\r
366}\r
367\r
368\r
369/**\r
370 Issue a listen token to get an existed connected network instance\r
371 or wait for a connection if there is none.\r
372\r
373 @param Sock Pointer to the socket to accept connections.\r
374 @param Token The token to accept a connection.\r
375\r
376 @retval EFI_SUCCESS Either a connection is accpeted or the Token is\r
377 buffered for further acception.\r
378 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket, or the\r
379 socket is closed, or the socket is not configured to\r
380 be a passive one, or the token is already in one of\r
381 this socket's lists.\r
382 @retval EFI_NO_MAPPING The IP address configuration operation is not\r
383 finished.\r
384 @retval EFI_NOT_STARTED The socket is not configured.\r
385 @retval EFI_OUT_OF_RESOURCE Failed to buffer the Token due to memory limit.\r
386\r
387**/\r
388EFI_STATUS\r
389SockAccept (\r
390 IN SOCKET *Sock,\r
391 IN VOID *Token\r
392 )\r
393{\r
394 EFI_TCP4_LISTEN_TOKEN *ListenToken;\r
395 LIST_ENTRY *ListEntry;\r
396 EFI_STATUS Status;\r
397 SOCKET *Socket;\r
398 EFI_EVENT Event;\r
399\r
400 ASSERT (SOCK_STREAM == Sock->Type);\r
401\r
402 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
403 if (EFI_ERROR (Status)) {\r
404\r
405 DEBUG ((EFI_D_ERROR, "SockAccept: Get the access for socket"\r
406 " failed with %r", Status));\r
407\r
408 return EFI_ACCESS_DENIED;\r
409 }\r
410\r
411 if (SOCK_IS_NO_MAPPING (Sock)) {\r
412 Status = EFI_NO_MAPPING;\r
413 goto Exit;\r
414 }\r
415\r
416 if (SOCK_IS_UNCONFIGURED (Sock)) {\r
417\r
418 Status = EFI_NOT_STARTED;\r
419 goto Exit;\r
420 }\r
421\r
422 if (!SOCK_IS_LISTENING (Sock)) {\r
423\r
424 Status = EFI_ACCESS_DENIED;\r
425 goto Exit;\r
426 }\r
427\r
428 Event = ((SOCK_COMPLETION_TOKEN *) Token)->Event;\r
429\r
430 if (SockTokenExisted (Sock, Event)) {\r
431\r
432 Status = EFI_ACCESS_DENIED;\r
433 goto Exit;\r
434 }\r
435\r
436 ListenToken = (EFI_TCP4_LISTEN_TOKEN *) Token;\r
437\r
438 //\r
439 // Check if a connection has already in this Sock->ConnectionList\r
440 //\r
441 NET_LIST_FOR_EACH (ListEntry, &Sock->ConnectionList) {\r
442\r
443 Socket = NET_LIST_USER_STRUCT (ListEntry, SOCKET, ConnectionList);\r
444\r
445 if (SOCK_IS_CONNECTED (Socket)) {\r
446 ListenToken->NewChildHandle = Socket->SockHandle;\r
447 SIGNAL_TOKEN (&(ListenToken->CompletionToken), EFI_SUCCESS);\r
448\r
449 RemoveEntryList (ListEntry);\r
450\r
451 ASSERT (Socket->Parent != NULL);\r
452\r
453 Socket->Parent->ConnCnt--;\r
454\r
455 DEBUG (\r
456 (EFI_D_INFO,\r
457 "SockAccept: Accept a socket, now conncount is %d",\r
458 Socket->Parent->ConnCnt)\r
459 );\r
460 Socket->Parent = NULL;\r
461\r
462 goto Exit;\r
463 }\r
464 }\r
465\r
466 //\r
467 // Buffer this token for latter incoming connection request\r
468 //\r
469 if (NULL == SockBufferToken (Sock, &(Sock->ListenTokenList), Token, 0)) {\r
470\r
471 Status = EFI_OUT_OF_RESOURCES;\r
472 }\r
473\r
474Exit:\r
475 EfiReleaseLock (&(Sock->Lock));\r
476\r
477 return Status;\r
478}\r
479\r
480\r
481/**\r
482 Issue a token with data to the socket to send out.\r
483\r
484 @param Sock Pointer to the socket to process the token with\r
485 data.\r
486 @param Token The token with data that needs to send out.\r
487\r
488 @retval EFI_SUCCESS The token is processed successfully.\r
489 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket, or the\r
490 socket is closed, or the socket is not in a\r
491 synchronized state , or the token is already in one\r
492 of this socket's lists.\r
493 @retval EFI_NO_MAPPING The IP address configuration operation is not\r
494 finished.\r
495 @retval EFI_NOT_STARTED The socket is not configured.\r
496 @retval EFI_OUT_OF_RESOURCE Failed to buffer the token due to memory limit.\r
497\r
498**/\r
499EFI_STATUS\r
500SockSend (\r
501 IN SOCKET *Sock,\r
502 IN VOID *Token\r
503 )\r
504{\r
505 SOCK_IO_TOKEN *SndToken;\r
506 EFI_EVENT Event;\r
507 UINT32 FreeSpace;\r
508 EFI_TCP4_TRANSMIT_DATA *TxData;\r
509 EFI_STATUS Status;\r
510 SOCK_TOKEN *SockToken;\r
511 UINT32 DataLen;\r
512\r
513 ASSERT (SOCK_STREAM == Sock->Type);\r
514\r
515 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
516 if (EFI_ERROR (Status)) {\r
517\r
518 DEBUG ((EFI_D_ERROR, "SockSend: Get the access for socket"\r
519 " failed with %r", Status));\r
520\r
521 return EFI_ACCESS_DENIED;\r
522 }\r
523\r
524 if (SOCK_IS_NO_MAPPING (Sock)) {\r
525 Status = EFI_NO_MAPPING;\r
526 goto Exit;\r
527 }\r
528\r
529 SndToken = (SOCK_IO_TOKEN *) Token;\r
530 TxData = (EFI_TCP4_TRANSMIT_DATA *) SndToken->Packet.TxData;\r
531\r
532 if (SOCK_IS_UNCONFIGURED (Sock)) {\r
533 Status = EFI_NOT_STARTED;\r
534 goto Exit;\r
535 }\r
536\r
537 if (!(SOCK_IS_CONNECTING (Sock) || SOCK_IS_CONNECTED (Sock))) {\r
538\r
539 Status = EFI_ACCESS_DENIED;\r
540 goto Exit;\r
541 }\r
542\r
543 //\r
544 // check if a token is already in the token buffer\r
545 //\r
546 Event = SndToken->Token.Event;\r
547\r
548 if (SockTokenExisted (Sock, Event)) {\r
549 Status = EFI_ACCESS_DENIED;\r
550 goto Exit;\r
551 }\r
552\r
553 DataLen = (UINT32) TxData->DataLength;\r
554\r
555 //\r
556 // process this sending token now or buffer it only?\r
557 //\r
558 FreeSpace = SockGetFreeSpace (Sock, SOCK_SND_BUF);\r
559\r
560 if ((FreeSpace < Sock->SndBuffer.LowWater) || !SOCK_IS_CONNECTED (Sock)) {\r
561\r
562 SockToken = SockBufferToken (\r
563 Sock,\r
564 &Sock->SndTokenList,\r
565 SndToken,\r
566 DataLen\r
567 );\r
568\r
569 if (NULL == SockToken) {\r
570 Status = EFI_OUT_OF_RESOURCES;\r
571 }\r
572 } else {\r
573\r
574 SockToken = SockBufferToken (\r
575 Sock,\r
576 &Sock->ProcessingSndTokenList,\r
577 SndToken,\r
578 DataLen\r
579 );\r
580\r
581 if (NULL == SockToken) {\r
582 DEBUG ((EFI_D_ERROR, "SockSend: Failed to buffer IO token into"\r
583 " socket processing SndToken List\n", Status));\r
584\r
585 Status = EFI_OUT_OF_RESOURCES;\r
586 goto Exit;\r
587 }\r
588\r
589 Status = SockProcessTcpSndData (Sock, TxData);\r
590\r
591 if (EFI_ERROR (Status)) {\r
592 DEBUG ((EFI_D_ERROR, "SockSend: Failed to process "\r
593 "Snd Data\n", Status));\r
594\r
595 RemoveEntryList (&(SockToken->TokenList));\r
596 gBS->FreePool (SockToken);\r
597 }\r
598 }\r
599\r
600Exit:\r
601 EfiReleaseLock (&(Sock->Lock));\r
602 return Status;\r
603}\r
604\r
605\r
606/**\r
607 Issue a token to get data from the socket.\r
608\r
609 @param Sock Pointer to the socket to get data from.\r
610 @param Token The token to store the received data from the\r
611 socket.\r
612\r
613 @retval EFI_SUCCESS The token is processed successfully.\r
614 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket, or the\r
615 socket is closed, or the socket is not in a\r
616 synchronized state , or the token is already in one\r
617 of this socket's lists.\r
618 @retval EFI_NO_MAPPING The IP address configuration operation is not\r
619 finished.\r
620 @retval EFI_NOT_STARTED The socket is not configured.\r
621 @retval EFI_CONNECTION_FIN The connection is closed and there is no more data.\r
622 @retval EFI_OUT_OF_RESOURCE Failed to buffer the token due to memory limit.\r
623\r
624**/\r
625EFI_STATUS\r
626SockRcv (\r
627 IN SOCKET *Sock,\r
628 IN VOID *Token\r
629 )\r
630{\r
631 SOCK_IO_TOKEN *RcvToken;\r
632 UINT32 RcvdBytes;\r
633 EFI_STATUS Status;\r
634 EFI_EVENT Event;\r
635\r
636 ASSERT (SOCK_STREAM == Sock->Type);\r
637\r
638 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
639 if (EFI_ERROR (Status)) {\r
640\r
641 DEBUG ((EFI_D_ERROR, "SockRcv: Get the access for socket"\r
642 " failed with %r", Status));\r
643\r
644 return EFI_ACCESS_DENIED;\r
645 }\r
646\r
647 if (SOCK_IS_NO_MAPPING (Sock)) {\r
648\r
649 Status = EFI_NO_MAPPING;\r
650 goto Exit;\r
651 }\r
652\r
653 if (SOCK_IS_UNCONFIGURED (Sock)) {\r
654\r
655 Status = EFI_NOT_STARTED;\r
656 goto Exit;\r
657 }\r
658\r
659 if (!(SOCK_IS_CONNECTED (Sock) || SOCK_IS_CONNECTING (Sock))) {\r
660\r
661 Status = EFI_ACCESS_DENIED;\r
662 goto Exit;\r
663 }\r
664\r
665 RcvToken = (SOCK_IO_TOKEN *) Token;\r
666\r
667 //\r
668 // check if a token is already in the token buffer of this socket\r
669 //\r
670 Event = RcvToken->Token.Event;\r
671 if (SockTokenExisted (Sock, Event)) {\r
672 Status = EFI_ACCESS_DENIED;\r
673 goto Exit;\r
674 }\r
675\r
676 RcvToken = (SOCK_IO_TOKEN *) Token;\r
677 RcvdBytes = GET_RCV_DATASIZE (Sock);\r
678\r
679 //\r
680 // check whether an error has happened before\r
681 //\r
682 if (EFI_ABORTED != Sock->SockError) {\r
683\r
684 SIGNAL_TOKEN (&(RcvToken->Token), Sock->SockError);\r
685 Sock->SockError = EFI_ABORTED;\r
686 goto Exit;\r
687 }\r
688\r
689 //\r
690 // check whether can not receive and there is no any\r
691 // data buffered in Sock->RcvBuffer\r
692 //\r
693 if (SOCK_IS_NO_MORE_DATA (Sock) && (0 == RcvdBytes)) {\r
694\r
695 Status = EFI_CONNECTION_FIN;\r
696 goto Exit;\r
697 }\r
698\r
699 if (RcvdBytes != 0) {\r
700 Status = SockProcessRcvToken (Sock, RcvToken);\r
701\r
702 if (EFI_ERROR (Status)) {\r
703 goto Exit;\r
704 }\r
705\r
706 Status = Sock->ProtoHandler (Sock, SOCK_CONSUMED, NULL);\r
707 } else {\r
708\r
709 if (NULL == SockBufferToken (Sock, &Sock->RcvTokenList, RcvToken, 0)) {\r
710 Status = EFI_OUT_OF_RESOURCES;\r
711 }\r
712 }\r
713\r
714Exit:\r
715 EfiReleaseLock (&(Sock->Lock));\r
716 return Status;\r
717}\r
718\r
719\r
720/**\r
721 Reset the socket and its associated protocol control block.\r
722\r
723 @param Sock Pointer to the socket to be flushed.\r
724\r
725 @retval EFI_SUCCESS The socket is flushed successfully.\r
726 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket.\r
727\r
728**/\r
729EFI_STATUS\r
730SockFlush (\r
731 IN SOCKET *Sock\r
732 )\r
733{\r
734 EFI_STATUS Status;\r
735\r
736 ASSERT (SOCK_STREAM == Sock->Type);\r
737\r
738 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
739 if (EFI_ERROR (Status)) {\r
740\r
741 DEBUG ((EFI_D_ERROR, "SockFlush: Get the access for socket"\r
742 " failed with %r", Status));\r
743\r
744 return EFI_ACCESS_DENIED;\r
745 }\r
746\r
747 if (!SOCK_IS_CONFIGURED (Sock)) {\r
748 goto Exit;\r
749 }\r
750\r
751 Status = Sock->ProtoHandler (Sock, SOCK_FLUSH, NULL);\r
752 if (EFI_ERROR (Status)) {\r
753\r
754 DEBUG ((EFI_D_ERROR, "SockFlush: Protocol failed handling"\r
755 " SOCK_FLUSH with %r", Status));\r
756\r
757 goto Exit;\r
758 }\r
759\r
760 SOCK_ERROR (Sock, EFI_ABORTED);\r
761 SockConnFlush (Sock);\r
762 SockSetState (Sock, SO_CLOSED);\r
763\r
764 Sock->ConfigureState = SO_UNCONFIGURED;\r
765\r
766Exit:\r
767 EfiReleaseLock (&(Sock->Lock));\r
768 return Status;\r
769}\r
770\r
771\r
772/**\r
773 Close or abort the socket associated connection.\r
774\r
775 @param Sock Pointer to the socket of the connection to close or\r
776 abort.\r
777 @param Token The token for close operation.\r
778 @param OnAbort TRUE for aborting the connection, FALSE to close it.\r
779\r
780 @retval EFI_SUCCESS The close or abort operation is initialized\r
781 successfully.\r
782 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket, or the\r
783 socket is closed, or the socket is not in a\r
784 synchronized state , or the token is already in one\r
785 of this socket's lists.\r
786 @retval EFI_NO_MAPPING The IP address configuration operation is not\r
787 finished.\r
788 @retval EFI_NOT_STARTED The socket is not configured.\r
789\r
790**/\r
791EFI_STATUS\r
792SockClose (\r
793 IN SOCKET *Sock,\r
794 IN VOID *Token,\r
795 IN BOOLEAN OnAbort\r
796 )\r
797{\r
798 EFI_STATUS Status;\r
799 EFI_EVENT Event;\r
800\r
801 ASSERT (SOCK_STREAM == Sock->Type);\r
802\r
803 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
804 if (EFI_ERROR (Status)) {\r
805 DEBUG ((EFI_D_ERROR, "SockClose: Get the access for socket"\r
806 " failed with %r", Status));\r
807\r
808 return EFI_ACCESS_DENIED;\r
809 }\r
810\r
811 if (SOCK_IS_NO_MAPPING (Sock)) {\r
812 Status = EFI_NO_MAPPING;\r
813 goto Exit;\r
814 }\r
815\r
816 if (SOCK_IS_UNCONFIGURED (Sock)) {\r
817 Status = EFI_NOT_STARTED;\r
818 goto Exit;\r
819 }\r
820\r
821 if (SOCK_IS_DISCONNECTING (Sock)) {\r
822 Status = EFI_ACCESS_DENIED;\r
823 goto Exit;\r
824 }\r
825\r
826 Event = ((SOCK_COMPLETION_TOKEN *) Token)->Event;\r
827\r
828 if (SockTokenExisted (Sock, Event)) {\r
829 Status = EFI_ACCESS_DENIED;\r
830 goto Exit;\r
831 }\r
832\r
833 Sock->CloseToken = Token;\r
834 SockSetState (Sock, SO_DISCONNECTING);\r
835\r
836 if (OnAbort) {\r
837 Status = Sock->ProtoHandler (Sock, SOCK_ABORT, NULL);\r
838 } else {\r
839 Status = Sock->ProtoHandler (Sock, SOCK_CLOSE, NULL);\r
840 }\r
841\r
842Exit:\r
843 EfiReleaseLock (&(Sock->Lock));\r
844 return Status;\r
845}\r
846\r
847\r
848/**\r
849 Get the mode data of the low layer protocol.\r
850\r
851 @param Sock Pointer to the socket to get mode data from.\r
852 @param Mode Pointer to the data to store the low layer mode\r
853 information.\r
854\r
855 @retval EFI_SUCCESS The mode data is got successfully.\r
856 @retval EFI_NOT_STARTED The socket is not configured.\r
857\r
858**/\r
859EFI_STATUS\r
860SockGetMode (\r
861 IN SOCKET *Sock,\r
862 IN OUT VOID *Mode\r
863 )\r
864{\r
865 return Sock->ProtoHandler (Sock, SOCK_MODE, Mode);\r
866}\r
867\r
868\r
869/**\r
870 Configure the low level protocol to join a multicast group for\r
871 this socket's connection.\r
872\r
873 @param Sock Pointer to the socket of the connection to join the\r
874 specific multicast group.\r
875 @param GroupInfo Pointer to the multicast group info.\r
876\r
877 @retval EFI_SUCCESS The configuration is done successfully.\r
878 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket.\r
879 @retval EFI_NOT_STARTED The socket is not configured.\r
880\r
881**/\r
882EFI_STATUS\r
883SockGroup (\r
884 IN SOCKET *Sock,\r
885 IN VOID *GroupInfo\r
886 )\r
887{\r
888 EFI_STATUS Status;\r
889\r
890 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
891\r
892 if (EFI_ERROR (Status)) {\r
893\r
894 DEBUG ((EFI_D_ERROR, "SockGroup: Get the access for socket"\r
895 " failed with %r", Status));\r
896\r
897 return EFI_ACCESS_DENIED;\r
898 }\r
899\r
900 if (SOCK_IS_UNCONFIGURED (Sock)) {\r
901 Status = EFI_NOT_STARTED;\r
902 goto Exit;\r
903 }\r
904\r
905 Status = Sock->ProtoHandler (Sock, SOCK_GROUP, GroupInfo);\r
906\r
907Exit:\r
908 EfiReleaseLock (&(Sock->Lock));\r
909 return Status;\r
910}\r
911\r
912\r
913/**\r
914 Add or remove route information in IP route table associated\r
915 with this socket.\r
916\r
917 @param Sock Pointer to the socket associated with the IP route\r
918 table to operate on.\r
919 @param RouteInfo Pointer to the route information to be processed.\r
920\r
921 @retval EFI_SUCCESS The route table is updated successfully.\r
922 @retval EFI_ACCESS_DENIED Failed to get the lock to access the socket.\r
923 @retval EFI_NO_MAPPING The IP address configuration operation is not\r
924 finished.\r
925 @retval EFI_NOT_STARTED The socket is not configured.\r
926\r
927**/\r
928EFI_STATUS\r
929SockRoute (\r
930 IN SOCKET *Sock,\r
931 IN VOID *RouteInfo\r
932 )\r
933{\r
934 EFI_STATUS Status;\r
935\r
936 Status = EfiAcquireLockOrFail (&(Sock->Lock));\r
937 if (EFI_ERROR (Status)) {\r
938 DEBUG ((EFI_D_ERROR, "SockRoute: Get the access for socket"\r
939 " failed with %r", Status));\r
940\r
941 return EFI_ACCESS_DENIED;\r
942 }\r
943\r
944 if (SOCK_IS_NO_MAPPING (Sock)) {\r
945 Status = EFI_NO_MAPPING;\r
946 goto Exit;\r
947 }\r
948\r
949 if (SOCK_IS_UNCONFIGURED (Sock)) {\r
950 Status = EFI_NOT_STARTED;\r
951 goto Exit;\r
952 }\r
953\r
954 Status = Sock->ProtoHandler (Sock, SOCK_ROUTE, RouteInfo);\r
955\r
956Exit:\r
957 EfiReleaseLock (&(Sock->Lock));\r
958 return Status;\r
959}\r