Hello everyone,
we have been measuring throughput between PC Windows 7 and Zynq device
using iperf applications. For Windows 7, we use official iperf client
application, while for our Zynq based board we have downloaded iperf
lwIP RAW server implementation from Zynq manufacturer - Xilinx. We send
data from PC to Zynq.
As expected, throughput is quite high, almost 1Gb, but only after first
4 to 5 seconds. During this few first seconds, data transfer is almost
non-existent. Does anyone have idea what could be the cause of this? Is
there any way to avoid this and have active data transfers all the time
including this first few seconds?
I was thinking that problem could be to iperf client, however, even with
our basic client implementation, the behavior is the same.
In attachments I provide:
* iperf_throughput.png - screenshot of iperf measurements,
* lwipopts.h - our lwIP configuration file and
* rxperf.c - lwIP server implementation file.
If any additional information is needed, let me know.
Best regards,
Nenad
#ifndef __LWIPOPTS_H_
#define __LWIPOPTS_H_
#ifndef PROCESSOR_LITTLE_ENDIAN
#define PROCESSOR_LITTLE_ENDIAN
#endif
#define SYS_LIGHTWEIGHT_PROT 1
#define NO_SYS 1
#define LWIP_SOCKET 0
#define LWIP_COMPAT_SOCKETS 0
#define LWIP_NETCONN 0
#define NO_SYS_NO_TIMERS 1
#define LWIP_TCP_KEEPALIVE 0
#define MEM_ALIGNMENT 64
#define MEM_SIZE 393216
#define MEMP_NUM_PBUF 16
#define MEMP_NUM_UDP_PCB 4
#define MEMP_NUM_TCP_PCB 32
#define MEMP_NUM_TCP_PCB_LISTEN 8
#define MEMP_NUM_TCP_SEG 1024
#define MEMP_NUM_SYS_TIMEOUT 8
#define MEMP_NUM_NETBUF 8
#define MEMP_NUM_NETCONN 16
#define MEMP_NUM_TCPIP_MSG_API 16
#define MEMP_NUM_TCPIP_MSG_INPKT 64
#define MEMP_NUM_SYS_TIMEOUT 8
#define PBUF_POOL_SIZE 256
#define PBUF_POOL_BUFSIZE 1700
#define PBUF_LINK_HLEN 16
#define ARP_TABLE_SIZE 2
#define ARP_QUEUEING 0
#define ICMP_TTL 255
#define IP_OPTIONS 0
#define IP_FORWARD 0
#define IP_REASSEMBLY 1
#define IP_FRAG 1
#define IP_REASS_MAX_PBUFS 128
#define IP_FRAG_MAX_MTU 1500
#define IP_DEFAULT_TTL 255
#define LWIP_CHKSUM_ALGORITHM 3
#define LWIP_UDP 1
#define UDP_TTL 255
#define LWIP_TCP 1
#define TCP_MSS 1460
#define TCP_SND_BUF 32120
#define TCP_WND 64240
#define TCP_TTL 255
#define TCP_MAXRTX 12
#define TCP_SYNMAXRTX 4
#define TCP_QUEUE_OOSEQ 1
#define TCP_SND_QUEUELEN 16 * TCP_SND_BUF/TCP_MSS
#define CHECKSUM_GEN_TCP 0
#define CHECKSUM_GEN_UDP 0
#define CHECKSUM_GEN_IP 0
#define CHECKSUM_CHECK_TCP 0
#define CHECKSUM_CHECK_UDP 0
#define CHECKSUM_CHECK_IP 0
#define LWIP_FULL_CSUM_OFFLOAD_RX 1
#define LWIP_FULL_CSUM_OFFLOAD_TX 1
#define MEMP_SEPARATE_POOLS 1
#define MEMP_NUM_FRAG_PBUF 256
#define IP_OPTIONS_ALLOWED 0
#define TCP_OVERSIZE TCP_MSS
#define LWIP_DHCP 1
#define DHCP_DOES_ARP_CHECK 1
#define CONFIG_LINKSPEED_AUTODETECT 1
#define LWIP_NETIF_HOSTNAME 1
#endif
/*
* Copyright (c) 2007 Xilinx, Inc. All rights reserved.
*
* Xilinx, Inc.
* XILINX IS PROVIDING THIS DESIGN, CODE, OR INFORMATION "AS IS" AS A
* COURTESY TO YOU. BY PROVIDING THIS DESIGN, CODE, OR INFORMATION AS
* ONE POSSIBLE IMPLEMENTATION OF THIS FEATURE, APPLICATION OR
* STANDARD, XILINX IS MAKING NO REPRESENTATION THAT THIS IMPLEMENTATION
* IS FREE FROM ANY CLAIMS OF INFRINGEMENT, AND YOU ARE RESPONSIBLE
* FOR OBTAINING ANY RIGHTS YOU MAY REQUIRE FOR YOUR IMPLEMENTATION.
* XILINX EXPRESSLY DISCLAIMS ANY WARRANTY WHATSOEVER WITH RESPECT TO
* THE ADEQUACY OF THE IMPLEMENTATION, INCLUDING BUT NOT LIMITED TO
* ANY WARRANTIES OR REPRESENTATIONS THAT THIS IMPLEMENTATION IS FREE
* FROM CLAIMS OF INFRINGEMENT, IMPLIED WARRANTIES OF MERCHANTABILITY
* AND FITNESS FOR A PARTICULAR PURPOSE.
*
*/
#include <stdio.h>
#include <string.h>
#include "lwip/err.h"
#include "lwip/tcp.h"
#ifdef __arm__
#include "xil_printf.h"
#endif
static unsigned rxperf_port = 5001; /* iperf default port */
static unsigned rxperf_server_running = 0;
static unsigned txperf_server_running = 0;
extern struct tcp_pcb *connected_pcb;
void print_rxperf_app_header();
err_t
txperf_sent_callback(void *arg, struct tcp_pcb *tpcb, u16_t len);
int
transfer_rxperf_data() {
return 0;
}
static err_t
rxperf_recv_callback(void *arg, struct tcp_pcb *tpcb, struct pbuf *p, err_t err)
{
/* close socket if the peer has sent the FIN packet */
if (p == NULL) {
xil_printf("Connection closed\n");
tcp_close(tpcb);
return ERR_OK;
}
/* all we do is say we've received the packet */
/* we don't actually make use of it */
tcp_recved(tpcb, p->tot_len);
//xil_printf("p tot len: %d\n", p->tot_len);
pbuf_free(p);
return ERR_OK;
}
err_t
rxperf_accept_callback(void *arg, struct tcp_pcb *newpcb, err_t err)
{
xil_printf("rxperf: Connection Accepted\r\n");
tcp_recv(newpcb, rxperf_recv_callback);
return ERR_OK;
}
int
start_rxperf_application()
{
struct tcp_pcb *pcb;
err_t err;
/* create new TCP PCB structure */
pcb = tcp_new();
if (!pcb) {
xil_printf("rxperf: Error creating PCB. Out of Memory\r\n");
return -1;
}
/* bind to iperf @port */
err = tcp_bind(pcb, IP_ADDR_ANY, rxperf_port);
if (err != ERR_OK) {
xil_printf("rxperf: Unable to bind to port %d: err = %d\r\n",
rxperf_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("rxperf: Out of memory while tcp_listen\r\n");
return -3;
}
/* specify callback to use for incoming connections */
tcp_accept(pcb, rxperf_accept_callback);
print_rxperf_app_header();
rxperf_server_running = 1;
return 0;
}
void
print_rxperf_app_header()
{
xil_printf("%20s %6d %s\r\n", "rxperf server",
rxperf_port,
"$ iperf -c <board ip> -i 5 -t 50 -w 64k");
}
_______________________________________________
lwip-users mailing list
[email protected]
https://lists.nongnu.org/mailman/listinfo/lwip-users
