Searched refs:DataQueue (Results 1 – 4 of 4) sorted by relevance
33 NetbufList = &(Sockbuf->DataQueue->BufList); in SockBufFirst()60 NetbufList = &(Sockbuf->DataQueue->BufList); in SockBufNext()223 Sock->RcvBuffer.DataQueue, in SockSetTcpRxData()346 NetbufQueTrim (Sock->RcvBuffer.DataQueue, TokenRcvdBytes); in SockProcessRcvToken()397 NetbufQueAppend (Sock->SndBuffer.DataQueue, SndData); in SockProcessTcpSndData()550 ASSERT (Sock->RcvBuffer.DataQueue != NULL); in SockWakeRcvToken()552 RcvdBytes = (Sock->RcvBuffer.DataQueue)->BufSize; in SockWakeRcvToken()638 Sock->SndBuffer.DataQueue = NetbufQueAlloc (); in SockCreate()639 if (NULL == Sock->SndBuffer.DataQueue) { in SockCreate()648 Sock->RcvBuffer.DataQueue = NetbufQueAlloc (); in SockCreate()[all …]
261 #define GET_RCV_DATASIZE(Sock) (((Sock)->RcvBuffer.DataQueue)->BufSize)290 #define GET_SND_DATASIZE(Sock) (((Sock)->SndBuffer.DataQueue)->BufSize)365 NET_BUF_QUEUE *DataQueue; ///< The queue to buffer data member
185 Sock->RcvBuffer.DataQueue, in SockSetTcpRxData()235 NetbufQueTrim (Sock->RcvBuffer.DataQueue, TokenRcvdBytes); in SockProcessRcvToken()285 NetbufQueAppend (Sock->SndBuffer.DataQueue, SndData); in SockProcessTcpSndData()439 ASSERT (Sock->RcvBuffer.DataQueue != NULL); in SockWakeRcvToken()441 RcvdBytes = (Sock->RcvBuffer.DataQueue)->BufSize; in SockWakeRcvToken()594 Sock->SndBuffer.DataQueue = NetbufQueAlloc (); in SockCreate()595 if (NULL == Sock->SndBuffer.DataQueue) { in SockCreate()602 Sock->RcvBuffer.DataQueue = NetbufQueAlloc (); in SockCreate()603 if (NULL == Sock->RcvBuffer.DataQueue) { in SockCreate()695 if (NULL != Sock->SndBuffer.DataQueue) { in SockCreate()[all …]
247 #define GET_RCV_DATASIZE(Sock) (((Sock)->RcvBuffer.DataQueue)->BufSize)276 #define GET_SND_DATASIZE(Sock) (((Sock)->SndBuffer.DataQueue)->BufSize)377 NET_BUF_QUEUE *DataQueue; ///< The queue to buffer data member