LWIP實(shí)現(xiàn)千兆TCP/IP網(wǎng)絡(luò)傳輸方案介紹

一、前言

之前ZYNQ與PC之間的網(wǎng)絡(luò)連接依賴于外接硬件協(xié)議棧芯片，雖然C驅(qū)動(dòng)非常簡單，但網(wǎng)絡(luò)帶寬受限?，F(xiàn)采用LWIP+PS端MAC控制器+PHY芯片的通用架構(gòu)。關(guān)于LWIP庫，已經(jīng)有很多現(xiàn)成的資料和書籍。其有兩套API，一個(gè)是SOCKET，另一個(gè)是本例中要用到的RAW。RAW API理解起來較為復(fù)雜，整個(gè)程序基于中斷機(jī)制運(yùn)行，通過函數(shù)指針完成多層回調(diào)函數(shù)的執(zhí)行。SOCKET API需要支持多線程操作系統(tǒng)的支持，也犧牲了效率，但理解和編程都較為容易。實(shí)際上SOCKET API是對(duì)RAW API的進(jìn)一步封裝。

二、LWIP Echo Server demo解讀

首先打開Xilinx SDK自帶的LwIP Echo Server demo.
/******************************************************************************
*
* Copyright (C) 2009 - 2014 Xilinx, Inc. All rights reserved.
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to deal
* in the Software without restriction, including without limitation the rights
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in
* all copies or substantial portions of the Software.
*
* Use of the Software is limited solely to applications:
* (a) running on a Xilinx device, or
* (b) that interact with a Xilinx device through a bus or interconnect.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
* XILINX BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
* WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF
* OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
* SOFTWARE.
*
* Except as contained in this notice, the name of the Xilinx shall not be used
* in advertising or otherwise to promote the sale, use or other dealings in
* this Software without prior written authorization from Xilinx.
*
******************************************************************************/

#include

#include "xparameters.h"

#include "netif/xadapter.h"

#include "platform.h"
#include "platform_config.h"
#if defined (__arm__) || defined(__aarch64__)
#include "xil_printf.h"
#endif

#include "lwip/tcp.h"
#include "xil_cache.h"

#if LWIP_DHCP==1
#include "lwip/dhcp.h"
#endif

/* defined by each RAW mode application */
void print_app_header();
int start_application();
int transfer_data();
void tcp_fasttmr(void);
void tcp_slowtmr(void);

/* missing declaration in lwIP */
void lwip_init();

#if LWIP_DHCP==1
extern volatile int dhcp_timoutcntr;
err_t dhcp_start(struct netif *netif);
#endif

extern volatile int TcpFastTmrFlag;
extern volatile int TcpSlowTmrFlag;
static struct netif server_netif;
struct netif *echo_netif;

void
print_ip(char *msg, struct ip_addr *ip)
{
print(msg);
xil_printf("%d.%d.%d.%d/n/r", ip4_addr1(ip), ip4_addr2(ip),
ip4_addr3(ip), ip4_addr4(ip));
}

void
print_ip_settings(struct ip_addr *ip, struct ip_addr *mask, struct ip_addr *gw)
{

print_ip("Board IP: ", ip);
print_ip("Netmask : ", mask);
print_ip("Gateway : ", gw);
}

#if defined (__arm__) && !defined (ARMR5)
#if XPAR_GIGE_PCS_PMA_SGMII_CORE_PRESENT == 1 || XPAR_GIGE_PCS_PMA_1000BASEX_CORE_PRESENT == 1
int ProgramSi5324(void);
int ProgramSfpPhy(void);
#endif
#endif

#ifdef XPS_BOARD_ZCU102
#ifdef XPAR_XIICPS_0_DEVICE_ID
int IicPhyReset(void);
#endif
#endif

int main()
{
struct ip_addr ipaddr, netmask, gw;

/* the mac address of the board. this should be unique per board */
unsigned char mac_ethernet_address[] =
{ 0x00, 0x0a, 0x35, 0x00, 0x01, 0x02 };

echo_netif = &server_netif;
#if defined (__arm__) && !defined (ARMR5)
#if XPAR_GIGE_PCS_PMA_SGMII_CORE_PRESENT == 1 || XPAR_GIGE_PCS_PMA_1000BASEX_CORE_PRESENT == 1
ProgramSi5324();
ProgramSfpPhy();
#endif
#endif

/* Define this board specific macro in order perform PHY reset on ZCU102 */
#ifdef XPS_BOARD_ZCU102
IicPhyReset();
#endif

init_platform();

#if LWIP_DHCP==1
ipaddr.addr = 0;
gw.addr = 0;
netmask.addr = 0;
#else
/* initliaze IP addresses to be used */
IP4_ADDR(&ipaddr, 192, 168, 1, 10);
IP4_ADDR(&netmask, 255, 255, 255, 0);
IP4_ADDR(&gw, 192, 168, 1, 1);
#endif
print_app_header();

lwip_init();//網(wǎng)絡(luò)參數(shù)初始化

/* Add network interface to the netif_list, and set it as default */
if (!xemac_add(echo_netif, &ipaddr, &netmask,
&gw, mac_ethernet_address,
PLATFORM_EMAC_BASEADDR)) {
xil_printf("Error adding N/W interface/n/r");
return -1;
}
netif_set_default(echo_netif);

/* now enable interrupts */
platform_enable_interrupts();

/* specify that the network if is up */
netif_set_up(echo_netif);

#if (LWIP_DHCP==1)
/* Create a new DHCP client for this interface.
* Note: you must call dhcp_fine_tmr() and dhcp_coarse_tmr() at
* the predefined regular intervals after starting the client.
*/
dhcp_start(echo_netif);
dhcp_timoutcntr = 24;

while(((echo_netif->ip_addr.addr) == 0) && (dhcp_timoutcntr > 0))
xemacif_input(echo_netif);

if (dhcp_timoutcntr if ((echo_netif->ip_addr.addr) == 0) {
xil_printf("DHCP Timeout/r/n");
xil_printf("Configuring default IP of 192.168.1.10/r/n");
IP4_ADDR(&(echo_netif->ip_addr), 192, 168, 1, 10);
IP4_ADDR(&(echo_netif->netmask), 255, 255, 255, 0);
IP4_ADDR(&(echo_netif->gw), 192, 168, 1, 1);
}
}

ipaddr.addr = echo_netif->ip_addr.addr;
gw.addr = echo_netif->gw.addr;
netmask.addr = echo_netif->netmask.addr;
#endif

print_ip_settings(&ipaddr, &netmask, &gw);//打印關(guān)鍵網(wǎng)絡(luò)參數(shù)

/* start the application (web server, rxtest, txtest, etc..) */
start_application();//設(shè)置回調(diào)函數(shù)，這些函數(shù)在特定事件發(fā)生時(shí)以函數(shù)指針的方式被調(diào)用

/* receive and process packets */
while (1) {
if (TcpFastTmrFlag) {//發(fā)送處理，如差錯(cuò)重傳，通過定時(shí)器置位標(biāo)志位
tcp_fasttmr();
TcpFastTmrFlag = 0;
}
if (TcpSlowTmrFlag) {
tcp_slowtmr();
TcpSlowTmrFlag = 0;
}
xemacif_input(echo_netif);//連續(xù)接收數(shù)據(jù)包，并將數(shù)據(jù)包存入LWIP
transfer_data();//空函數(shù)
}

/* never reached */
cleanup_platform();

return 0;
}

echo

整體流程為：初始化LWIP、添加網(wǎng)絡(luò)接口（MAC）、使能中斷、設(shè)置回調(diào)函數(shù)。最終進(jìn)入主循環(huán)，內(nèi)部不斷檢測(cè)定時(shí)器中斷標(biāo)志位，當(dāng)標(biāo)志位TcpFastTmrFlag或TcpSlowTmrFlag為1則調(diào)用相應(yīng)的處理函數(shù)，完成超時(shí)重傳等任務(wù)。接下來查看回調(diào)函數(shù)的設(shè)置：
int start_application()
{
struct tcp_pcb *pcb;//protocol control block 簡稱PCB
err_t err;
unsigned port = 7;

/* create new TCP PCB structure */
pcb = tcp_new();
if (!pcb) {
xil_printf("Error creating PCB. Out of Memory/n/r");
return -1;
}

/* bind to specified @port */
err = tcp_bind(pcb, IP_ADDR_ANY, port);
if (err != ERR_OK) {
xil_printf("Unable to bind to port %d: err = %d/n/r", port, err);
return -2;
}

/* we do not need any arguments to callback functions */
tcp_arg(pcb, NULL);

/* listen for connections */
pcb = tcp_listen(pcb);
if (!pcb) {
xil_printf("Out of memory while tcp_listen/n/r");
return -3;
}

/* specify callback to use for incoming connections */
tcp_accept(pcb, accept_callback);

xil_printf("TCP echo server started @ port %d/n/r", port);

return 0;
}

start_application

創(chuàng)建PCB（protocol control block）建立連接、綁定IP地址和端口號(hào)、監(jiān)聽請(qǐng)求，最后tcp_accept函數(shù)用于指定當(dāng)監(jiān)聽到連接請(qǐng)求時(shí)調(diào)用的函數(shù)accept_callback。進(jìn)入該函數(shù)內(nèi)部查看：
err_t accept_callback(void *arg, struct tcp_pcb *newpcb, err_t err)
{
static int connection = 1;

/* set the receive callback for this connection */
tcp_recv(newpcb, recv_callback);

/* just use an integer number indicating the connection id as the
callback argument */
tcp_arg(newpcb, (void*)(UINTPTR)connection);

/* increment for subsequent accepted connections */
connection++;

return ERR_OK;
}

accept_callback

內(nèi)部主要通過tcp_recv函數(shù)來指定當(dāng)收到TCP包后調(diào)用的函數(shù)recv_callback。我們?cè)俅斡^察其內(nèi)容：
err_t recv_callback(void *arg, struct tcp_pcb *tpcb,
struct pbuf *p, err_t err)
{
/* do not read the packet if we are not in ESTABLISHED state */
if (!p) {
tcp_close(tpcb);
tcp_recv(tpcb, NULL);
return ERR_OK;
}

/* indicate that the packet has been received */
tcp_recved(tpcb, p->len);

/* echo back the payload */
/* in this case, we assume that the payload is if (tcp_sndbuf(tpcb) > p->len) {
err = tcp_write(tpcb, p->payload, p->len, 1);
} else
xil_printf("no space in tcp_sndbuf/n/r");

/* free the received pbuf */
pbuf_free(p);

return ERR_OK;
}

recv_callback

tcp_recved函數(shù)指示用來告知LWIP接收數(shù)據(jù)量，然后檢測(cè)發(fā)送緩沖區(qū)是否足夠容納接收內(nèi)容，若大于則調(diào)用tcp_write函數(shù)將接收數(shù)據(jù)寫入發(fā)送緩沖區(qū)等待發(fā)送。綜上，整體的調(diào)用流程為：tcp_accept -> accept_callback -> tcp_recv -> recv_callback -> tcp_recved和tcp_write。前四個(gè)用于接收，后兩個(gè)用于發(fā)送。

函數(shù)解析完畢，之后改動(dòng)上位機(jī)網(wǎng)絡(luò)參數(shù)，使PC機(jī)IP地址與Board在同一網(wǎng)段內(nèi)，這里設(shè)置為192.168.1.11.打開網(wǎng)絡(luò)調(diào)試助手，設(shè)置PC為TCP Client。以下是ZYNQ串口打印及網(wǎng)絡(luò)調(diào)試結(jié)果。

三、TCP Client Send data

現(xiàn)在我們來改動(dòng)demo，設(shè)計(jì)一個(gè)客戶端發(fā)送數(shù)據(jù)包的示例工程，功能是循環(huán)發(fā)送一個(gè)常數(shù)數(shù)組中數(shù)據(jù)到遠(yuǎn)程服務(wù)器。該工程參考米聯(lián)客教程中相關(guān)章節(jié)內(nèi)容。代碼如下：
/******************************************************************************
*
* Copyright (C) 2009 - 2014 Xilinx, Inc. All rights reserved.
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to deal
* in the Software without restriction, including without limitation the rights
* to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
* copies of the Software, and to permit persons to whom the Software is
* furnished to do so, subject to the following conditions:
*
* The above copyright notice and this permission notice shall be included in
* all copies or substantial portions of the Software.
*
* Use of the Software is limited solely to applications:
* (a) running on a Xilinx device, or
* (b) that interact with a Xilinx device through a bus or interconnect.
*
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
* XILINX BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
* WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF
* OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
* SOFTWARE.
*
* Except as contained in this notice, the name of the Xilinx shall not be used
* in advertising or otherwise to promote the sale, use or other dealings in
* this Software without prior written authorization from Xilinx.
*
******************************************************************************/

#include

#include "xparameters.h"

#include "netif/xadapter.h"

#include "platform.h"
#include "platform_config.h"
#if defined (__arm__) || defined(__aarch64__)
#include "xil_printf.h"
#endif

#include "lwip/tcp.h"
#include "xil_cache.h"

#if LWIP_DHCP==1
#include "lwip/dhcp.h"
#endif

/* defined by each RAW mode application */
void print_app_header();
int client_application();
//int start_application();
//int transfer_data();
int send_data();
void tcp_fasttmr(void);
void tcp_slowtmr(void);

/* missing declaration in lwIP */
void lwip_init();

#if LWIP_DHCP==1
extern volatile int dhcp_timoutcntr;
err_t dhcp_start(struct netif *netif);
#endif

extern volatile int TcpFastTmrFlag;
extern volatile int TcpSlowTmrFlag;
static struct netif server_netif;
struct netif *echo_netif;

void
print_ip(char *msg, struct ip_addr *ip)
{
print(msg);
xil_printf("%d.%d.%d.%d/n/r", ip4_addr1(ip), ip4_addr2(ip),
ip4_addr3(ip), ip4_addr4(ip));
}

void
print_ip_settings(struct ip_addr *ip, struct ip_addr *mask, struct ip_addr *gw)
{

print_ip("Board IP: ", ip);
print_ip("Netmask : ", mask);
print_ip("Gateway : ", gw);
}

int main()
{
uint cycle = 0;
struct ip_addr ipaddr, netmask, gw;

/* the mac address of the board. this should be unique per board */
unsigned char mac_ethernet_address[] =
{ 0x00, 0x0a, 0x35, 0x00, 0x01, 0x02 };

echo_netif = &server_netif;

/* Define this board specific macro in order perform PHY reset on ZCU102 */

init_platform();

/* initliaze IP addresses to be used */
IP4_ADDR(&ipaddr, 192, 168, 1, 10);
IP4_ADDR(&netmask, 255, 255, 255, 0);
IP4_ADDR(&gw, 192, 168, 1, 1);

print_app_header();

lwip_init();

/* Add network interface to the netif_list, and set it as default */
if (!xemac_add(echo_netif, &ipaddr, &netmask,
&gw, mac_ethernet_address,
PLATFORM_EMAC_BASEADDR)) {
xil_printf("Error adding N/W interface/n/r");
return -1;
}
netif_set_default(echo_netif);

/* now enable interrupts */
platform_enable_interrupts();

/* specify that the network if is up */
netif_set_up(echo_netif);

print_ip_settings(&ipaddr, &netmask, &gw);

/* start the application (web server, rxtest, txtest, etc..) */
//start_application();
client_application();

/* receive and process packets */
while (1) {
if (TcpFastTmrFlag) {
tcp_fasttmr();
TcpFastTmrFlag = 0;
}
if (TcpSlowTmrFlag) {
tcp_slowtmr();
TcpSlowTmrFlag = 0;
}
xemacif_input(echo_netif);
//transfer_data();
if(cycle == 9999){
cycle = 0;
send_data();
}
else
cycle++;
}

return 0;
}

main

函數(shù)定義：
/*
* tcp_trans.c
*
* Created on: 2018年10月18日
* Author: s
*/

#include
#include

#include "lwip/err.h"
#include "lwip/tcp.h"
#include "lwipopts.h"
#include "xil_cache.h"
#include "xil_printf.h"
#include "sleep.h"

#define TX_SIZE 10

static struct tcp_pcb*connected_pcb = NULL;
unsigned client_connected = 0;
//靜態(tài)全局函數(shù) 外部文件不可見
uint tcp_trans_done = 0;

u_char data[TX_SIZE] = {0,1,2,3,4,5,6,7,8,9};

int send_data()
{
err_t err;
struct tcp_pcb *tpcb = connected_pcb;

if (!tpcb)
return -1;

//判斷發(fā)送數(shù)據(jù)長度是否小于發(fā)送緩沖區(qū)剩余可用長度
if (TX_SIZE //Write data for sending (but does not send it immediately).
err = tcp_write(tpcb, data, TX_SIZE, 1);
if (err != ERR_OK) {
xil_printf("txperf: Error on tcp_write: %d/r/n", err);
connected_pcb = NULL;
return -1;
}

//Find out what we can send and send it
err = tcp_output(tpcb);
if (err != ERR_OK) {
xil_printf("txperf: Error on tcp_output: %d/r/n",err);
return -1;
}
}
else
xil_printf("no space in tcp_sndbuf/n/r");

return 0;
}

static err_t tcp_sent_callback(void *arg, struct tcp_pcb *tpcb,u16_t len)
{
tcp_trans_done ++;
return ERR_OK;
}

//tcp連接回調(diào)函數(shù) 設(shè)置為靜態(tài)函數(shù)，外部文件不可見
static err_t tcp_connected_callback(void *arg, struct tcp_pcb *tpcb, err_t err)
{
/* store state */
connected_pcb = tpcb;

/* set callback values & functions */
tcp_arg(tpcb, NULL);

//發(fā)送到遠(yuǎn)程主機(jī)后調(diào)用tcp_sent_callback
tcp_sent(tpcb, tcp_sent_callback);

client_connected = 1;

/* initiate data transfer */
return ERR_OK;
}

int client_application()
{
struct tcp_pcb *pcb;
struct ip_addr ipaddr;
err_t err;
unsigned port = 7;

/* create new TCP PCB structure */
pcb = tcp_new();
if (!pcb) {
xil_printf("Error creating PCB. Out of Memory/n/r");
return -1;
}

/* connect to iperf tcp server */
IP4_ADDR(&ipaddr, 192, 168, 1, 209);//設(shè)置要連接的主機(jī)的地址

//當(dāng)連接到主機(jī)時(shí)，調(diào)用tcp_connected_callback
err = tcp_connect(pcb, &ipaddr, port, tcp_connected_callback);
if (err != ERR_OK) {
xil_printf("txperf: tcp_connect returned error: %d/r/n", err);
return err;
}

return 0;
}

tcp_trans

可以看出還是一樣的套路，在client_application函數(shù)中設(shè)置回調(diào)函數(shù)。首先新建PCB，tcp_connect函數(shù)設(shè)定要連接遠(yuǎn)程服務(wù)器的IP地址和端口號(hào)，連接建立時(shí)將調(diào)用回調(diào)函數(shù)tcp_connected_callback。tcp_connected_callback內(nèi)部tcp_sent函數(shù)用于指定當(dāng)發(fā)送數(shù)據(jù)包完成后執(zhí)行的tcp_sent_callback。tcp_sent_callback內(nèi)部只利用tcp_trans_done變量計(jì)數(shù)發(fā)送次數(shù)。而真正的發(fā)送處理任務(wù)則交給主循環(huán)中的send_data。若處于連接狀態(tài)，且發(fā)送緩沖區(qū)容量比帶發(fā)送數(shù)據(jù)量大，則調(diào)用tcp_write將待發(fā)送數(shù)據(jù)寫入發(fā)送緩沖區(qū)，之后調(diào)用tcp_output函數(shù)立即傳輸發(fā)送緩沖區(qū)內(nèi)容。如果不調(diào)用tcp_output，LWIP會(huì)等待數(shù)據(jù)量達(dá)到一定值時(shí)一起發(fā)送來提高效率，是否調(diào)用tcp_output函數(shù)可根據(jù)具體需求而定。

接下來看下實(shí)驗(yàn)結(jié)果：

PC端正確接收到常數(shù)數(shù)組，實(shí)驗(yàn)無誤。

參考文獻(xiàn)：

1 LWIP 無OS RAW-API 函數(shù) - 專注的力量 - CSDN博客 https://blog.csdn.net/liang890319/article/details/8574603

2 解讀TCP 四種定時(shí)器 - xiaofei0859的專欄 - CSDN博客 https://blog.csdn.net/xiaofei0859/article/details/52794576

3 米聯(lián) 《ZYNQ SOC修煉秘籍》

編輯：hfy