+++ /dev/null
-/** @file\r
- Data source for network testing.\r
-\r
- Copyright (c) 2011-2012, Intel Corporation. All rights reserved.\r
- SPDX-License-Identifier: BSD-2-Clause-Patent\r
-\r
-**/\r
-\r
-#include <errno.h>\r
-#include <Uefi.h>\r
-\r
-#include <Library/BaseMemoryLib.h>\r
-#include <Library/DebugLib.h>\r
-#include <Library/PcdLib.h>\r
-#include <Library/UefiBootServicesTableLib.h>\r
-#include <Library/UefiLib.h>\r
-\r
-#include <netinet/in.h>\r
-\r
-#include <sys/EfiSysCall.h>\r
-#include <sys/poll.h>\r
-#include <sys/socket.h>\r
-\r
-\r
-#define DATA_SAMPLE_SHIFT 5 ///< Shift for number of samples\r
-#define MAX_CONNECTIONS ( 1 + 16 ) ///< Maximum number of client connections\r
-#define RANGE_SWITCH ( 1024 * 1024 ) ///< Switch display ranges\r
-#define DATA_RATE_UPDATE_SHIFT 2 ///< 2n seconds between updates\r
-#define AVERAGE_SHIFT_COUNT ( 6 - DATA_RATE_UPDATE_SHIFT ) ///< 2n samples in average\r
-#define DATA_SAMPLES ( 1 << DATA_SAMPLE_SHIFT ) ///< Number of samples\r
-\r
-#define TPL_DATASINK TPL_CALLBACK ///< Synchronization TPL\r
-\r
-#define PACKET_SIZE 1448 ///< Size of data packets\r
-#define DATA_BUFFER_SIZE (( 65536 / PACKET_SIZE ) * PACKET_SIZE ) ///< Buffer size in bytes\r
-\r
-typedef struct _DT_PORT {\r
- UINT64 BytesTotal;\r
- struct sockaddr_in6 IpAddress;\r
- UINT32 In;\r
- UINT32 Samples;\r
- UINT64 BytesReceived[ DATA_SAMPLES ];\r
-} DT_PORT;\r
-\r
-volatile BOOLEAN bTick;\r
-BOOLEAN bTimerRunning;\r
-struct sockaddr_in6 LocalAddress;\r
-EFI_EVENT pTimer;\r
-int ListenSocket;\r
-UINT8 Buffer[ DATA_BUFFER_SIZE ];\r
-struct pollfd PollFd[ MAX_CONNECTIONS ];\r
-DT_PORT Port[ MAX_CONNECTIONS ];\r
-nfds_t MaxPort;\r
-\r
-\r
-//\r
-// Forward routine declarations\r
-//\r
-EFI_STATUS TimerStart ( UINTN Milliseconds );\r
-\r
-\r
-/**\r
- Check for control C entered at console\r
-\r
- @retval EFI_SUCCESS Control C not entered\r
- @retval EFI_ABORTED Control C entered\r
-**/\r
-EFI_STATUS\r
-ControlCCheck (\r
- )\r
-{\r
- EFI_STATUS Status;\r
-\r
- //\r
- // Assume no user intervention\r
- //\r
- Status = EFI_SUCCESS;\r
-\r
- //\r
- // Display user stop request\r
- //\r
- if ( EFI_ERROR ( Status )) {\r
- DEBUG (( DEBUG_INFO,\r
- "User stop request!\r\n" ));\r
- }\r
-\r
- //\r
- // Return the check status\r
- //\r
- return Status;\r
-}\r
-\r
-\r
-/**\r
- Accept a socket connection\r
-\r
- @retval EFI_SUCCESS The application is running normally\r
- @retval EFI_NOT_STARTED Error with the listen socket\r
- @retval Other The user stopped the application\r
-**/\r
-EFI_STATUS\r
-SocketAccept (\r
- )\r
-{\r
- INT32 SocketStatus;\r
- EFI_STATUS Status;\r
- INTN Index;\r
-\r
- //\r
- // Assume failure\r
- //\r
- Status = EFI_DEVICE_ERROR;\r
-\r
- //\r
- // Bind to the local address\r
- //\r
- SocketStatus = bind ( ListenSocket,\r
- (struct sockaddr *) &LocalAddress,\r
- LocalAddress.sin6_len );\r
- if ( 0 == SocketStatus ) {\r
- //\r
- // Start listening on the local socket\r
- //\r
- SocketStatus = listen ( ListenSocket, 5 );\r
- if ( 0 == SocketStatus ) {\r
- //\r
- // Local socket in the listen state\r
- //\r
- Status = EFI_SUCCESS;\r
-\r
- //\r
- // Allocate a port\r
- //\r
- Index = MaxPort++;\r
- PollFd[ Index ].fd = ListenSocket;\r
- PollFd[ Index ].events = POLLRDNORM | POLLHUP;\r
- PollFd[ Index ].revents = 0;\r
- ZeroMem ( &Port[ Index ], sizeof ( Port[ Index ]));\r
- }\r
- }\r
-\r
- //\r
- // Return the operation status\r
- //\r
- return Status;\r
-}\r
-\r
-\r
-/**\r
- Close the socket\r
-\r
- @retval EFI_SUCCESS The application is running normally\r
- @retval Other The user stopped the application\r
-**/\r
-EFI_STATUS\r
-SocketClose (\r
- )\r
-{\r
- INT32 CloseStatus;\r
- EFI_STATUS Status;\r
-\r
- //\r
- // Determine if the socket is open\r
- //\r
- Status = EFI_DEVICE_ERROR;\r
- if ( -1 != ListenSocket ) {\r
- //\r
- // Attempt to close the socket\r
- //\r
- CloseStatus = close ( ListenSocket );\r
- if ( 0 == CloseStatus ) {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket closed\r\n",\r
- ListenSocket ));\r
- ListenSocket = -1;\r
- Status = EFI_SUCCESS;\r
- }\r
- else {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR: Failed to close socket, errno: %d\r\n",\r
- errno ));\r
- }\r
- }\r
-\r
- //\r
- // Return the operation status\r
- //\r
- return Status;\r
-}\r
-\r
-\r
-/**\r
- Create the socket\r
-\r
- @param [in] Family Network family, AF_INET or AF_INET6\r
-\r
- @retval EFI_SUCCESS The application is running normally\r
- @retval Other The user stopped the application\r
-**/\r
-EFI_STATUS\r
-SocketNew (\r
- sa_family_t Family\r
- )\r
-{\r
- EFI_STATUS Status;\r
-\r
- //\r
- // Get the port number\r
- //\r
- ZeroMem ( &LocalAddress, sizeof ( LocalAddress ));\r
- LocalAddress.sin6_len = sizeof ( LocalAddress );\r
- LocalAddress.sin6_family = Family;\r
- LocalAddress.sin6_port = htons ( PcdGet16 ( DataSource_Port ));\r
- \r
- //\r
- // Loop creating the socket\r
- //\r
- DEBUG (( DEBUG_INFO,\r
- "Creating the socket\r\n" ));\r
-\r
- //\r
- // Check for user stop request\r
- //\r
- Status = ControlCCheck ( );\r
- if ( !EFI_ERROR ( Status )) {\r
- //\r
- // Attempt to create the socket\r
- //\r
- ListenSocket = socket ( LocalAddress.sin6_family,\r
- SOCK_STREAM,\r
- IPPROTO_TCP );\r
- if ( -1 != ListenSocket ) {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket created\r\n",\r
- ListenSocket ));\r
- }\r
- else {\r
- Status = EFI_NOT_STARTED;\r
- }\r
- }\r
-\r
- //\r
- // Return the operation status\r
- //\r
- return Status;\r
-}\r
-\r
-\r
-/**\r
- Poll the socket for more work\r
-\r
- @retval EFI_SUCCESS The application is running normally\r
- @retval EFI_NOT_STARTED Listen socket error\r
- @retval Other The user stopped the application\r
-**/\r
-EFI_STATUS\r
-SocketPoll (\r
- )\r
-{\r
- BOOLEAN bRemoveSocket;\r
- BOOLEAN bListenError;\r
- size_t BytesReceived;\r
- int CloseStatus;\r
- nfds_t Entry;\r
- INTN EntryPrevious;\r
- int FdCount;\r
- nfds_t Index;\r
- socklen_t LengthInBytes;\r
- struct sockaddr_in * pPortIpAddress4;\r
- struct sockaddr_in6 * pPortIpAddress6;\r
- struct sockaddr_in * pRemoteAddress4;\r
- struct sockaddr_in6 * pRemoteAddress6;\r
- struct sockaddr_in6 RemoteAddress;\r
- int Socket;\r
- EFI_STATUS Status;\r
- EFI_TPL TplPrevious;\r
-\r
- //\r
- // Check for control-C\r
- //\r
- pRemoteAddress4 = (struct sockaddr_in *)&RemoteAddress;\r
- pRemoteAddress6 = (struct sockaddr_in6 *)&RemoteAddress;\r
- bListenError = FALSE;\r
- Status = ControlCCheck ( );\r
- if ( !EFI_ERROR ( Status )) {\r
- //\r
- // Poll the sockets\r
- //\r
- FdCount = poll ( &PollFd[0],\r
- MaxPort,\r
- 0 );\r
- if ( -1 == FdCount ) {\r
- //\r
- // Poll error\r
- //\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Poll error, errno: %d\r\n",\r
- errno ));\r
- Status = EFI_DEVICE_ERROR;\r
- }\r
- else {\r
- //\r
- // Process the poll output\r
- //\r
- Index = 0;\r
- while ( FdCount ) {\r
- bRemoveSocket = FALSE;\r
-\r
- //\r
- // Account for this descriptor\r
- //\r
- pPortIpAddress4 = (struct sockaddr_in *)&Port[ Index ].IpAddress;\r
- pPortIpAddress6 = (struct sockaddr_in6 *)&Port[ Index ].IpAddress;\r
- if ( 0 != PollFd[ Index ].revents ) {\r
- FdCount -= 1;\r
- }\r
-\r
- //\r
- // Check for a broken connection\r
- //\r
- if ( 0 != ( PollFd[ Index ].revents & POLLHUP )) {\r
- bRemoveSocket = TRUE;\r
- if ( ListenSocket == PollFd[ Index ].fd ) {\r
- bListenError = TRUE;\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Network closed on listen socket, errno: %d\r\n",\r
- errno ));\r
- }\r
- else {\r
- if ( AF_INET == pPortIpAddress4->sin_family ) {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Network closed on socket %d.%d.%d.%d:%d, errno: %d\r\n",\r
- pPortIpAddress4->sin_addr.s_addr & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pPortIpAddress4->sin_port ),\r
- errno ));\r
- }\r
- else {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Network closed on socket [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d, errno: %d\r\n",\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pPortIpAddress6->sin6_port ),\r
- errno ));\r
- }\r
-\r
- //\r
- // Close the socket\r
- //\r
- CloseStatus = close ( PollFd[ Index ].fd );\r
- if ( 0 == CloseStatus ) {\r
- bRemoveSocket = TRUE;\r
- if ( AF_INET == pPortIpAddress4->sin_family ) {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket closed for %d.%d.%d.%d:%d\r\n",\r
- PollFd[ Index ].fd,\r
- pPortIpAddress4->sin_addr.s_addr & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pPortIpAddress4->sin_port )));\r
- }\r
- else {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket closed for [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d\r\n",\r
- PollFd[ Index ].fd,\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pPortIpAddress6->sin6_port )));\r
- }\r
- }\r
- else {\r
- if ( AF_INET == pPortIpAddress4->sin_family ) {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Failed to close socket 0x%08x for %d.%d.%d.%d:%d, errno: %d\r\n",\r
- PollFd[ Index ].fd,\r
- pPortIpAddress4->sin_addr.s_addr & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pPortIpAddress4->sin_port ),\r
- errno ));\r
- }\r
- else {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Failed to close socket 0x%08x for [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d, errno: %d\r\n",\r
- PollFd[ Index ].fd,\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pPortIpAddress6->sin6_port ),\r
- errno ));\r
- }\r
- }\r
- }\r
- }\r
- \r
- //\r
- // Check for a connection or read data\r
- //\r
- if ( 0 != ( PollFd[ Index ].revents & POLLRDNORM )) {\r
- //\r
- // Check for a connection\r
- //\r
- if ( ListenSocket == PollFd[ Index ].fd ) {\r
- //\r
- // Another client connection was received\r
- //\r
- LengthInBytes = sizeof ( RemoteAddress );\r
- Socket = accept ( ListenSocket,\r
- (struct sockaddr *) &RemoteAddress,\r
- &LengthInBytes );\r
- if ( -1 == Socket ) {\r
- //\r
- // Listen socket error\r
- //\r
- bListenError = TRUE;\r
- bRemoveSocket = TRUE;\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Listen socket failure, errno: %d\r\n",\r
- errno ));\r
- }\r
- else {\r
- //\r
- // Determine if there is room for this connection\r
- //\r
- if (( MAX_CONNECTIONS <= MaxPort )\r
- || ((( MAX_CONNECTIONS - 1 ) == MaxPort ) && ( -1 == ListenSocket ))) {\r
- //\r
- // Display the connection\r
- //\r
- if ( AF_INET == pRemoteAddress4->sin_family ) {\r
- Print ( L"Rejecting connection to remote system %d.%d.%d.%d:%d\r\n",\r
- pRemoteAddress4->sin_addr.s_addr & 0xff,\r
- ( pRemoteAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pRemoteAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pRemoteAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pRemoteAddress4->sin_port ));\r
- }\r
- else {\r
- Print ( L"Rejecting connection to remote system [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d\r\n",\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pRemoteAddress6->sin6_port ));\r
- }\r
-\r
- //\r
- // No room for this connection\r
- // Close the connection\r
- //\r
- CloseStatus = close ( Socket );\r
- if ( 0 == CloseStatus ) {\r
- bRemoveSocket = TRUE;\r
- if ( AF_INET == pRemoteAddress4->sin_family ) {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket closed for %d.%d.%d.%d:%d\r\n",\r
- PollFd[ Index ].fd,\r
- pRemoteAddress4->sin_addr.s_addr & 0xff,\r
- ( pRemoteAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pRemoteAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pRemoteAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pRemoteAddress4->sin_port )));\r
- }\r
- else {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket closed for [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d\r\n",\r
- PollFd[ Index ].fd,\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pRemoteAddress6->sin6_port )));\r
- }\r
- }\r
- else {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Failed to close socket 0x%08x, errno: %d\r\n",\r
- PollFd[ Index ].fd,\r
- errno ));\r
- }\r
-\r
- //\r
- // Keep the application running\r
- // No issue with the listen socket\r
- //\r
- Status = EFI_SUCCESS;\r
- }\r
- else {\r
- //\r
- // Display the connection\r
- //\r
- if ( AF_INET == pRemoteAddress4->sin_family ) {\r
- Print ( L"Connected to remote system %d.%d.%d.%d:%d\r\n",\r
- pRemoteAddress4->sin_addr.s_addr & 0xff,\r
- ( pRemoteAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pRemoteAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pRemoteAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pRemoteAddress4->sin_port ));\r
- }\r
- else {\r
- Print ( L"Connected to remote system [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d\r\n",\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pRemoteAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pRemoteAddress6->sin6_port ));\r
- }\r
-\r
- //\r
- // Allocate the client connection\r
- //\r
- Index = MaxPort++;\r
- ZeroMem ( &Port[ Index ], sizeof ( Port[ Index ]));\r
- CopyMem ( pPortIpAddress6, pRemoteAddress6, sizeof ( *pRemoteAddress6 ));\r
- PollFd[ Index ].fd = Socket;\r
- PollFd[ Index ].events = POLLRDNORM | POLLHUP;\r
- PollFd[ Index ].revents = 0;\r
- }\r
- }\r
- }\r
- else {\r
- //\r
- // Data received\r
- //\r
- BytesReceived = read ( PollFd[ Index ].fd,\r
- &Buffer,\r
- sizeof ( Buffer ));\r
- if ( 0 < BytesReceived ) {\r
- //\r
- // Display the amount of data received\r
- //\r
- if ( AF_INET == pPortIpAddress4->sin_family ) {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket received 0x%08x bytes from %d.%d.%d.%d:%d\r\n",\r
- PollFd[ Index ].fd,\r
- BytesReceived,\r
- pPortIpAddress4->sin_addr.s_addr & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pPortIpAddress4->sin_port )));\r
- }\r
- else {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket received 0x%08x bytes from [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d\r\n",\r
- PollFd[ Index ].fd,\r
- BytesReceived,\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pPortIpAddress6->sin6_port )));\r
- }\r
-\r
- //\r
- // Synchronize with the TimerCallback routine\r
- //\r
- TplPrevious = gBS->RaiseTPL ( TPL_DATASINK );\r
-\r
- //\r
- // Account for the data received\r
- //\r
- Port[ Index ].BytesTotal += BytesReceived;\r
-\r
- //\r
- // Release the synchronization with the TimerCallback routine\r
- //\r
- gBS->RestoreTPL ( TplPrevious );\r
- }\r
- else if ( -1 == BytesReceived ) {\r
- //\r
- // Close the socket\r
- //\r
- if ( AF_INET == pPortIpAddress4->sin_family ) {\r
- DEBUG (( DEBUG_INFO,\r
- "ERROR - Receive failure for %d.%d.%d.%d:%d, errno: %d\r\n",\r
- pPortIpAddress4->sin_addr.s_addr & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pPortIpAddress4->sin_port ),\r
- errno ));\r
- }\r
- else {\r
- DEBUG (( DEBUG_INFO,\r
- "ERROR - Receive failure for [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d, errno: %d\r\n",\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pPortIpAddress6->sin6_port ),\r
- errno ));\r
- }\r
- CloseStatus = close ( PollFd[ Index ].fd );\r
- if ( 0 == CloseStatus ) {\r
- bRemoveSocket = TRUE;\r
- if ( AF_INET == pPortIpAddress4->sin_family ) {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket closed for %d.%d.%d.%d:%d\r\n",\r
- PollFd[ Index ].fd,\r
- pPortIpAddress4->sin_addr.s_addr & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pPortIpAddress4->sin_port )));\r
- }\r
- else {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket closed for [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d\r\n",\r
- PollFd[ Index ].fd,\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pPortIpAddress6->sin6_port )));\r
- }\r
- }\r
- else {\r
- if ( AF_INET == pPortIpAddress4->sin_family ) {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Failed to close socket 0x%08x for %d.%d.%d.%d:%d, errno: %d\r\n",\r
- PollFd[ Index ].fd,\r
- pPortIpAddress4->sin_addr.s_addr & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 8 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 16 ) & 0xff,\r
- ( pPortIpAddress4->sin_addr.s_addr >> 24 ) & 0xff,\r
- ntohs ( pPortIpAddress4->sin_port ),\r
- errno ));\r
- }\r
- else {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Failed to close socket 0x%08x for [%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x:%02x%02x]:%d, errno: %d\r\n",\r
- PollFd[ Index ].fd,\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 0 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 1 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 2 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 3 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 4 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 5 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 6 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 7 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 8 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 9 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 10 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 11 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 12 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 13 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 14 ],\r
- pPortIpAddress6->sin6_addr.__u6_addr.__u6_addr8[ 15 ],\r
- ntohs ( pPortIpAddress6->sin6_port ),\r
- errno ));\r
- }\r
- }\r
- }\r
-\r
- //\r
- // Keep the application running\r
- // No issue with the listen socket\r
- //\r
- Status = EFI_SUCCESS;\r
- }\r
- }\r
-\r
- //\r
- // Remove the socket if necessary\r
- //\r
- if ( bRemoveSocket ) {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Socket removed from polling\r\n",\r
- PollFd[ Index ].fd ));\r
- MaxPort -= 1;\r
- for ( Entry = Index + 1; MaxPort >= Entry; Entry++ ) {\r
- EntryPrevious = Entry;\r
- CopyMem ( &Port[ EntryPrevious ],\r
- &Port[ Entry ],\r
- sizeof ( Port[ Entry ]));\r
- PollFd[ EntryPrevious ].events = PollFd[ Entry ].events;\r
- PollFd[ EntryPrevious ].fd = PollFd[ Entry ].fd;\r
- PollFd[ EntryPrevious ].revents = PollFd[ Entry ].revents;\r
- }\r
- PollFd[ MaxPort ].fd = -1;\r
- Index -= 1;\r
- }\r
-\r
- //\r
- // Account for this socket\r
- //\r
- Index += 1;\r
- }\r
- }\r
- }\r
-\r
- //\r
- // Return the listen failure if necessary\r
- //\r
- if (( !EFI_ERROR ( Status )) && bListenError ) {\r
- Status = EFI_NOT_STARTED;\r
- }\r
-\r
- //\r
- // Return the poll status\r
- //\r
- return Status;\r
-}\r
-\r
-\r
-/**\r
- Handle the timer callback\r
-\r
- @param [in] Event Event that caused this callback\r
- @param [in] pContext Context for this routine\r
-**/\r
-VOID\r
-EFIAPI\r
-TimerCallback (\r
- IN EFI_EVENT Event,\r
- IN VOID * pContext\r
- )\r
-{\r
- UINT32 Average;\r
- UINT64 BitsPerSecond;\r
- UINT64 BytesReceived;\r
- UINT32 Count;\r
- nfds_t Index;\r
- UINT64 TotalBytes;\r
-\r
- //\r
- // Notify the other code of the timer tick\r
- //\r
- bTick = TRUE;\r
-\r
- //\r
- // Walk the list of ports\r
- //\r
- for ( Index = 0; MaxPort > Index; Index++ ) {\r
- //\r
- // Determine if any data was received\r
- //\r
- BytesReceived = Port[ Index ].BytesTotal;\r
- if (( ListenSocket != PollFd[ Index ].fd )\r
- && ( 0 != BytesReceived )) {\r
- //\r
- // Update the received data samples\r
- //\r
- Port[ Index ].BytesTotal = 0;\r
- Port[ Index ].BytesReceived [ Port[ Index ].In ] = BytesReceived;\r
- Port[ Index ].In += 1;\r
- if ( DATA_SAMPLES <= Port[ Index ].In ) {\r
- Port[ Index ].In = 0;\r
- }\r
- \r
- //\r
- // Separate the samples\r
- //\r
- if ( DATA_SAMPLES == Port[ Index ].Samples ) {\r
- Print ( L"---------- Stable average ----------\r\n" );\r
- }\r
- Port[ Index ].Samples += 1;\r
-\r
- //\r
- // Compute the data rate\r
- //\r
- TotalBytes = 0;\r
- for ( Count = 0; DATA_SAMPLES > Count; Count++ )\r
- {\r
- TotalBytes += Port[ Index ].BytesReceived[ Count ];\r
- }\r
- Average = (UINT32)RShiftU64 ( TotalBytes, DATA_SAMPLE_SHIFT );\r
- BitsPerSecond = Average * 8;\r
-\r
- //\r
- // Display the data rate\r
- //\r
- if (( RANGE_SWITCH >> 10 ) > Average ) {\r
- Print ( L"Ave: %d Bytes/Sec, %Ld Bits/sec\r\n",\r
- Average,\r
- BitsPerSecond );\r
- }\r
- else {\r
- BitsPerSecond /= 1000;\r
- if ( RANGE_SWITCH > Average ) {\r
- Print ( L"Ave: %d.%03d KiBytes/Sec, %Ld KBits/sec\r\n",\r
- Average >> 10,\r
- (( Average & 0x3ff ) * 1000 ) >> 10,\r
- BitsPerSecond );\r
- }\r
- else {\r
- BitsPerSecond /= 1000;\r
- Average >>= 10;\r
- if ( RANGE_SWITCH > Average ) {\r
- Print ( L"Ave: %d.%03d MiBytes/Sec, %Ld MBits/sec\r\n",\r
- Average >> 10,\r
- (( Average & 0x3ff ) * 1000 ) >> 10,\r
- BitsPerSecond );\r
- }\r
- else {\r
- BitsPerSecond /= 1000;\r
- Average >>= 10;\r
- if ( RANGE_SWITCH > Average ) {\r
- Print ( L"Ave: %d.%03d GiBytes/Sec, %Ld GBits/sec\r\n",\r
- Average >> 10,\r
- (( Average & 0x3ff ) * 1000 ) >> 10,\r
- BitsPerSecond );\r
- }\r
- else {\r
- BitsPerSecond /= 1000;\r
- Average >>= 10;\r
- if ( RANGE_SWITCH > Average ) {\r
- Print ( L"Ave: %d.%03d TiBytes/Sec, %Ld TBits/sec\r\n",\r
- Average >> 10,\r
- (( Average & 0x3ff ) * 1000 ) >> 10,\r
- BitsPerSecond );\r
- }\r
- else {\r
- BitsPerSecond /= 1000;\r
- Average >>= 10;\r
- Print ( L"Ave: %d.%03d PiBytes/Sec, %Ld PBits/sec\r\n",\r
- Average >> 10,\r
- (( Average & 0x3ff ) * 1000 ) >> 10,\r
- BitsPerSecond );\r
- }\r
- }\r
- }\r
- }\r
- }\r
- }\r
- }\r
-}\r
-\r
-\r
-/**\r
- Create the timer\r
-\r
- @retval EFI_SUCCESS The timer was successfully created\r
- @retval Other Timer initialization failed\r
-**/\r
-EFI_STATUS\r
-TimerCreate (\r
- )\r
-{\r
- EFI_STATUS Status;\r
-\r
- //\r
- // Create the timer\r
- //\r
- Status = gBS->CreateEvent ( EVT_TIMER | EVT_NOTIFY_SIGNAL,\r
- TPL_DATASINK,\r
- TimerCallback,\r
- NULL,\r
- &pTimer );\r
- if ( EFI_ERROR ( Status )) {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Failed to allocate the timer event, Status: %r\r\n",\r
- Status ));\r
- }\r
- else {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Timer created\r\n",\r
- pTimer ));\r
- }\r
-\r
- //\r
- // Return the operation status\r
- //\r
- return Status;\r
-}\r
-\r
-\r
-/**\r
- Stop the timer\r
-\r
- @retval EFI_SUCCESS The timer was stopped successfully\r
- @retval Other The timer failed to stop\r
-**/\r
-EFI_STATUS\r
-TimerStop (\r
- )\r
-{\r
- EFI_STATUS Status;\r
-\r
- //\r
- // Assume success\r
- //\r
- Status = EFI_SUCCESS;\r
-\r
- //\r
- // Determine if the timer is running\r
- //\r
- if ( bTimerRunning ) {\r
- //\r
- // Stop the timer\r
- //\r
- Status = gBS->SetTimer ( pTimer,\r
- TimerCancel,\r
- 0 );\r
- if ( EFI_ERROR ( Status )) {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Failed to stop the timer, Status: %r\r\n",\r
- Status ));\r
- }\r
- else {\r
- //\r
- // Timer timer is now stopped\r
- //\r
- bTimerRunning = FALSE;\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Timer stopped\r\n",\r
- pTimer ));\r
- }\r
- }\r
-\r
- //\r
- // Return the operation status\r
- //\r
- return Status;\r
-}\r
-\r
-\r
-/**\r
- Start the timer\r
-\r
- @param [in] Milliseconds The number of milliseconds between timer callbacks\r
-\r
- @retval EFI_SUCCESS The timer was successfully created\r
- @retval Other Timer initialization failed\r
-**/\r
-EFI_STATUS\r
-TimerStart (\r
- UINTN Milliseconds\r
- )\r
-{\r
- EFI_STATUS Status;\r
- UINT64 TimeDelay;\r
-\r
- //\r
- // Stop the timer if necessary\r
- //\r
- Status = EFI_SUCCESS;\r
- if ( bTimerRunning ) {\r
- Status = TimerStop ( );\r
- }\r
- if ( !EFI_ERROR ( Status )) {\r
- //\r
- // Compute the new delay\r
- //\r
- TimeDelay = Milliseconds;\r
- TimeDelay *= 1000 * 10;\r
-\r
- //\r
- // Start the timer\r
- //\r
- Status = gBS->SetTimer ( pTimer,\r
- TimerPeriodic,\r
- TimeDelay );\r
- if ( EFI_ERROR ( Status )) {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Failed to start the timer, Status: %r\r\n",\r
- Status ));\r
- }\r
- else {\r
- //\r
- // The timer is now running\r
- //\r
- bTimerRunning = TRUE;\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Timer running\r\n",\r
- pTimer ));\r
- }\r
- }\r
-\r
- //\r
- // Return the operation status\r
- //\r
- return Status;\r
-}\r
-\r
-\r
-/**\r
- Destroy the timer\r
-\r
- @retval EFI_SUCCESS The timer was destroyed successfully\r
- @retval Other Failed to destroy the timer\r
-**/\r
-EFI_STATUS\r
-TimerDestroy (\r
- )\r
-{\r
- EFI_STATUS Status;\r
-\r
- //\r
- // Assume success\r
- //\r
- Status = EFI_SUCCESS;\r
-\r
- //\r
- // Determine if the timer is running\r
- //\r
- if ( bTimerRunning ) {\r
- //\r
- // Stop the timer\r
- //\r
- Status = TimerStop ( );\r
- }\r
- if (( !EFI_ERROR ( Status )) && ( NULL != pTimer )) {\r
- //\r
- // Done with this timer\r
- //\r
- Status = gBS->CloseEvent ( pTimer );\r
- if ( EFI_ERROR ( Status )) {\r
- DEBUG (( DEBUG_ERROR,\r
- "ERROR - Failed to free the timer event, Status: %r\r\n",\r
- Status ));\r
- }\r
- else {\r
- DEBUG (( DEBUG_INFO,\r
- "0x%08x: Timer Destroyed\r\n",\r
- pTimer ));\r
- pTimer = NULL;\r
- }\r
- }\r
-\r
- //\r
- // Return the operation status\r
- //\r
- return Status;\r
-}\r
-\r
-\r
-/**\r
- Receive data from the DataSource program to test a network's bandwidth.\r
-\r
- @param [in] Argc The number of arguments\r
- @param [in] Argv The argument value array\r
-\r
- @retval 0 The application exited normally.\r
- @retval Other An error occurred.\r
-**/\r
-int\r
-main (\r
- IN int Argc,\r
- IN char **Argv\r
- )\r
-{\r
- sa_family_t Family;\r
- EFI_STATUS Status;\r
-\r
- DEBUG (( DEBUG_INFO,\r
- "DataSink starting\r\n" ));\r
-\r
- //\r
- // Determine the family to use\r
- //\r
- Family = ( 1 < Argc ) ? AF_INET6 : AF_INET;\r
-\r
- //\r
- // Use for/break instead of goto\r
- //\r
- for ( ; ; ) {\r
- //\r
- // Create the timer\r
- //\r
- bTick = TRUE;\r
- Status = TimerCreate ( );\r
- if ( EFI_ERROR ( Status )) {\r
- break;\r
- }\r
-\r
- //\r
- // Start a timer to perform network polling and display updates\r
- //\r
- Status = TimerStart ( 1 * 1000 );\r
- if ( EFI_ERROR ( Status )) {\r
- break;\r
- }\r
-\r
- //\r
- // Loop forever waiting for abuse\r
- //\r
- do {\r
- ListenSocket = -1;\r
- do {\r
- //\r
- // Complete any client operations\r
- //\r
- Status = SocketPoll ( );\r
- if ( EFI_ERROR ( Status )) {\r
- //\r
- // Control-C\r
- //\r
- break;\r
- }\r
- \r
- //\r
- // Wait for a while\r
- //\r
- } while ( !bTick );\r
- if ( EFI_ERROR ( Status )) {\r
- //\r
- // Control-C\r
- //\r
- break;\r
- }\r
- \r
- //\r
- // Wait for the network layer to initialize\r
- //\r
- Status = SocketNew ( Family );\r
- if ( EFI_ERROR ( Status )) {\r
- continue;\r
- }\r
-\r
- //\r
- // Wait for the remote network application to start\r
- //\r
- Status = SocketAccept ( );\r
- if ( EFI_NOT_STARTED == Status ) {\r
- Status = SocketClose ( );\r
- continue;\r
- }\r
- else if ( EFI_SUCCESS != Status ) {\r
- //\r
- // Control-C\r
- //\r
- break;\r
- }\r
-\r
- //\r
- // Receive data until the connection breaks\r
- //\r
- do {\r
- Status = SocketPoll ( );\r
- } while ( !EFI_ERROR ( Status ));\r
-\r
- //\r
- // Done with the socket\r
- //\r
- Status = SocketClose ( );\r
- } while ( !EFI_ERROR ( Status ));\r
-\r
- //\r
- // Close the socket if necessary\r
- //\r
- SocketClose ( );\r
-\r
- //\r
- // All done\r
- //\r
- break;\r
- }\r
-\r
- //\r
- // Stop the timer if necessary\r
- //\r
- TimerStop ( );\r
- TimerDestroy ( );\r
-\r
- //\r
- // Return the operation status\r
- //\r
- DEBUG (( DEBUG_INFO,\r
- "DataSink exiting, Status: %r\r\n",\r
- Status ));\r
- return Status;\r
-}\r
projects / mirror_edk2.git / blobdiff