From 25b957c10a1126a59a53c4c7c3e319aaa6a4c9f4 Mon Sep 17 00:00:00 2001 From: Joel Sherrill Date: Mon, 27 Jan 2003 23:30:53 +0000 Subject: 2003-01-27 Joel Sherrill * Makefile.am, configure.ac: Added new test loopback which shows how to use the loopback interface. Thank you Eric Norum for a portable target independent test which exercises the TCP/IP. This should prevent massive failures in the TCP/IP stack from reaching the street. * loopback/.cvsignore, loopback/Makefile.am, loopback/README, loopback/init.c, loopback/loopback.scn: New files. --- testsuites/samples/loopback/.cvsignore | 2 + testsuites/samples/loopback/Makefile.am | 41 +++++ testsuites/samples/loopback/README | 65 ++++++++ testsuites/samples/loopback/init.c | 267 +++++++++++++++++++++++++++++++ testsuites/samples/loopback/loopback.scn | 56 +++++++ 5 files changed, 431 insertions(+) create mode 100644 testsuites/samples/loopback/.cvsignore create mode 100644 testsuites/samples/loopback/Makefile.am create mode 100644 testsuites/samples/loopback/README create mode 100644 testsuites/samples/loopback/init.c create mode 100644 testsuites/samples/loopback/loopback.scn (limited to 'testsuites') diff --git a/testsuites/samples/loopback/.cvsignore b/testsuites/samples/loopback/.cvsignore new file mode 100644 index 0000000000..282522db03 --- /dev/null +++ b/testsuites/samples/loopback/.cvsignore @@ -0,0 +1,2 @@ +Makefile +Makefile.in diff --git a/testsuites/samples/loopback/Makefile.am b/testsuites/samples/loopback/Makefile.am new file mode 100644 index 0000000000..ef34244254 --- /dev/null +++ b/testsuites/samples/loopback/Makefile.am @@ -0,0 +1,41 @@ +## +## $Id$ +## + + +SAMPLE = loopback +PGM = ${ARCH}/$(SAMPLE).exe + +MANAGERS = io event + +C_FILES = init.c +C_O_FILES = $(C_FILES:%.c=${ARCH}/%.$(OBJEXT)) + +DOCTYPES = scn +DOCS = $(DOCTYPES:%=$(SAMPLE).%) + +SRCS = $(DOCS) $(C_FILES) $(H_FILES) +OBJS = $(C_O_FILES) + +PRINT_SRCS = $(DOCS) + +include $(RTEMS_ROOT)/make/custom/@RTEMS_BSP@.cfg +include $(top_srcdir)/../../../../automake/compile.am +include $(top_srcdir)/../../../../automake/leaf.am +include $(top_srcdir)/sample.am + +# +# (OPTIONAL) Add local stuff here using += +# + + +if HAS_NETWORKING +all-local: ${ARCH} $(TMPINSTALL_FILES) + +${PGM}: $(OBJS) $(LINK_FILES) + $(make-exe) +endif + +EXTRA_DIST = $(C_FILES) $(DOCS) + +include $(top_srcdir)/../../../../automake/local.am diff --git a/testsuites/samples/loopback/README b/testsuites/samples/loopback/README new file mode 100644 index 0000000000..8733bed358 --- /dev/null +++ b/testsuites/samples/loopback/README @@ -0,0 +1,65 @@ +# +# $Id$ +# + +Simple test of kernel network code. +Requires no network hardware since only the loopback network address is used. + +Output should look like: +======================================================================== +"Network" initializing! +"Network" initialized! +Try running client with no server present. +Should fail with `connection refused'. +Connect to server. +Can't connect to server: Connection refused +Client closing connection. + +Start server. + +Try running client with server present. +Create socket. +Connect to server. +Bind socket. +Can't connect to server: Connection refused +Client closing connection. +Client task terminating. + +Try running two clients. +Connect to server. +Connect to server. +ACCEPTED:7F000001 +ACCEPTED:7F000001 +Write 22-byte message to server. +Write 22-byte message to server. +Read 43 from server: Server received 22 (Hi there, server (2).) +Read 43 from server: Server received 22 (Hi there, server (3).) +Client closing connection. +Client task terminating. +Worker task terminating. +Client closing connection. +Client task terminating. +Worker task terminating. + +Try running three clients. +Connect to server. +Connect to server. +Connect to server. +ACCEPTED:7F000001 +ACCEPTED:7F000001 +ACCEPTED:7F000001 +Write 22-byte message to server. +Write 22-byte message to server. +Write 22-byte message to server. +Read 43 from server: Server received 22 (Hi there, server (4).) +Read 43 from server: Server received 22 (Hi there, server (5).) +Read 43 from server: Server received 22 (Hi there, server (6).) +Client closing connection. +Client task terminating. +Worker task terminating. +Client closing connection. +Client task terminating. +Worker task terminating. +Client closing connection. +Client task terminating. +Worker task terminating. diff --git a/testsuites/samples/loopback/init.c b/testsuites/samples/loopback/init.c new file mode 100644 index 0000000000..b0aaf66597 --- /dev/null +++ b/testsuites/samples/loopback/init.c @@ -0,0 +1,267 @@ +#include + +#define CONFIGURE_TEST_NEEDS_CONSOLE_DRIVER +#define CONFIGURE_TEST_NEEDS_CLOCK_DRIVER +#define CONFIGURE_RTEMS_INIT_TASKS_TABLE + +#define CONFIGURE_EXECUTIVE_RAM_SIZE (512*1024) +#define CONFIGURE_MAXIMUM_SEMAPHORES 20 +#define CONFIGURE_MAXIMUM_MESSAGE_QUEUES 20 +#define CONFIGURE_MAXIMUM_TASKS 20 + +#define CONFIGURE_MICROSECONDS_PER_TICK 10000 +#define CONFIGURE_LIBIO_MAXIMUM_FILE_DESCRIPTORS 50 +#define CONFIGURE_USE_IMFS_AS_BASE_FILESYSTEM + +#define CONFIGURE_INIT_TASK_STACK_SIZE (10*1024) +#define CONFIGURE_INIT_TASK_PRIORITY 50 +#define CONFIGURE_INIT_TASK_INITIAL_MODES (RTEMS_PREEMPT | \ + RTEMS_NO_TIMESLICE | \ + RTEMS_NO_ASR | \ + RTEMS_INTERRUPT_LEVEL(0)) + +#define CONFIGURE_INIT +rtems_task Init(rtems_task_argument argument); + +#include + +#include +#include +#include +#include +#include +#include +#include +#include + +/* + * Network configuration + */ +extern void rtems_bsdnet_loopattach(); +static struct rtems_bsdnet_ifconfig loopback_config = { + "lo0", /* name */ + (int (*)(struct rtems_bsdnet_ifconfig *, int))rtems_bsdnet_loopattach, /* attach function */ + NULL, /* link to next interface */ + "127.0.0.1", /* IP address */ + "255.0.0.0", /* IP net mask */ +}; + +struct rtems_bsdnet_config rtems_bsdnet_config = { + &loopback_config, /* Network interface */ + NULL, /* Use fixed network configuration */ + 0, /* Default network task priority */ + 0, /* Default mbuf capacity */ + 0, /* Default mbuf cluster capacity */ + "testSystem", /* Host name */ + "nowhere.com", /* Domain name */ + "127.0.0.1", /* Gateway */ + "127.0.0.1", /* Log host */ + {"127.0.0.1" }, /* Name server(s) */ + {"127.0.0.1" }, /* NTP server(s) */ +}; + +/* + * Thread-safe output routines + */ +static rtems_id printMutex; +static void printSafe(const char *fmt, ...) +{ + va_list args; + va_start(args, fmt); + rtems_semaphore_obtain(printMutex, RTEMS_WAIT, RTEMS_NO_TIMEOUT); + vprintf(fmt, args); + rtems_semaphore_release(printMutex); + va_end(args); +} +#define printf printSafe + +/* + * Spawn a task + */ +static void spawnTask(rtems_task_entry entryPoint, rtems_task_priority priority, rtems_task_argument arg) +{ + rtems_status_code sc; + rtems_id tid; + + sc = rtems_task_create(rtems_build_name('t','a','s','k'), + priority, + RTEMS_MINIMUM_STACK_SIZE+(8*1024), + RTEMS_PREEMPT|RTEMS_TIMESLICE|RTEMS_NO_ASR|RTEMS_INTERRUPT_LEVEL(0), + RTEMS_FLOATING_POINT|RTEMS_LOCAL, + &tid); + if (sc != RTEMS_SUCCESSFUL) + rtems_panic("Can't create task: %s", rtems_status_text(sc)); + sc = rtems_task_start(tid, entryPoint, arg); + if (sc != RTEMS_SUCCESSFUL) + rtems_panic("Can't start task: %s", rtems_status_text(sc)); +} + +/* + * Server subtask + */ +static rtems_task workerTask(rtems_task_argument arg) +{ + int s = arg; + char msg[80]; + char reply[100]; + int i; + + for (;;) { + if ((i = read(s, msg, sizeof msg)) < 0) { + printf("Server couldn't read message from client: %s\n", strerror(errno)); + break; + } + if (i == 0) + break; + rtems_task_wake_after(20); /* Simulate some processing delay */ + i = sprintf(reply, "Server received %d (%s)", i, msg); + if ((i = write(s, reply, i+1)) < 0) { + printf("Server couldn't write message to client: %s\n", strerror(errno)); + break; + } + } + if (close(s) < 0) + printf("Can't close worker task socket: %s\n", strerror(errno)); + printf("Worker task terminating.\n"); + rtems_task_delete(RTEMS_SELF); +} + +/* + * Server Task + */ +static rtems_task serverTask(rtems_task_argument arg) +{ + int s, s1; + int addrlen; + struct sockaddr_in myAddr, farAddr; + rtems_task_priority myPriority; + + printf("Create socket.\n"); + s = socket(AF_INET, SOCK_STREAM, 0); + if (s < 0) + rtems_panic("Can't create socket: %s\n", strerror(errno)); + memset(&myAddr, 0, sizeof myAddr); + myAddr.sin_family = AF_INET; + myAddr.sin_port = htons(1234); + myAddr.sin_addr.s_addr = htonl(INADDR_ANY); + printf("Bind socket.\n"); + if (bind(s, (struct sockaddr *)&myAddr, sizeof myAddr) < 0) + rtems_panic("Can't bind socket: %s\n", strerror(errno)); + if (listen(s, 5) < 0) + printf("Can't listen on socket: %s\n", strerror(errno)); + rtems_task_set_priority(RTEMS_SELF, RTEMS_CURRENT_PRIORITY, &myPriority); + for(;;) { + addrlen = sizeof farAddr; + s1 = accept(s, (struct sockaddr *)&farAddr, &addrlen); + if (s1 < 0) + rtems_panic("Can't accept connection: %s", strerror(errno)); + else + printf("ACCEPTED:%lX\n", ntohl(farAddr.sin_addr.s_addr)); + spawnTask(workerTask, myPriority, s1); + } +} + +/* + * The real part of the client + */ +static rtems_task clientWorker(int arg) +{ + int s; + struct sockaddr_in myAddr, farAddr; + char cbuf[50]; + int i; + + s = socket(AF_INET, SOCK_STREAM, 0); + if (s < 0) { + printf("Can't create client socket: %s\n", strerror(errno)); + return; + } + memset(&myAddr, 0, sizeof myAddr); + myAddr.sin_family = AF_INET; + myAddr.sin_port = htons(0); + myAddr.sin_addr.s_addr = htonl(INADDR_ANY); + if (bind(s, (struct sockaddr *)&myAddr, sizeof myAddr) < 0) { + printf("Can't bind socket: %s\n", strerror(errno)); + goto close; + } + memset(&farAddr, 0, sizeof farAddr); + farAddr.sin_family = AF_INET; + farAddr.sin_port = htons(1234); + farAddr.sin_addr.s_addr = htonl(INADDR_ANY); + printf("Connect to server.\n"); + if (connect(s, (struct sockaddr *)&farAddr, sizeof farAddr) < 0) { + printf("Can't connect to server: %s\n", strerror(errno)); + goto close; + } + rtems_task_wake_after(20); /* Simulate client delay */ + i = sprintf(cbuf, "Hi there, server (%d).", arg); + i++; /* Send the '\0', too */ + printf("Write %d-byte message to server.\n", i); + if (write(s, cbuf, i) < 0) { + printf("Can't write to server: %s\n", strerror(errno)); + goto close; + } + if ((i = read(s, cbuf, sizeof cbuf)) < 0) { + printf("Can't read from server: %s\n", strerror(errno)); + goto close; + } + printf("Read %d from server: %.*s\n", i, i, cbuf); + rtems_task_wake_after(20); /* Simulate client delay */ + close: + printf("Client closing connection.\n"); + if (close(s) < 0) + printf("Can't close client task socket: %s\n", strerror(errno)); +} + +/* + * Client Task + */ +static rtems_task clientTask(rtems_task_argument arg) +{ + clientWorker(arg); + printf("Client task terminating.\n"); +} + +/* + * RTEMS Startup Task + */ +rtems_task +Init (rtems_task_argument ignored) +{ + rtems_status_code sc; + + sc = rtems_semaphore_create(rtems_build_name('P','m','t','x'), + 1, + RTEMS_PRIORITY|RTEMS_BINARY_SEMAPHORE|RTEMS_INHERIT_PRIORITY| + RTEMS_NO_PRIORITY_CEILING|RTEMS_LOCAL, + 0, + &printMutex); + if (sc != RTEMS_SUCCESSFUL) + rtems_panic("Can't create printf mutex:", rtems_status_text(sc)); + printf("\"Network\" initializing!\n"); + rtems_bsdnet_initialize_network(); + printf("\"Network\" initialized!\n"); + + printf("Try running client with no server present.\n"); + printf("Should fail with `connection refused'.\n"); + clientWorker(0); + + printf("\nStart server.\n"); + spawnTask(serverTask, 150, 0); + + printf("\nTry running client with server present.\n"); + spawnTask(clientTask, 120, 1); + rtems_task_wake_after(500); + + printf("\nTry running two clients.\n"); + spawnTask(clientTask, 120, 2); + spawnTask(clientTask, 120, 3); + rtems_task_wake_after(500); + + printf("\nTry running three clients.\n"); + spawnTask(clientTask, 120, 4); + spawnTask(clientTask, 120, 5); + spawnTask(clientTask, 120, 6); + + rtems_task_suspend(RTEMS_SELF); +} diff --git a/testsuites/samples/loopback/loopback.scn b/testsuites/samples/loopback/loopback.scn new file mode 100644 index 0000000000..ec6207f315 --- /dev/null +++ b/testsuites/samples/loopback/loopback.scn @@ -0,0 +1,56 @@ +"Network" initializing! +"Network" initialized! +Try running client with no server present. +Should fail with `connection refused'. +Connect to server. +Can't connect to server: Connection refused +Client closing connection. + +Start server. + +Try running client with server present. +Create socket. +Connect to server. +Bind socket. +Can't connect to server: Connection refused +Client closing connection. +Client task terminating. + +Try running two clients. +Connect to server. +Connect to server. +ACCEPTED:7F000001 +ACCEPTED:7F000001 +Write 22-byte message to server. +Write 22-byte message to server. +Read 43 from server: Server received 22 (Hi there, server (2).) +Read 43 from server: Server received 22 (Hi there, server (3).) +Client closing connection. +Client task terminating. +Worker task terminating. +Client closing connection. +Client task terminating. +Worker task terminating. + +Try running three clients. +Connect to server. +Connect to server. +Connect to server. +ACCEPTED:7F000001 +ACCEPTED:7F000001 +ACCEPTED:7F000001 +Write 22-byte message to server. +Write 22-byte message to server. +Write 22-byte message to server. +Read 43 from server: Server received 22 (Hi there, server (4).) +Read 43 from server: Server received 22 (Hi there, server (5).) +Read 43 from server: Server received 22 (Hi there, server (6).) +Client closing connection. +Client task terminating. +Worker task terminating. +Client closing connection. +Client task terminating. +Worker task terminating. +Client closing connection. +Client task terminating. +Worker task terminating. -- cgit v1.2.3