sergiotarxz/nuttx
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

net/tcp: new api tcp_dataconcat() to concatenate/pack iob chain

Browse Source 
Signed-off-by: chao an <anchao@xiaomi.com>
This commit is contained in:
chao an 2023-01-06 13:50:43 +08:00 committed by Xiang Xiao
parent b362f18d6a
commit 0e7d397553
2 changed files with 54 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
net/tcp/tcp.h
View File

@ -1278,6 +1278,21 @@ uint16_t tcp_datahandler(FAR struct net_driver_s *dev,
FAR struct tcp_conn_s *conn,
uint16_t offset);
/****************************************************************************
* Name: tcp_dataconcat
*
* Description:
* Concatenate iob_s chain iob2 to iob1, if CONFIG_NET_TCP_RECV_PACK is
* endabled, pack all data in the I/O buffer chain.
*
* Returned Value:
* The number of bytes actually buffered is returned. This will be either
* zero or equal to iob1->io_pktlen.
*
****************************************************************************/
uint16_t tcp_dataconcat(FAR struct iob_s **iob1, FAR struct iob_s **iob2);
/****************************************************************************
* Name: tcp_backlogcreate
*

54
net/tcp/tcp_callback.c
View File

@ -196,6 +196,43 @@ uint16_t tcp_callback(FAR struct net_driver_s *dev,
return flags;
}
/****************************************************************************
* Name: tcp_dataconcat
*
* Description:
* Concatenate iob_s chain iob2 to iob1, if CONFIG_NET_TCP_RECV_PACK is
* endabled, pack all data in the I/O buffer chain.
*
* Returned Value:
* The number of bytes actually buffered is returned. This will be either
* zero or equal to iob->io_pktlen.
*
****************************************************************************/
uint16_t tcp_dataconcat(FAR struct iob_s **iob1, FAR struct iob_s **iob2)
{
if (*iob1 == NULL)
{
*iob1 = *iob2;
}
else
{
iob_concat(*iob1, *iob2);
}
*iob2 = NULL;
#ifdef CONFIG_NET_TCP_RECV_PACK
/* Merge an iob chain into a continuous space, thereby reducing iob
* consumption.
*/
*iob1 = iob_pack(*iob1);
#endif
return (*iob1)->io_pktlen;
}
/****************************************************************************
* Name: tcp_datahandler
*
@ -247,22 +284,9 @@ uint16_t tcp_datahandler(FAR struct net_driver_s *dev,
/* Concat the iob to readahead */
if (conn->readahead == NULL)
{
conn->readahead = iob;
}
else
{
iob_concat(conn->readahead, iob);
}
tcp_dataconcat(&conn->readahead, &iob);
#ifdef CONFIG_NET_TCP_RECV_PACK
/* Merge an iob chain into a continuous space, thereby reducing iob
* consumption.
*/
conn->readahead = iob_pack(conn->readahead);
#endif
/* Clear device buffer */
netdev_iob_clear(dev);