]> git.proxmox.com Git - mirror_edk2.git/blobdiff - StdLib/EfiSocketLib/Socket.c
projects / mirror_edk2.git / blobdiff
? search:
summary | shortlog | log | commit | commitdiff | tree
raw | inline | side by side
Change to match the tree required on the storage device.
[mirror_edk2.git] / StdLib / EfiSocketLib / Socket.c
diff --git a/StdLib/EfiSocketLib/Socket.c b/StdLib/EfiSocketLib/Socket.c
index 42e4689d0b836e3b3f37b27397938236885f0da6..1805fa629ce1f052252b7dce32f5800ad5de0dae 100644 (file)
--- a/StdLib/EfiSocketLib/Socket.c
+++ b/StdLib/EfiSocketLib/Socket.c
@@ -481,6 +481,14 @@ CONST ESL_SOCKET_BINDING cEslSocketBinding[] = {
     4,    //  RX buffers\r
     4,    //  TX buffers\r
     4 },  //  TX Oob buffers\r
+  { L"Tcp6",\r
+    &gEfiTcp6ServiceBindingProtocolGuid,\r
+    &gEfiTcp6ProtocolGuid,\r
+    &mEslTcp6ServiceGuid,\r
+    OFFSET_OF ( ESL_LAYER, pTcp6List ),\r
+    4,    //  RX buffers\r
+    4,    //  TX buffers\r
+    4 },  //  TX Oob buffers\r
   { L"Udp4",\r
     &gEfiUdp4ServiceBindingProtocolGuid,\r
     &gEfiUdp4ProtocolGuid,\r
@@ -488,6 +496,14 @@ CONST ESL_SOCKET_BINDING cEslSocketBinding[] = {
     OFFSET_OF ( ESL_LAYER, pUdp4List ),\r
     4,    //  RX buffers\r
     4,    //  TX buffers\r
+    0 },  //  TX Oob buffers\r
+  { L"Udp6",\r
+    &gEfiUdp6ServiceBindingProtocolGuid,\r
+    &gEfiUdp6ProtocolGuid,\r
+    &mEslUdp6ServiceGuid,\r
+    OFFSET_OF ( ESL_LAYER, pUdp6List ),\r
+    4,    //  RX buffers\r
+    4,    //  TX buffers\r
     0 }   //  TX Oob buffers\r
 };\r
 \r
@@ -516,11 +532,11 @@ CONST int cEslAfInetApiSize = DIM ( cEslAfInetApi );
 **/\r
 CONST ESL_PROTOCOL_API * cEslAfInet6Api[] = {\r
   NULL,             //  0\r
-  NULL,             //  SOCK_STREAM\r
-  NULL,             //  SOCK_DGRAM\r
+  &cEslTcp6Api,     //  SOCK_STREAM\r
+  &cEslUdp6Api,     //  SOCK_DGRAM\r
   NULL,             //  SOCK_RAW\r
   NULL,             //  SOCK_RDM\r
-  NULL              //  SOCK_SEQPACKET\r
+  &cEslTcp6Api      //  SOCK_SEQPACKET\r
 };\r
 \r
 /**\r
@@ -603,6 +619,7 @@ EslSocket (
     //  Validate the domain value\r
     //\r
     if (( AF_INET != domain )\r
+      && ( AF_INET6 != domain )\r
       && ( AF_LOCAL != domain )) {\r
       DEBUG (( DEBUG_ERROR | DEBUG_SOCKET,\r
                 "ERROR - Invalid domain value\r\n" ));\r
@@ -1789,6 +1806,11 @@ EslSocketConnect (
           if ( EFI_NOT_READY != Status ) {\r
             if ( !EFI_ERROR ( Status )) {\r
               pSocket->State = SOCKET_STATE_CONNECTED;\r
+\r
+              //\r
+              //  Start the receive operations\r
+              //\r
+              EslSocketRxStart ( pSocket->pPortList );\r
             }\r
             else {\r
               pSocket->State = SOCKET_STATE_BOUND;\r
@@ -1980,7 +2002,8 @@ EslSocketGetLocalAddress (
         //\r
         //  Verify the socket state\r
         //\r
-        if ( SOCKET_STATE_CONNECTED == pSocket->State ) {\r
+        if (( SOCKET_STATE_CONNECTED == pSocket->State )\r
+          || ( SOCKET_STATE_LISTENING == pSocket->State )) {\r
           //\r
           //  Verify the API\r
           //\r
@@ -2307,7 +2330,7 @@ EslSocketIoInit (
   IN ESL_IO_MGMT ** ppFreeQueue,\r
   IN UINTN DebugFlags,\r
   IN CHAR8 * pEventName,\r
-  IN EFI_EVENT_NOTIFY pfnCompletion\r
+  IN PFN_API_IO_COMPLETE pfnCompletion\r
   )\r
 {\r
   ESL_IO_MGMT * pEnd;\r
@@ -2670,7 +2693,7 @@ EslSocketOptionGet (
   int errno;\r
   socklen_t LengthInBytes;\r
   socklen_t MaxBytes;\r
-  UINT8 * pOptionData;\r
+  CONST UINT8 * pOptionData;\r
   ESL_SOCKET * pSocket;\r
   EFI_STATUS Status;\r
 \r
@@ -2709,7 +2732,7 @@ EslSocketOptionGet (
         if ( pSocket->pApi->DefaultProtocol == level ) {\r
           Status = pSocket->pApi->pfnOptionGet ( pSocket,\r
                                                  OptionName,\r
-                                                 &pOptionData,\r
+                                                 (CONST void ** __restrict)&pOptionData,\r
                                                  &LengthInBytes );\r
           errno = pSocket->errno;\r
           break;\r
@@ -2749,7 +2772,7 @@ EslSocketOptionGet (
         //\r
         //  Return the listen flag\r
         //\r
-        pOptionData = (UINT8 *)&pSocket->bListenCalled;\r
+        pOptionData = (CONST UINT8 *)&pSocket->bListenCalled;\r
         LengthInBytes = sizeof ( pSocket->bListenCalled );\r
         break;\r
 \r
@@ -2757,7 +2780,7 @@ EslSocketOptionGet (
         //\r
         //  Return the debug flags\r
         //\r
-        pOptionData = (UINT8 *)&pSocket->bOobInLine;\r
+        pOptionData = (CONST UINT8 *)&pSocket->bOobInLine;\r
         LengthInBytes = sizeof ( pSocket->bOobInLine );\r
         break;\r
 \r
@@ -2765,7 +2788,7 @@ EslSocketOptionGet (
         //\r
         //  Return the out-of-band inline flag\r
         //\r
-        pOptionData = (UINT8 *)&pSocket->bOobInLine;\r
+        pOptionData = (CONST UINT8 *)&pSocket->bOobInLine;\r
         LengthInBytes = sizeof ( pSocket->bOobInLine );\r
         break;\r
 \r
@@ -2773,7 +2796,7 @@ EslSocketOptionGet (
         //\r
         //  Return the receive timeout\r
         //\r
-        pOptionData = (UINT8 *)&pSocket->RxTimeout;\r
+        pOptionData = (CONST UINT8 *)&pSocket->RxTimeout;\r
         LengthInBytes = sizeof ( pSocket->RxTimeout );\r
         break;\r
         \r
@@ -2781,7 +2804,7 @@ EslSocketOptionGet (
         //\r
         //  Return the maximum receive buffer size\r
         //\r
-        pOptionData = (UINT8 *)&pSocket->MaxRxBuf;\r
+        pOptionData = (CONST UINT8 *)&pSocket->MaxRxBuf;\r
         LengthInBytes = sizeof ( pSocket->MaxRxBuf );\r
         break;\r
 \r
@@ -2789,7 +2812,7 @@ EslSocketOptionGet (
         //\r
         //  Return the maximum transmit buffer size\r
         //\r
-        pOptionData = (UINT8 *)&pSocket->MaxTxBuf;\r
+        pOptionData = (CONST UINT8 *)&pSocket->MaxTxBuf;\r
         LengthInBytes = sizeof ( pSocket->MaxTxBuf );\r
         break;\r
 \r
@@ -2797,7 +2820,7 @@ EslSocketOptionGet (
         //\r
         //  Return the socket type\r
         //\r
-        pOptionData = (UINT8 *)&pSocket->Type;\r
+        pOptionData = (CONST UINT8 *)&pSocket->Type;\r
         LengthInBytes = sizeof ( pSocket->Type );\r
         break;\r
       }\r
@@ -3096,7 +3119,7 @@ EslSocketPacketAllocate (
                                LengthInBytes,\r
                                (VOID **)&pPacket );\r
   if ( !EFI_ERROR ( Status )) {\r
-    DEBUG (( DebugFlags | DEBUG_POOL | DEBUG_INIT,\r
+    DEBUG (( DebugFlags | DEBUG_POOL,\r
               "0x%08x: Allocate pPacket, %d bytes\r\n",\r
               pPacket,\r
               LengthInBytes ));\r
@@ -3210,6 +3233,7 @@ EslSocketPoll (
   short DetectedEvents;\r
   ESL_SOCKET * pSocket;\r
   EFI_STATUS Status;\r
+  EFI_TPL TplPrevious;\r
   short ValidEvents;\r
 \r
   DEBUG (( DEBUG_POLL, "Entering SocketPoll\r\n" ));\r
@@ -3247,6 +3271,22 @@ EslSocketPoll (
                 Events & ( ~ValidEvents )));\r
     }\r
     else {\r
+      //\r
+      //  Synchronize with the socket layer\r
+      //\r
+      RAISE_TPL ( TplPrevious, TPL_SOCKETS );\r
+      \r
+      //\r
+      //  Increase the network performance by extending the\r
+      //  polling (idle) loop down into the LAN driver\r
+      //\r
+      EslSocketRxPoll ( pSocket );\r
+      \r
+      //\r
+      //  Release the socket layer synchronization\r
+      //\r
+      RESTORE_TPL ( TplPrevious );\r
+\r
       //\r
       //  Check for pending connections\r
       //\r
@@ -4366,6 +4406,11 @@ EslSocketReceive (
               //  Verify that the socket is connected\r
               //\r
               if ( SOCKET_STATE_CONNECTED == pSocket->State ) {\r
+                //\r
+                //  Poll the network to increase performance\r
+                //\r
+                EslSocketRxPoll ( pSocket );\r
+\r
                 //\r
                 //  Locate the port\r
                 //\r
@@ -4847,6 +4892,49 @@ EslSocketRxComplete (
 }\r
 \r
 \r
+/**\r
+  Poll a socket for pending receive activity.\r
+\r
+  This routine is called at elivated TPL and extends the idle\r
+  loop which polls a socket down into the LAN driver layer to\r
+  determine if there is any receive activity.\r
+\r
+  The ::EslSocketPoll, ::EslSocketReceive and ::EslSocketTransmit\r
+  routines call this routine when there is nothing to do.\r
+\r
+  @param [in] pSocket   Address of an ::EFI_SOCKET structure.\r
+\r
+ **/\r
+VOID\r
+EslSocketRxPoll (\r
+  IN ESL_SOCKET * pSocket\r
+  )\r
+{\r
+  ESL_PORT * pPort;\r
+\r
+  DEBUG (( DEBUG_POLL, "Entering EslSocketRxPoll\r\n" ));\r
+\r
+  //\r
+  //  Increase the network performance by extending the\r
+  //  polling (idle) loop down into the LAN driver\r
+  //\r
+  pPort = pSocket->pPortList;\r
+  while ( NULL != pPort ) {\r
+    //\r
+    //  Poll the LAN adapter\r
+    //\r
+    pPort->pfnRxPoll ( pPort->pProtocol.v );\r
+\r
+    //\r
+    //  Locate the next LAN adapter\r
+    //\r
+    pPort = pPort->pLinkSocket;\r
+  }\r
+\r
+  DEBUG (( DEBUG_POLL, "Exiting EslSocketRxPoll\r\n" ));\r
+}\r
+\r
+\r
 /**\r
   Start a receive operation\r
 \r
@@ -5291,6 +5379,11 @@ EslSocketTransmit (
                 //\r
                 RAISE_TPL ( TplPrevious, TPL_SOCKETS );\r
 \r
+                //\r
+                //  Poll the network to increase performance\r
+                //\r
+                EslSocketRxPoll ( pSocket );\r
+\r
                 //\r
                 //  Attempt to buffer the packet for transmission\r
                 //\r
EFI Development Kit II mirror for PVE