**/\r
NET_BUF *\r
SockBufFirst (\r
- IN SOCK_BUFFER *Sockbuf\r
+ IN SOCK_BUFFER *Sockbuf\r
)\r
{\r
LIST_ENTRY *NetbufList;\r
**/\r
NET_BUF *\r
SockBufNext (\r
- IN SOCK_BUFFER *Sockbuf,\r
- IN NET_BUF *SockEntry\r
+ IN SOCK_BUFFER *Sockbuf,\r
+ IN NET_BUF *SockEntry\r
)\r
{\r
LIST_ENTRY *NetbufList;\r
if ((SockEntry->List.ForwardLink == NetbufList) ||\r
(SockEntry->List.BackLink == &SockEntry->List) ||\r
(SockEntry->List.ForwardLink == &SockEntry->List)\r
- ) {\r
-\r
+ )\r
+ {\r
return NULL;\r
}\r
\r
VOID\r
EFIAPI\r
SockFreeFoo (\r
- IN VOID *Arg\r
+ IN VOID *Arg\r
)\r
{\r
return;\r
**/\r
UINT32\r
SockTcpDataToRcv (\r
- IN SOCK_BUFFER *SockBuffer,\r
- OUT BOOLEAN *IsUrg,\r
- IN UINT32 BufLen\r
+ IN SOCK_BUFFER *SockBuffer,\r
+ OUT BOOLEAN *IsUrg,\r
+ IN UINT32 BufLen\r
)\r
{\r
NET_BUF *RcvBufEntry;\r
RcvBufEntry = SockBufFirst (SockBuffer);\r
ASSERT (RcvBufEntry != NULL);\r
\r
- TcpRsvData = (TCP_RSV_DATA *) RcvBufEntry->ProtoData;\r
+ TcpRsvData = (TCP_RSV_DATA *)RcvBufEntry->ProtoData;\r
\r
//\r
// Check whether the receive data is out of bound. If yes, calculate the maximum\r
// allowed length of the urgent data and output it.\r
//\r
- *IsUrg = (BOOLEAN) ((TcpRsvData->UrgLen > 0) ? TRUE : FALSE);\r
+ *IsUrg = (BOOLEAN)((TcpRsvData->UrgLen > 0) ? TRUE : FALSE);\r
\r
if (*IsUrg && (TcpRsvData->UrgLen < RcvBufEntry->TotalSize)) {\r
-\r
DataLen = MIN (TcpRsvData->UrgLen, BufLen);\r
\r
if (DataLen < TcpRsvData->UrgLen) {\r
}\r
\r
return DataLen;\r
-\r
}\r
\r
//\r
// Process the next socket receive buffer to get the maximum allowed length\r
// of the received data.\r
//\r
- DataLen = RcvBufEntry->TotalSize;\r
+ DataLen = RcvBufEntry->TotalSize;\r
\r
RcvBufEntry = SockBufNext (SockBuffer, RcvBufEntry);\r
\r
while ((BufLen > DataLen) && (RcvBufEntry != NULL)) {\r
+ TcpRsvData = (TCP_RSV_DATA *)RcvBufEntry->ProtoData;\r
\r
- TcpRsvData = (TCP_RSV_DATA *) RcvBufEntry->ProtoData;\r
-\r
- Urg = (BOOLEAN) ((TcpRsvData->UrgLen > 0) ? TRUE : FALSE);\r
+ Urg = (BOOLEAN)((TcpRsvData->UrgLen > 0) ? TRUE : FALSE);\r
\r
if (*IsUrg != Urg) {\r
break;\r
}\r
\r
- if (*IsUrg && TcpRsvData->UrgLen < RcvBufEntry->TotalSize) {\r
-\r
+ if (*IsUrg && (TcpRsvData->UrgLen < RcvBufEntry->TotalSize)) {\r
if (TcpRsvData->UrgLen + DataLen < BufLen) {\r
TcpRsvData->UrgLen = 0;\r
} else {\r
}\r
\r
return MIN (TcpRsvData->UrgLen + DataLen, BufLen);\r
-\r
}\r
\r
DataLen += RcvBufEntry->TotalSize;\r
**/\r
VOID\r
SockSetTcpRxData (\r
- IN SOCKET *Sock,\r
- IN VOID *TcpRxData,\r
- IN UINT32 RcvdBytes,\r
- IN BOOLEAN IsUrg\r
+ IN SOCKET *Sock,\r
+ IN VOID *TcpRxData,\r
+ IN UINT32 RcvdBytes,\r
+ IN BOOLEAN IsUrg\r
)\r
{\r
UINT32 Index;\r
EFI_TCP4_RECEIVE_DATA *RxData;\r
EFI_TCP4_FRAGMENT_DATA *Fragment;\r
\r
- RxData = (EFI_TCP4_RECEIVE_DATA *) TcpRxData;\r
+ RxData = (EFI_TCP4_RECEIVE_DATA *)TcpRxData;\r
\r
- OffSet = 0;\r
+ OffSet = 0;\r
\r
ASSERT (RxData->DataLength >= RcvdBytes);\r
\r
- RxData->DataLength = RcvdBytes;\r
- RxData->UrgentFlag = IsUrg;\r
+ RxData->DataLength = RcvdBytes;\r
+ RxData->UrgentFlag = IsUrg;\r
\r
//\r
// Copy the CopyBytes data from socket receive buffer to RxData.\r
//\r
for (Index = 0; (Index < RxData->FragmentCount) && (RcvdBytes > 0); Index++) {\r
-\r
Fragment = &RxData->FragmentTable[Index];\r
- CopyBytes = MIN ((UINT32) (Fragment->FragmentLength), RcvdBytes);\r
+ CopyBytes = MIN ((UINT32)(Fragment->FragmentLength), RcvdBytes);\r
\r
NetbufQueCopy (\r
Sock->RcvBuffer.DataQueue,\r
);\r
\r
Fragment->FragmentLength = CopyBytes;\r
- RcvdBytes -= CopyBytes;\r
- OffSet += CopyBytes;\r
+ RcvdBytes -= CopyBytes;\r
+ OffSet += CopyBytes;\r
}\r
}\r
\r
**/\r
VOID\r
SockProcessSndToken (\r
- IN OUT SOCKET *Sock\r
+ IN OUT SOCKET *Sock\r
)\r
{\r
UINT32 FreeSpace;\r
// socket layer flow control policy\r
//\r
while ((FreeSpace >= Sock->SndBuffer.LowWater) && !IsListEmpty (&Sock->SndTokenList)) {\r
-\r
SockToken = NET_LIST_HEAD (\r
&(Sock->SndTokenList),\r
SOCK_TOKEN,\r
//\r
// Process it in the light of SockType\r
//\r
- SndToken = (SOCK_IO_TOKEN *) SockToken->Token;\r
- TxData = SndToken->Packet.TxData;\r
+ SndToken = (SOCK_IO_TOKEN *)SockToken->Token;\r
+ TxData = SndToken->Packet.TxData;\r
\r
- DataLen = TxData->DataLength;\r
- Status = SockProcessTcpSndData (Sock, TxData);\r
+ DataLen = TxData->DataLength;\r
+ Status = SockProcessTcpSndData (Sock, TxData);\r
\r
if (EFI_ERROR (Status)) {\r
goto OnError;\r
\r
if (DataLen >= FreeSpace) {\r
FreeSpace = 0;\r
-\r
} else {\r
FreeSpace -= DataLen;\r
-\r
}\r
}\r
\r
**/\r
UINT32\r
SockProcessRcvToken (\r
- IN OUT SOCKET *Sock,\r
- IN OUT SOCK_IO_TOKEN *RcvToken\r
+ IN OUT SOCKET *Sock,\r
+ IN OUT SOCK_IO_TOKEN *RcvToken\r
)\r
{\r
- UINT32 TokenRcvdBytes;\r
- EFI_TCP4_RECEIVE_DATA *RxData;\r
- BOOLEAN IsUrg;\r
+ UINT32 TokenRcvdBytes;\r
+ EFI_TCP4_RECEIVE_DATA *RxData;\r
+ BOOLEAN IsUrg;\r
\r
ASSERT (Sock != NULL);\r
\r
**/\r
EFI_STATUS\r
SockProcessTcpSndData (\r
- IN SOCKET *Sock,\r
- IN VOID *TcpTxData\r
+ IN SOCKET *Sock,\r
+ IN VOID *TcpTxData\r
)\r
{\r
NET_BUF *SndData;\r
EFI_STATUS Status;\r
EFI_TCP4_TRANSMIT_DATA *TxData;\r
\r
- TxData = (EFI_TCP4_TRANSMIT_DATA *) TcpTxData;\r
+ TxData = (EFI_TCP4_TRANSMIT_DATA *)TcpTxData;\r
\r
//\r
// transform this TxData into a NET_BUFFER\r
// and insert it into Sock->SndBuffer\r
//\r
SndData = NetbufFromExt (\r
- (NET_FRAGMENT *) TxData->FragmentTable,\r
+ (NET_FRAGMENT *)TxData->FragmentTable,\r
TxData->FragmentCount,\r
0,\r
0,\r
if (NULL == SndData) {\r
DEBUG (\r
(DEBUG_ERROR,\r
- "SockKProcessSndData: Failed to call NetBufferFromExt\n")\r
+ "SockKProcessSndData: Failed to call NetBufferFromExt\n")\r
);\r
\r
return EFI_OUT_OF_RESOURCES;\r
**/\r
VOID\r
SockFlushPendingToken (\r
- IN SOCKET *Sock,\r
- IN OUT LIST_ENTRY *PendingTokenList\r
+ IN SOCKET *Sock,\r
+ IN OUT LIST_ENTRY *PendingTokenList\r
)\r
{\r
- SOCK_TOKEN *SockToken;\r
- SOCK_COMPLETION_TOKEN *Token;\r
+ SOCK_TOKEN *SockToken;\r
+ SOCK_COMPLETION_TOKEN *Token;\r
\r
ASSERT ((Sock != NULL) && (PendingTokenList != NULL));\r
\r
**/\r
VOID\r
SockWakeConnToken (\r
- IN OUT SOCKET *Sock\r
+ IN OUT SOCKET *Sock\r
)\r
{\r
ASSERT (Sock->ConnectionToken != NULL);\r
**/\r
VOID\r
SockWakeListenToken (\r
- IN OUT SOCKET *Sock\r
+ IN OUT SOCKET *Sock\r
)\r
{\r
- SOCKET *Parent;\r
- SOCK_TOKEN *SockToken;\r
- EFI_TCP4_LISTEN_TOKEN *ListenToken;\r
+ SOCKET *Parent;\r
+ SOCK_TOKEN *SockToken;\r
+ EFI_TCP4_LISTEN_TOKEN *ListenToken;\r
\r
Parent = Sock->Parent;\r
\r
TokenList\r
);\r
\r
- ListenToken = (EFI_TCP4_LISTEN_TOKEN *) SockToken->Token;\r
+ ListenToken = (EFI_TCP4_LISTEN_TOKEN *)SockToken->Token;\r
ListenToken->NewChildHandle = Sock->SockHandle;\r
\r
SIGNAL_TOKEN (&(ListenToken->CompletionToken), EFI_SUCCESS);\r
Parent->ConnCnt--;\r
DEBUG (\r
(DEBUG_NET,\r
- "SockWakeListenToken: accept a socket, now conncnt is %d",\r
- Parent->ConnCnt)\r
+ "SockWakeListenToken: accept a socket, now conncnt is %d",\r
+ Parent->ConnCnt)\r
);\r
\r
Sock->Parent = NULL;\r
**/\r
VOID\r
SockWakeRcvToken (\r
- IN OUT SOCKET *Sock\r
+ IN OUT SOCKET *Sock\r
)\r
{\r
- UINT32 RcvdBytes;\r
- UINT32 TokenRcvdBytes;\r
- SOCK_TOKEN *SockToken;\r
- SOCK_IO_TOKEN *RcvToken;\r
+ UINT32 RcvdBytes;\r
+ UINT32 TokenRcvdBytes;\r
+ SOCK_TOKEN *SockToken;\r
+ SOCK_IO_TOKEN *RcvToken;\r
\r
ASSERT (Sock->RcvBuffer.DataQueue != NULL);\r
\r
ASSERT (RcvdBytes > 0);\r
\r
while (RcvdBytes > 0 && !IsListEmpty (&Sock->RcvTokenList)) {\r
-\r
SockToken = NET_LIST_HEAD (\r
&Sock->RcvTokenList,\r
SOCK_TOKEN,\r
TokenList\r
);\r
\r
- RcvToken = (SOCK_IO_TOKEN *) SockToken->Token;\r
- TokenRcvdBytes = SockProcessRcvToken (Sock, RcvToken);\r
+ RcvToken = (SOCK_IO_TOKEN *)SockToken->Token;\r
+ TokenRcvdBytes = SockProcessRcvToken (Sock, RcvToken);\r
\r
if (0 == TokenRcvdBytes) {\r
- return ;\r
+ return;\r
}\r
\r
RemoveEntryList (&(SockToken->TokenList));\r
IN OUT LIST_ENTRY *SpecifiedTokenList\r
)\r
{\r
- EFI_STATUS Status;\r
- LIST_ENTRY *Entry;\r
- SOCK_TOKEN *SockToken;\r
+ EFI_STATUS Status;\r
+ LIST_ENTRY *Entry;\r
+ SOCK_TOKEN *SockToken;\r
\r
Status = EFI_SUCCESS;\r
Entry = NULL;\r
SockToken = NULL;\r
\r
- if (IsListEmpty (SpecifiedTokenList) && Token != NULL) {\r
+ if (IsListEmpty (SpecifiedTokenList) && (Token != NULL)) {\r
return EFI_NOT_FOUND;\r
}\r
\r
RemoveEntryList (&SockToken->TokenList);\r
FreePool (SockToken);\r
\r
- Entry = SpecifiedTokenList->ForwardLink;\r
+ Entry = SpecifiedTokenList->ForwardLink;\r
Status = EFI_SUCCESS;\r
} else {\r
- if (Token == (VOID *) SockToken->Token) {\r
+ if (Token == (VOID *)SockToken->Token) {\r
SIGNAL_TOKEN (Token, EFI_ABORTED);\r
RemoveEntryList (&(SockToken->TokenList));\r
FreePool (SockToken);\r
**/\r
SOCKET *\r
SockCreate (\r
- IN SOCK_INIT_DATA *SockInitData\r
+ IN SOCK_INIT_DATA *SockInitData\r
)\r
{\r
SOCKET *Sock;\r
ProtocolLength = sizeof (EFI_TCP6_PROTOCOL);\r
}\r
\r
-\r
Parent = SockInitData->Parent;\r
\r
if ((Parent != NULL) && (Parent->ConnCnt == Parent->BackLog)) {\r
DEBUG (\r
(DEBUG_ERROR,\r
- "SockCreate: Socket parent has reached its connection limit with %d ConnCnt and %d BackLog\n",\r
- Parent->ConnCnt,\r
- Parent->BackLog)\r
+ "SockCreate: Socket parent has reached its connection limit with %d ConnCnt and %d BackLog\n",\r
+ Parent->ConnCnt,\r
+ Parent->BackLog)\r
);\r
\r
return NULL;\r
\r
Sock = AllocateZeroPool (sizeof (SOCKET));\r
if (NULL == Sock) {\r
-\r
DEBUG ((DEBUG_ERROR, "SockCreate: No resource to create a new socket\n"));\r
return NULL;\r
}\r
if (NULL == Sock->SndBuffer.DataQueue) {\r
DEBUG (\r
(DEBUG_ERROR,\r
- "SockCreate: No resource to allocate SndBuffer for new socket\n")\r
+ "SockCreate: No resource to allocate SndBuffer for new socket\n")\r
);\r
\r
goto OnError;\r
if (NULL == Sock->RcvBuffer.DataQueue) {\r
DEBUG (\r
(DEBUG_ERROR,\r
- "SockCreate: No resource to allocate RcvBuffer for new socket\n")\r
+ "SockCreate: No resource to allocate RcvBuffer for new socket\n")\r
);\r
\r
goto OnError;\r
}\r
\r
- Sock->Signature = SOCK_SIGNATURE;\r
+ Sock->Signature = SOCK_SIGNATURE;\r
\r
Sock->Parent = Parent;\r
Sock->BackLog = SockInitData->BackLog;\r
Sock->DestroyCallback = SockInitData->DestroyCallback;\r
Sock->Context = SockInitData->Context;\r
\r
- Sock->SockError = EFI_ABORTED;\r
- Sock->SndBuffer.LowWater = SOCK_BUFF_LOW_WATER;\r
- Sock->RcvBuffer.LowWater = SOCK_BUFF_LOW_WATER;\r
+ Sock->SockError = EFI_ABORTED;\r
+ Sock->SndBuffer.LowWater = SOCK_BUFF_LOW_WATER;\r
+ Sock->RcvBuffer.LowWater = SOCK_BUFF_LOW_WATER;\r
\r
- Sock->IpVersion = SockInitData->IpVersion;\r
+ Sock->IpVersion = SockInitData->IpVersion;\r
\r
//\r
// Install protocol on Sock->SockHandle\r
if (EFI_ERROR (Status)) {\r
DEBUG (\r
(DEBUG_ERROR,\r
- "SockCreate: Install TCP protocol in socket failed with %r\n",\r
- Status)\r
+ "SockCreate: Install TCP protocol in socket failed with %r\n",\r
+ Status)\r
);\r
\r
goto OnError;\r
\r
DEBUG (\r
(DEBUG_NET,\r
- "SockCreate: Create a new socket and add to parent, now conncnt is %d\n",\r
- Parent->ConnCnt)\r
+ "SockCreate: Create a new socket and add to parent, now conncnt is %d\n",\r
+ Parent->ConnCnt)\r
);\r
\r
InsertTailList (&Parent->ConnectionList, &Sock->ConnectionList);\r
**/\r
VOID\r
SockDestroy (\r
- IN OUT SOCKET *Sock\r
+ IN OUT SOCKET *Sock\r
)\r
{\r
ASSERT (SockStream == Sock->Type);\r
// by sock and rcv, snd buffer\r
//\r
if (!SOCK_IS_UNCONFIGURED (Sock)) {\r
-\r
SockConnFlush (Sock);\r
SockSetState (Sock, SO_CLOSED);\r
Sock->ConfigureState = SO_UNCONFIGURED;\r
-\r
}\r
+\r
//\r
// Destroy the RcvBuffer Queue and SendBuffer Queue\r
//\r
// Remove it from parent connection list if needed\r
//\r
if (Sock->Parent != NULL) {\r
-\r
RemoveEntryList (&(Sock->ConnectionList));\r
(Sock->Parent->ConnCnt)--;\r
\r
DEBUG (\r
(DEBUG_WARN,\r
- "SockDestroy: Delete a unaccepted socket from parent now conncnt is %d\n",\r
- Sock->Parent->ConnCnt)\r
+ "SockDestroy: Delete a unaccepted socket from parent now conncnt is %d\n",\r
+ Sock->Parent->ConnCnt)\r
);\r
\r
Sock->Parent = NULL;\r
**/\r
VOID\r
SockConnFlush (\r
- IN OUT SOCKET *Sock\r
+ IN OUT SOCKET *Sock\r
)\r
{\r
SOCKET *Child;\r
\r
Sock->ConnCnt = 0;\r
}\r
-\r
}\r
\r
/**\r
**/\r
VOID\r
SockSetState (\r
- IN OUT SOCKET *Sock,\r
- IN UINT8 State\r
+ IN OUT SOCKET *Sock,\r
+ IN UINT8 State\r
)\r
{\r
Sock->State = State;\r
**/\r
SOCKET *\r
SockClone (\r
- IN SOCKET *Sock\r
+ IN SOCKET *Sock\r
)\r
{\r
SOCKET *ClonedSock;\r
InitData.ProtoData = Sock->ProtoReserved;\r
InitData.DataSize = sizeof (Sock->ProtoReserved);\r
\r
- ClonedSock = SockCreate (&InitData);\r
+ ClonedSock = SockCreate (&InitData);\r
\r
if (NULL == ClonedSock) {\r
DEBUG ((DEBUG_ERROR, "SockClone: no resource to create a cloned sock\n"));\r
**/\r
VOID\r
SockConnEstablished (\r
- IN OUT SOCKET *Sock\r
+ IN OUT SOCKET *Sock\r
)\r
{\r
-\r
ASSERT (SO_CONNECTING == Sock->State);\r
\r
SockSetState (Sock, SO_CONNECTED);\r
} else {\r
SockWakeListenToken (Sock);\r
}\r
-\r
}\r
\r
/**\r
**/\r
VOID\r
SockConnClosed (\r
- IN OUT SOCKET *Sock\r
+ IN OUT SOCKET *Sock\r
)\r
{\r
if (Sock->CloseToken != NULL) {\r
if (Sock->Parent != NULL) {\r
SockDestroyChild (Sock);\r
}\r
-\r
}\r
\r
/**\r
**/\r
VOID\r
SockDataSent (\r
- IN OUT SOCKET *Sock,\r
- IN UINT32 Count\r
+ IN OUT SOCKET *Sock,\r
+ IN UINT32 Count\r
)\r
{\r
- SOCK_TOKEN *SockToken;\r
- SOCK_COMPLETION_TOKEN *SndToken;\r
+ SOCK_TOKEN *SockToken;\r
+ SOCK_COMPLETION_TOKEN *SndToken;\r
\r
ASSERT (!IsListEmpty (&Sock->ProcessingSndTokenList));\r
ASSERT (Count <= (Sock->SndBuffer.DataQueue)->BufSize);\r
SndToken = SockToken->Token;\r
\r
if (SockToken->RemainDataLen <= Count) {\r
-\r
RemoveEntryList (&(SockToken->TokenList));\r
SIGNAL_TOKEN (SndToken, EFI_SUCCESS);\r
Count -= SockToken->RemainDataLen;\r
FreePool (SockToken);\r
} else {\r
-\r
SockToken->RemainDataLen -= Count;\r
- Count = 0;\r
+ Count = 0;\r
}\r
}\r
\r
**/\r
UINT32\r
SockGetDataToSend (\r
- IN SOCKET *Sock,\r
- IN UINT32 Offset,\r
- IN UINT32 Len,\r
- OUT UINT8 *Dest\r
+ IN SOCKET *Sock,\r
+ IN UINT32 Offset,\r
+ IN UINT32 Len,\r
+ OUT UINT8 *Dest\r
)\r
{\r
ASSERT ((Sock != NULL) && SockStream == Sock->Type);\r
\r
return NetbufQueCopy (\r
- Sock->SndBuffer.DataQueue,\r
- Offset,\r
- Len,\r
- Dest\r
- );\r
+ Sock->SndBuffer.DataQueue,\r
+ Offset,\r
+ Len,\r
+ Dest\r
+ );\r
}\r
\r
/**\r
**/\r
VOID\r
SockDataRcvd (\r
- IN OUT SOCKET *Sock,\r
- IN OUT NET_BUF *NetBuffer,\r
- IN UINT32 UrgLen\r
+ IN OUT SOCKET *Sock,\r
+ IN OUT NET_BUF *NetBuffer,\r
+ IN UINT32 UrgLen\r
)\r
{\r
- ASSERT ((Sock != NULL) && (Sock->RcvBuffer.DataQueue != NULL) &&\r
- UrgLen <= NetBuffer->TotalSize);\r
+ ASSERT (\r
+ (Sock != NULL) && (Sock->RcvBuffer.DataQueue != NULL) &&\r
+ UrgLen <= NetBuffer->TotalSize\r
+ );\r
\r
NET_GET_REF (NetBuffer);\r
\r
- ((TCP_RSV_DATA *) (NetBuffer->ProtoData))->UrgLen = UrgLen;\r
+ ((TCP_RSV_DATA *)(NetBuffer->ProtoData))->UrgLen = UrgLen;\r
\r
NetbufQueAppend (Sock->RcvBuffer.DataQueue, NetBuffer);\r
\r
IN UINT32 Which\r
)\r
{\r
- UINT32 BufferCC;\r
- SOCK_BUFFER *SockBuffer;\r
+ UINT32 BufferCC;\r
+ SOCK_BUFFER *SockBuffer;\r
\r
ASSERT (Sock != NULL && ((SOCK_SND_BUF == Which) || (SOCK_RCV_BUF == Which)));\r
\r
BufferCC = (SockBuffer->DataQueue)->BufSize;\r
\r
if (BufferCC >= SockBuffer->HighWater) {\r
-\r
return 0;\r
}\r
\r
**/\r
VOID\r
SockNoMoreData (\r
- IN OUT SOCKET *Sock\r
+ IN OUT SOCKET *Sock\r
)\r
{\r
EFI_STATUS Err;\r
SOCK_NO_MORE_DATA (Sock);\r
\r
if (!IsListEmpty (&Sock->RcvTokenList)) {\r
-\r
ASSERT (0 == GET_RCV_DATASIZE (Sock));\r
\r
Err = Sock->SockError;\r
SockFlushPendingToken (Sock, &Sock->RcvTokenList);\r
\r
SOCK_ERROR (Sock, Err);\r
-\r
}\r
}\r