Date: Sat, 20 Jun 2015 08:46:55 GMT From: btw@FreeBSD.org To: svn-soc-all@FreeBSD.org Subject: socsvn commit: r287367 - soc2015/btw/head/tools/tools/mq-testing/tcp Message-ID: <201506200846.t5K8kt5m056890@socsvn.freebsd.org>
next in thread | raw e-mail | index | archive | help
Author: btw Date: Sat Jun 20 08:46:55 2015 New Revision: 287367 URL: http://svnweb.FreeBSD.org/socsvn/?view=rev&rev=287367 Log: Add the tools for multiqueue testing: - client: a TCP client based on vme and lwip; - server: a TCP server based on socket(2); Added: soc2015/btw/head/tools/tools/mq-testing/tcp/ soc2015/btw/head/tools/tools/mq-testing/tcp/Makefile soc2015/btw/head/tools/tools/mq-testing/tcp/client.c soc2015/btw/head/tools/tools/mq-testing/tcp/common.h soc2015/btw/head/tools/tools/mq-testing/tcp/lwipopts.h soc2015/btw/head/tools/tools/mq-testing/tcp/server.c soc2015/btw/head/tools/tools/mq-testing/tcp/vmeif.c soc2015/btw/head/tools/tools/mq-testing/tcp/vmeif.h Added: soc2015/btw/head/tools/tools/mq-testing/tcp/Makefile ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ soc2015/btw/head/tools/tools/mq-testing/tcp/Makefile Sat Jun 20 08:46:55 2015 (r287367) @@ -0,0 +1,93 @@ +# +# $FreeBSD$ +# + +CCDEP=cc +CC=cc + +ARCH=unix +CFLAGS=-g -Wall -D$(ARCH) -DIPv4 -pedantic -Werror \ + -Wparentheses -Wsequence-point -Wswitch-default \ + -Wextra -Wundef -Wshadow -Wpointer-arith -Wbad-function-cast \ + -Wc++-compat -Wwrite-strings -Wold-style-definition \ + -Wmissing-prototypes -Wredundant-decls -Wnested-externs +LDFLAGS=-lpthread -lutil +ARFLAGS=rs + +CONTRIBDIR=$(HOME)/lwip/lwip-1.4.1/contrib-1.4.1 +LWIPDIR=$(HOME)/lwip/lwip-1.4.1/lwip-1.4.1/src +LWIPARCH=$(CONTRIBDIR)/ports/unix + +CFLAGS:=$(CFLAGS) \ + -I. \ + -I$(LWIPDIR)/include \ + -I$(LWIPARCH)/include \ + -I$(LWIPDIR)/include/ipv4 \ + -I$(LWIPDIR) + +# COREFILES, CORE4FILES: The minimum set of files needed for lwIP. +COREFILES=$(LWIPDIR)/core/mem.c \ + $(LWIPDIR)/core/memp.c \ + $(LWIPDIR)/core/netif.c \ + $(LWIPDIR)/core/pbuf.c \ + $(LWIPDIR)/core/raw.c \ + $(LWIPDIR)/core/stats.c \ + $(LWIPDIR)/core/sys.c \ + $(LWIPDIR)/core/tcp.c \ + $(LWIPDIR)/core/tcp_in.c \ + $(LWIPDIR)/core/tcp_out.c \ + $(LWIPDIR)/core/udp.c \ + $(LWIPDIR)/core/dhcp.c \ + $(LWIPDIR)/core/init.c \ + $(LWIPDIR)/core/timers.c \ + $(LWIPDIR)/core/def.c +CORE4FILES=$(wildcard $(LWIPDIR)/core/ipv4/*.c) \ + $(LWIPDIR)/core/ipv4/inet.c \ + $(LWIPDIR)/core/ipv4/inet_chksum.c + +# APIFILES: The files which implement the sequential and socket APIs. +APIFILES=$(LWIPDIR)/api/api_lib.c \ + $(LWIPDIR)/api/api_msg.c \ + $(LWIPDIR)/api/tcpip.c \ + $(LWIPDIR)/api/err.c \ + $(LWIPDIR)/api/sockets.c \ + $(LWIPDIR)/api/netbuf.c \ + $(LWIPDIR)/api/netdb.c + +# NETIFFILES: Files implementing various generic network interface functions. +NETIFFILES=$(LWIPDIR)/netif/etharp.c + +# ARCHFILES: Architecture specific files. +ARCHFILES=$(wildcard $(LWIPARCH)/*.c) + +# LWIPFILES: All the above. +LWIPFILES=$(COREFILES) $(CORE4FILES) $(APIFILES) \ + $(NETIFFILES) $(ARCHFILES) +LWIPFILESW=$(wildcard $(LWIPFILES)) +LWIPOBJS=$(notdir $(LWIPFILESW:.c=.o)) +LWIPLIB=liblwip4.a + +CLIENTFILES=client.c vmeif.c +CLIENTOBJS=$(notdir $(CLIENTFILES:.c=.o)) + +%.o: + $(CC) $(CFLAGS) -c $(<:.o=.c) + +all: client server +.PHONY: all + +clean: + rm -f *.o $(LWIPLIB) client server *.s .depend* *.core core + +depend dep: .depend + +-include .depend + +$(LWIPLIB): $(LWIPOBJS) + $(AR) $(ARFLAGS) $(LWIPLIB) $? + +.depend: $(CLIENTFILES) $(LWIPFILES) + $(CCDEP) $(CFLAGS) -MM $^ > .depend || rm -f .depend + +client: .depend $(LWIPLIB) $(CLIENTOBJS) + $(CC) $(CFLAGS) $(LDFLAGS) -o client $(CLIENTOBJS) $(LWIPLIB) Added: soc2015/btw/head/tools/tools/mq-testing/tcp/client.c ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ soc2015/btw/head/tools/tools/mq-testing/tcp/client.c Sat Jun 20 08:46:55 2015 (r287367) @@ -0,0 +1,206 @@ +/*- + * Copyright (c) 2015, Tiwei Bie <btw@FreeBSD.org> + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice unmodified, this list of conditions, and the following + * disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include <getopt.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <signal.h> + +#include "lwip/tcpip.h" +#include "lwip/sockets.h" + +#include "vmeif.h" +#include "common.h" + +static ip_addr_t ipaddr, netmask, gw; +static char payload[1024]; +static struct netif netif; +static int quiet = 0; +static int nr_connections = 10000; + +static const char *gw_str = "192.168.10.1"; +static const char *ip_str = "192.168.10.2"; +static const char *nm_str = "255.255.255.0"; + +/* nonstatic debug cmd option, exported in lwipopts.h */ +unsigned char debug_flags; + +static void +usage(const char *prgname) +{ + (void)prgname; + fprintf(stderr, + "Usage: %s [-g gateway] [-i address] [-m netmask]\n" + " %*s [-n connections] [-dhq]\n", + prgname, (int)strlen(prgname), ""); + exit(EXIT_FAILURE); +} + +static void +init_netifs(void) +{ + netif_set_default(netif_add(&netif, &ipaddr, &netmask, &gw, + NULL, vmeif_init, tcpip_input)); + netif_set_up(&netif); +} + +static void +tcpip_init_done(void *arg) +{ + sys_sem_t *sem = arg; + init_netifs(); + sys_sem_signal(sem); +} + +static void +client_routine(void) +{ + struct sockaddr_in daddr; + int sd, *sds; + int i; + + sds = malloc(sizeof(int) * nr_connections); + + memset(&daddr, 0, sizeof(daddr)); + daddr.sin_family = AF_INET; + daddr.sin_addr.s_addr = gw.addr; + daddr.sin_port = htons(SERVER_PORT); + + for (i = 0; i < nr_connections; i++) { + sd = lwip_socket(AF_INET, SOCK_STREAM, 0); + if (sd < 0) { + fprintf(stderr, "Failed to create socket\n"); + exit(EXIT_FAILURE); + } + + if (lwip_connect(sd, (struct sockaddr *)&daddr, + sizeof(daddr)) < 0) { + fprintf(stderr, "Failed to connect to server sd=%d\n", + i); + exit(EXIT_FAILURE); + } + + sds[i] = sd; + } + + while (1) { + for (i = 0; i < nr_connections; i++) { + sd = sds[i]; + + snprintf(payload, sizeof(payload), + "message from socket %d", i); + + if (lwip_send(sd, payload, strlen(payload), 0) < 0) { + fprintf(stderr, + "Failed to send data to server\n"); + exit(EXIT_FAILURE); + } + } + } +} + +static void +main_thread(void) +{ + sys_sem_t sem; + + netif_init(); + + if (sys_sem_new(&sem, 0) != ERR_OK) { + fprintf(stderr, "Failed to create semaphore\n"); + exit(EXIT_FAILURE); + } + + tcpip_init(tcpip_init_done, &sem); + sys_sem_wait(&sem); + + if (!quiet) + printf("TCP/IP initialized.\n"); + + client_routine(); +} + +static void +signal_handler(int arg) +{ + if (arg == SIGINT) + exit(EXIT_SUCCESS); +} + +int +main(int argc, char **argv) +{ + int ch; + + debug_flags = LWIP_DBG_OFF; + + while ((ch = getopt(argc, argv, "g:i:m:n:dhq")) != -1) { + switch (ch) { + case 'd': + debug_flags |= + (LWIP_DBG_ON | LWIP_DBG_TRACE | LWIP_DBG_STATE | + LWIP_DBG_FRESH | LWIP_DBG_HALT); + break; + case 'g': + gw_str = optarg; + break; + case 'i': + ip_str = optarg; + break; + case 'm': + nm_str = optarg; + break; + case 'n': + sscanf(optarg, "%d", &nr_connections); + break; + case 'q': + quiet = 1; + break; + case 'h': + default: + usage(argv[0]); + break; + } + } + + gw.addr = inet_addr(gw_str); + ipaddr.addr = inet_addr(ip_str); + netmask.addr = inet_addr(nm_str); + + signal(SIGINT, signal_handler); + + if (!quiet) { + printf("host at %s\n", ip_str); + printf("netmask: %s\n", nm_str); + printf("gateway: %s\n", gw_str); + printf("connections: %d\n", nr_connections); + } + + main_thread(); + + return (0); +} Added: soc2015/btw/head/tools/tools/mq-testing/tcp/common.h ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ soc2015/btw/head/tools/tools/mq-testing/tcp/common.h Sat Jun 20 08:46:55 2015 (r287367) @@ -0,0 +1,34 @@ +/*- + * Copyright (c) 2015, Tiwei Bie <btw@FreeBSD.org> + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice unmodified, this list of conditions, and the following + * disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +/* $FreeBSD$ */ + +#ifndef _COMMON_H_ +#define _COMMON_H_ + +#define SERVER_PORT 8000 + +#endif Added: soc2015/btw/head/tools/tools/mq-testing/tcp/lwipopts.h ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ soc2015/btw/head/tools/tools/mq-testing/tcp/lwipopts.h Sat Jun 20 08:46:55 2015 (r287367) @@ -0,0 +1,311 @@ +/* + * Copyright (c) 2001-2003 Swedish Institute of Computer Science. + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without modification, + * are permitted provided that the following conditions are met: + * + * 1. Redistributions of source code must retain the above copyright notice, + * this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright notice, + * this list of conditions and the following disclaimer in the documentation + * and/or other materials provided with the distribution. + * 3. The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED + * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT + * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, + * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT + * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS + * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN + * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING + * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY + * OF SUCH DAMAGE. + * + * This file is part of the lwIP TCP/IP stack. + * + * Author: Adam Dunkels <adam@sics.se> + * + */ +#ifndef __LWIPOPTS_H__ +#define __LWIPOPTS_H__ + +#define LWIP_DBG_MIN_LEVEL 0 +#define LWIP_COMPAT_SOCKETS 1 +#define TAPIF_DEBUG LWIP_DBG_ON +#define TUNIF_DEBUG LWIP_DBG_OFF +#define UNIXIF_DEBUG LWIP_DBG_OFF +#define DELIF_DEBUG LWIP_DBG_OFF +#define SIO_FIFO_DEBUG LWIP_DBG_OFF +#define TCPDUMP_DEBUG LWIP_DBG_ON + +#define PPP_DEBUG LWIP_DBG_OFF +#define MEM_DEBUG LWIP_DBG_OFF +#define MEMP_DEBUG LWIP_DBG_OFF +#define PBUF_DEBUG LWIP_DBG_OFF +#define API_LIB_DEBUG LWIP_DBG_OFF +#define API_MSG_DEBUG LWIP_DBG_OFF +#define TCPIP_DEBUG LWIP_DBG_OFF +#define NETIF_DEBUG LWIP_DBG_OFF +#define SOCKETS_DEBUG LWIP_DBG_OFF +#define DEMO_DEBUG LWIP_DBG_OFF +#define IP_DEBUG LWIP_DBG_OFF +#define IP_REASS_DEBUG LWIP_DBG_OFF +#define RAW_DEBUG LWIP_DBG_OFF +#define ICMP_DEBUG LWIP_DBG_OFF +#define UDP_DEBUG LWIP_DBG_OFF +#define TCP_DEBUG LWIP_DBG_OFF +#define TCP_INPUT_DEBUG LWIP_DBG_OFF +#define TCP_OUTPUT_DEBUG LWIP_DBG_OFF +#define TCP_RTO_DEBUG LWIP_DBG_OFF +#define TCP_CWND_DEBUG LWIP_DBG_OFF +#define TCP_WND_DEBUG LWIP_DBG_OFF +#define TCP_FR_DEBUG LWIP_DBG_OFF +#define TCP_QLEN_DEBUG LWIP_DBG_OFF +#define TCP_RST_DEBUG LWIP_DBG_OFF + +extern unsigned char debug_flags; +#define LWIP_DBG_TYPES_ON debug_flags + +#define NO_SYS 0 +#define LWIP_SOCKET (NO_SYS==0) +#define LWIP_NETCONN (NO_SYS==0) + + +/* ---------- Memory options ---------- */ +/* MEM_ALIGNMENT: should be set to the alignment of the CPU for which + lwIP is compiled. 4 byte alignment -> define MEM_ALIGNMENT to 4, 2 + byte alignment -> define MEM_ALIGNMENT to 2. */ +/* MSVC port: intel processors don't need 4-byte alignment, + but are faster that way! */ +#define MEM_ALIGNMENT 4 + +/* MEM_SIZE: the size of the heap memory. If the application will send +a lot of data that needs to be copied, this should be set high. */ +#define MEM_SIZE 10240 + +/* MEMP_NUM_PBUF: the number of memp struct pbufs. If the application + sends a lot of data out of ROM (or other static memory), this + should be set high. */ +#define MEMP_NUM_PBUF 16 +/* MEMP_NUM_RAW_PCB: the number of UDP protocol control blocks. One + per active RAW "connection". */ +#define MEMP_NUM_RAW_PCB 3 +/* MEMP_NUM_UDP_PCB: the number of UDP protocol control blocks. One + per active UDP "connection". */ +#define MEMP_NUM_UDP_PCB 4 +/* MEMP_NUM_TCP_PCB: the number of simulatenously active TCP + connections. */ +#define MEMP_NUM_TCP_PCB 60000 +/* MEMP_NUM_TCP_PCB_LISTEN: the number of listening TCP + connections. */ +#define MEMP_NUM_TCP_PCB_LISTEN 8 +/* MEMP_NUM_TCP_SEG: the number of simultaneously queued TCP + segments. */ +#define MEMP_NUM_TCP_SEG 16 +/* MEMP_NUM_SYS_TIMEOUT: the number of simulateously active + timeouts. */ +#define MEMP_NUM_SYS_TIMEOUT 3 + +/* The following four are used only with the sequential API and can be + set to 0 if the application only will use the raw API. */ +/* MEMP_NUM_NETBUF: the number of struct netbufs. */ +#define MEMP_NUM_NETBUF 2 +/* MEMP_NUM_NETCONN: the number of struct netconns. */ +#define MEMP_NUM_NETCONN 60000 +/* MEMP_NUM_TCPIP_MSG_*: the number of struct tcpip_msg, which is used + for sequential API communication and incoming packets. Used in + src/api/tcpip.c. */ +#define MEMP_NUM_TCPIP_MSG_API 16 +#define MEMP_NUM_TCPIP_MSG_INPKT 16 + +/* ---------- Pbuf options ---------- */ +/* PBUF_POOL_SIZE: the number of buffers in the pbuf pool. */ +#define PBUF_POOL_SIZE 120 + +/* PBUF_POOL_BUFSIZE: the size of each pbuf in the pbuf pool. */ +#define PBUF_POOL_BUFSIZE 128 + +/* PBUF_LINK_HLEN: the number of bytes that should be allocated for a + link level header. */ +#define PBUF_LINK_HLEN 16 + +/** SYS_LIGHTWEIGHT_PROT + * define SYS_LIGHTWEIGHT_PROT in lwipopts.h if you want inter-task protection + * for certain critical regions during buffer allocation, deallocation and memory + * allocation and deallocation. + */ +#define SYS_LIGHTWEIGHT_PROT 1 + +/* ---------- TCP options ---------- */ +#define LWIP_TCP 1 +#define TCP_TTL 255 + +/* Controls if TCP should queue segments that arrive out of + order. Define to 0 if your device is low on memory. */ +#define TCP_QUEUE_OOSEQ 1 + +/* TCP Maximum segment size. */ +#define TCP_MSS 1024 + +/* TCP sender buffer space (bytes). */ +#define TCP_SND_BUF 2048 + +/* TCP sender buffer space (pbufs). This must be at least = 2 * + TCP_SND_BUF/TCP_MSS for things to work. */ +#define TCP_SND_QUEUELEN (4 * TCP_SND_BUF/TCP_MSS) + +/* TCP writable space (bytes). This must be less than or equal + to TCP_SND_BUF. It is the amount of space which must be + available in the tcp snd_buf for select to return writable */ +#define TCP_SNDLOWAT (TCP_SND_BUF/2) + +/* TCP receive window. */ +#define TCP_WND 8096 + +/* Maximum number of retransmissions of data segments. */ +#define TCP_MAXRTX 12 + +/* Maximum number of retransmissions of SYN segments. */ +#define TCP_SYNMAXRTX 4 + +/* ---------- ARP options ---------- */ +#define LWIP_ARP 1 +#define ARP_TABLE_SIZE 10 +#define ARP_QUEUEING 1 + +/* ---------- IP options ---------- */ +/* Define IP_FORWARD to 1 if you wish to have the ability to forward + IP packets across network interfaces. If you are going to run lwIP + on a device with only one network interface, define this to 0. */ +#define IP_FORWARD 1 + + +/* IP reassembly and segmentation.These are orthogonal even + * if they both deal with IP fragments */ +#define IP_REASSEMBLY 1 +#define IP_REASS_MAX_PBUFS 10 +#define MEMP_NUM_REASSDATA 10 +#define IP_FRAG 1 + +/* ---------- ICMP options ---------- */ +#define ICMP_TTL 255 + +/* ---------- DHCP options ---------- */ +/* Define LWIP_DHCP to 1 if you want DHCP configuration of + interfaces. */ +#define LWIP_DHCP 0 + +/* 1 if you want to do an ARP check on the offered address + (recommended if using DHCP). */ +#define DHCP_DOES_ARP_CHECK (LWIP_DHCP) + +/* ---------- AUTOIP options ------- */ +#define LWIP_AUTOIP 0 + +/* ---------- SNMP options ---------- */ +/** @todo SNMP is experimental for now + @note UDP must be available for SNMP transport */ +#ifndef LWIP_SNMP +#define LWIP_SNMP 0 +#endif + +#ifndef SNMP_PRIVATE_MIB +#define SNMP_PRIVATE_MIB 0 +#endif + +/* ---------- UDP options ---------- */ +#define LWIP_UDP 1 +#define UDP_TTL 255 + +/* ---------- RAW options ---------- */ +#define LWIP_RAW 1 +#define RAW_TTL 255 + +/* ---------- Statistics options ---------- */ +/* individual STATS options can be turned off by defining them to 0 + * (e.g #define TCP_STATS 0). All of them are turned off if LWIP_STATS + * is 0 + * */ + +#define LWIP_STATS 1 + +/* ---------- PPP options ---------- */ + +#define PPP_SUPPORT 0 /* Set > 0 for PPP */ + +#if PPP_SUPPORT > 0 + +#define NUM_PPP 1 /* Max PPP sessions. */ + + +/* Select modules to enable. Ideally these would be set in the makefile but + * we're limited by the command line length so you need to modify the settings + * in this file. + */ +#define PAP_SUPPORT 1 /* Set > 0 for PAP. */ +#define CHAP_SUPPORT 1 /* Set > 0 for CHAP. */ +#define MSCHAP_SUPPORT 0 /* Set > 0 for MSCHAP (NOT FUNCTIONAL!) */ +#define CBCP_SUPPORT 0 /* Set > 0 for CBCP (NOT FUNCTIONAL!) */ +#define CCP_SUPPORT 0 /* Set > 0 for CCP (NOT FUNCTIONAL!) */ +#define VJ_SUPPORT 1 /* Set > 0 for VJ header compression. */ +#define MD5_SUPPORT 1 /* Set > 0 for MD5 (see also CHAP) */ + + +/* + * Timeouts. + */ +#define FSM_DEFTIMEOUT 6 /* Timeout time in seconds */ +#define FSM_DEFMAXTERMREQS 2 /* Maximum Terminate-Request transmissions */ +#define FSM_DEFMAXCONFREQS 10 /* Maximum Configure-Request transmissions */ +#define FSM_DEFMAXNAKLOOPS 5 /* Maximum number of nak loops */ + +#define UPAP_DEFTIMEOUT 6 /* Timeout (seconds) for retransmitting req */ +#define UPAP_DEFREQTIME 30 /* Time to wait for auth-req from peer */ + +#define CHAP_DEFTIMEOUT 6 /* Timeout time in seconds */ +#define CHAP_DEFTRANSMITS 10 /* max # times to send challenge */ + + +/* Interval in seconds between keepalive echo requests, 0 to disable. */ +#if 1 +#define LCP_ECHOINTERVAL 0 +#else +#define LCP_ECHOINTERVAL 10 +#endif + +/* Number of unanswered echo requests before failure. */ +#define LCP_MAXECHOFAILS 3 + +/* Max Xmit idle time (in jiffies) before resend flag char. */ +#define PPP_MAXIDLEFLAG 100 + +/* + * Packet sizes + * + * Note - lcp shouldn't be allowed to negotiate stuff outside these + * limits. See lcp.h in the pppd directory. + * (XXX - these constants should simply be shared by lcp.c instead + * of living in lcp.h) + */ +#define PPP_MTU 1500 /* Default MTU (size of Info field) */ +#if 0 +#define PPP_MAXMTU 65535 - (PPP_HDRLEN + PPP_FCSLEN) +#else +#define PPP_MAXMTU 1500 /* Largest MTU we allow */ +#endif +#define PPP_MINMTU 64 +#define PPP_MRU 1500 /* default MRU = max length of info field */ +#define PPP_MAXMRU 1500 /* Largest MRU we allow */ +#define PPP_DEFMRU 296 /* Try for this */ +#define PPP_MINMRU 128 /* No MRUs below this */ + + +#define MAXNAMELEN 256 /* max length of hostname or name for auth */ +#define MAXSECRETLEN 256 /* max length of password or secret */ + +#endif /* PPP_SUPPORT > 0 */ + +#endif /* __LWIPOPTS_H__ */ Added: soc2015/btw/head/tools/tools/mq-testing/tcp/server.c ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ soc2015/btw/head/tools/tools/mq-testing/tcp/server.c Sat Jun 20 08:46:55 2015 (r287367) @@ -0,0 +1,216 @@ +/*- + * Copyright (c) 2015, Tiwei Bie <btw@FreeBSD.org> + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice unmodified, this list of conditions, and the following + * disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR + * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES + * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. + * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, + * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT + * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF + * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. + */ + +#include <stdio.h> +#include <stdlib.h> +#include <string.h> +#include <unistd.h> +#include <ctype.h> +#include <err.h> + +#include <sys/types.h> +#include <sys/socket.h> +#include <sys/event.h> +#include <netinet/in.h> + +#include <arpa/inet.h> + +#include "common.h" + +static int verbose = 0; + +#define NR_EVENTS 10 + +static void +usage(const char *prgname) +{ + fprintf(stderr, "Usage: %s [-hv]\n", prgname); + exit(EXIT_FAILURE); +} + +static char * +addr2str(int af, void *addr) +{ + static char msg[1024]; + char addrstr[INET6_ADDRSTRLEN]; + + switch (af) { + case AF_INET: + snprintf(msg, sizeof(msg), "%s:%d", + inet_ntoa(((struct sockaddr_in *)addr)->sin_addr), + ntohs(((struct sockaddr_in *)addr)->sin_port)); + break; + case AF_INET6: + snprintf(msg, sizeof(msg), "%s:%d", + inet_ntop(AF_INET6, + &((struct sockaddr_in6 *)addr)->sin6_addr, + addrstr, sizeof(addrstr)), + ntohs(((struct sockaddr_in6 *)addr)->sin6_port)); + break; + } + + return (msg); +} + +static int +kq_add(int kq, int fd) +{ + struct kevent changes[1]; + int ret; + + EV_SET(&changes[0], fd, EVFILT_READ, EV_ADD, 0, 0, NULL); + ret = kevent(kq, changes, 1, NULL, 0, NULL); + + return (ret); +} + +static int +kq_delete(int kq, int fd) +{ + struct kevent changes[1]; + int ret; + + EV_SET(&changes[0], fd, EVFILT_READ, EV_DELETE, 0, 0, NULL); + ret = kevent(kq, changes, 1, NULL, 0, NULL); + + return (ret); +} + +static void +accept_new_connection(int kq, int fd, int n) +{ + struct sockaddr_in from; + socklen_t length; + int newfd, i; + + for (i = 0; i < n; i++) { + length = sizeof(from); + newfd = accept(fd, (struct sockaddr *)&from, &length); + if (newfd < 0) + err(EXIT_FAILURE, "accept"); + + if (kq_add(kq, newfd) < 0) + err(EXIT_FAILURE, "kq_add"); + + if (verbose) + printf("accept connection from %s\n", + addr2str(AF_INET, &from)); + } +} + +static void +receive_data(int kq, int fd, int n) +{ + char msg[BUFSIZ]; + int i; + + n = read(fd, msg, sizeof(msg)); + if (n < 0) + err(EXIT_FAILURE, "read"); + + if (n == 0) { + if (kq_delete(kq, fd) < 0) + err(EXIT_FAILURE, "kq_delete"); + return; + } + + if (verbose) { + printf("len=%d ", n); + for (i = 0; i < n && msg[i]; i++) { + if (isprint(msg[i])) + printf("%c", msg[i]); + } + printf("\n"); + } +} + +int +main(int argc, char **argv) +{ + int servfd, kq; + struct sockaddr_in sin; + int ch, on; + + while ((ch = getopt(argc, argv, "hv")) != -1) { + switch (ch) { + case 'v': + verbose = 1; + break; + case 'h': + default: + usage(argv[0]); + break; + } + } + + servfd = socket(AF_INET, SOCK_STREAM, 0); + if (servfd < 0) + err(EXIT_FAILURE, "socket"); + + memset(&sin, 0, sizeof(sin)); + sin.sin_family = AF_INET; + sin.sin_addr.s_addr = INADDR_ANY; + sin.sin_port = htons(SERVER_PORT); + + on = 1; + if (setsockopt(servfd, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) < 0) + err(EXIT_FAILURE, "setsockopt"); + + if (bind(servfd, (struct sockaddr *)&sin, sizeof(sin)) < 0) + err(EXIT_FAILURE, "bind"); + + if (listen(servfd, 5) < 0) + err(EXIT_FAILURE, "listen"); + + if ((kq = kqueue()) < 0) + err(EXIT_FAILURE, "kqueue"); + + if (kq_add(kq, servfd) < 0) + err(EXIT_FAILURE, "kq_add"); + + while (1) { + struct kevent events[NR_EVENTS]; + int n, i; + + n = kevent(kq, NULL, 0, events, NR_EVENTS, NULL); + if (n < 0) + err(EXIT_FAILURE, "kevent"); + + for (i = 0; i < n; i++) { + int sd, data; + + sd = events[i].ident; + data = events[i].data; + + if (sd == servfd) + accept_new_connection(kq, sd, data); + else + receive_data(kq, sd, data); + } + } + + return (0); +} Added: soc2015/btw/head/tools/tools/mq-testing/tcp/vmeif.c ============================================================================== --- /dev/null 00:00:00 1970 (empty, because file is newly added) +++ soc2015/btw/head/tools/tools/mq-testing/tcp/vmeif.c Sat Jun 20 08:46:55 2015 (r287367) @@ -0,0 +1,298 @@ +/* + * Copyright (c) 2001-2003 Swedish Institute of Computer Science. + * Copyright (c) 2015 Tiwei Bie <btw@FreeBSD.org> + * + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without modification, + * are permitted provided that the following conditions are met: + * + * 1. Redistributions of source code must retain the above copyright notice, + * this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright notice, + * this list of conditions and the following disclaimer in the documentation + * and/or other materials provided with the distribution. + * 3. The name of the author may not be used to endorse or promote products + * derived from this software without specific prior written permission. + * + * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED + * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF + * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT + * SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, + * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT + * OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS + * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN + * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING + * IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY + * OF SUCH DAMAGE. + * + * This file is part of the lwIP TCP/IP stack. + * + * Author: Adam Dunkels <adam@sics.se> + */ + +#include <fcntl.h> +#include <stdlib.h> +#include <stdio.h> +#include <string.h> +#include <unistd.h> +#include <sys/types.h> +#include <sys/uio.h> +#include <sys/socket.h> + +#include "lwip/debug.h" + +#include "lwip/opt.h" +#include "lwip/def.h" +#include "lwip/ip.h" +#include "lwip/mem.h" +#include "lwip/pbuf.h" +#include "lwip/sys.h" + +#include "netif/etharp.h" + +#include "vmeif.h" + +#define IFCONFIG_BIN "/sbin/ifconfig " + +#define DEVVME "/dev/vme0" +#define IFCONFIG_ARGS "vme0 inet %d.%d.%d.%d" + +#define IFNAME0 't' +#define IFNAME1 'p' + +#ifndef VMEIF_DEBUG +#define VMEIF_DEBUG LWIP_DBG_OFF +#endif + +struct vmeif { + struct eth_addr *ethaddr; + int fd; +}; + +/* Forward declarations. */ +static void vmeif_input(struct netif *netif); +static void vmeif_thread(void *data); + +static void +low_level_init(struct netif *netif) +{ + struct vmeif *vmeif; + char buf[sizeof(IFCONFIG_ARGS) + sizeof(IFCONFIG_BIN) + 50]; + + vmeif = (struct vmeif *)netif->state; + + /* Obtain MAC address from network interface. */ + + /* (We just fake an address...) */ + vmeif->ethaddr->addr[0] = 0xbc; + vmeif->ethaddr->addr[1] = 0xae; + vmeif->ethaddr->addr[2] = 0xc5; + vmeif->ethaddr->addr[3] = 0x23; + vmeif->ethaddr->addr[4] = 0x61; + vmeif->ethaddr->addr[5] = 0x22; + + /* Do whatever else is needed to initialize interface. */ + + vmeif->fd = open(DEVVME, O_RDWR); + LWIP_DEBUGF(VMEIF_DEBUG, ("vmeif_init: fd %d\n", vmeif->fd)); + if (vmeif->fd == -1) { + perror("vmeif_init: cannot open " DEVVME); + exit(1); + } + + sprintf(buf, IFCONFIG_BIN IFCONFIG_ARGS, + ip4_addr1(&(netif->gw)), + ip4_addr2(&(netif->gw)), + ip4_addr3(&(netif->gw)), ip4_addr4(&(netif->gw))); + + LWIP_DEBUGF(VMEIF_DEBUG, ("vmeif_init: system(\"%s\");\n", buf)); + system(buf); + sys_thread_new("vmeif_thread", vmeif_thread, netif, + DEFAULT_THREAD_STACKSIZE, DEFAULT_THREAD_PRIO); + +} + +/* + * low_level_output(): + * + * Should do the actual transmission of the packet. The packet is + * contained in the pbuf that is passed to the function. This pbuf + * might be chained. + */ *** DIFF OUTPUT TRUNCATED AT 1000 LINES ***
Want to link to this message? Use this URL: <https://mail-archive.FreeBSD.org/cgi/mid.cgi?201506200846.t5K8kt5m056890>