URL
https://opencores.org/ocsvn/openrisc/openrisc/trunk
Subversion Repositories openrisc
[/] [openrisc/] [trunk/] [rtos/] [ecos-3.0/] [packages/] [net/] [common/] [current/] [tests/] [tcp_lo_test.c] - Rev 786
Compare with Previous | Blame | View Log
//========================================================================== // // tests/tcp_lo_test.c // // Simple TCP throughput test // //========================================================================== // ####BSDALTCOPYRIGHTBEGIN#### // ------------------------------------------- // Portions of this software may have been derived from FreeBSD, OpenBSD, // or other sources, and if so are covered by the appropriate copyright // and license included herein. // ------------------------------------------- // ####BSDALTCOPYRIGHTEND#### //========================================================================== //#####DESCRIPTIONBEGIN#### // // Author(s): sorin@netappi.com // Contributors: gthomas,sorin@netappi.com, hmt // Date: 2000-05-24 // Network throughput test code #include <network.h> #include <cyg/infra/testcase.h> #define SOURCE_PORT 9990 #define SINK_PORT 9991 #define NUM_BUF 1024 #define MAX_BUF 8192 static unsigned char data_buf[MAX_BUF]; static unsigned char data_buf_write[MAX_BUF]="Client is alive. You may continue ...."; #define STACK_SIZE (CYGNUM_HAL_STACK_SIZE_TYPICAL + 0x10000) static char stack_server[STACK_SIZE]; static cyg_thread server_thread_data; static cyg_handle_t server_thread_handle; static char stack_client[STACK_SIZE]; static cyg_thread client_thread_data; static cyg_handle_t client_thread_handle; #define MAIN_THREAD_PRIORITY CYGPKG_NET_THREAD_PRIORITY-4 void pexit(char *s) { CYG_TEST_FAIL_FINISH( s ); } void server(void) { int s_source, e_source; struct sockaddr_in e_source_addr, local; int one = 1; fd_set in_fds; socklen_t len; char *hello_string=" Hello eCos network \n"; diag_printf("TCP SERVER:"); diag_printf(hello_string); s_source = socket(AF_INET, SOCK_STREAM, 0); if (s_source < 0) { pexit("stream socket"); } if (setsockopt(s_source, SOL_SOCKET, SO_REUSEADDR, &one, sizeof(one))) { pexit("setsockopt /source/ SO_REUSEADDR"); } if (setsockopt(s_source, SOL_SOCKET, SO_REUSEPORT, &one, sizeof(one))) { pexit("setsockopt /source/ SO_REUSEPORT"); } memset(&local, 0, sizeof(local)); local.sin_family = AF_INET; local.sin_len = sizeof(local); local.sin_port = ntohs(SOURCE_PORT); local.sin_addr.s_addr = htonl(INADDR_LOOPBACK); if(bind(s_source, (struct sockaddr *) &local, sizeof(local)) < 0) { pexit("bind /source/ error"); } listen(s_source, SOMAXCONN); e_source = 0; while (true) { FD_ZERO(&in_fds); FD_SET(s_source, &in_fds); len = sizeof(e_source_addr); if ((e_source = accept(s_source,(struct sockaddr *)&e_source_addr,&len))<0) { pexit("accept /source/"); } diag_printf("TCP SERVER connection from %s: %d\n", inet_ntoa(e_source_addr.sin_addr),ntohs(e_source_addr.sin_port)); if (e_source != 0) { break; } } /* while (true) */ if ((len = read(e_source, data_buf, MAX_BUF)) < 0 ) { CYG_TEST_FAIL_FINISH( "I/O error" ); } diag_printf("SERVER : %s\n",data_buf); } void client(void) { int s_source; struct sockaddr_in local; int len; diag_printf("client:started\n"); s_source = socket(AF_INET, SOCK_STREAM, 0); if (s_source < 0) { pexit("stream socket"); } memset(&local, 0, sizeof(local)); local.sin_family = AF_INET; local.sin_len = sizeof(local); local.sin_port = htons(SOURCE_PORT); local.sin_addr.s_addr = htonl(INADDR_LOOPBACK); if (connect(s_source, (struct sockaddr *)&local, sizeof(local)) < 0) { pexit("Can't connect to target"); } if ((len = write(s_source,data_buf_write,40)) < 0){ CYG_TEST_FAIL_FINISH( "Error writing buffer"); } } void tcp_server(cyg_addrword_t param) { init_all_network_interfaces(); diag_printf("Start TCP server - test\n"); cyg_thread_resume(client_thread_handle); // Start it #if NLOOP > 0 server(); CYG_TEST_PASS_FINISH( "server returned OK" ); #endif CYG_TEST_NA( "No loopback devs" ); } void tcp_client(cyg_addrword_t param) { diag_printf("Start TCP client - test\n"); #if NLOOP > 0 client(); #endif } void cyg_start(void) { CYG_TEST_INIT(); cyg_thread_create(MAIN_THREAD_PRIORITY, // Priority tcp_server, // entry 0, // entry parameter "TCP loopback server", // Name &stack_server[0], // Stack STACK_SIZE, // Size &server_thread_handle, // Handle &server_thread_data // Thread data structure ); cyg_thread_resume(server_thread_handle); // Start it cyg_thread_create(MAIN_THREAD_PRIORITY, // Priority tcp_client, // entry 0, // entry parameter "TCP loopback client", // Name &stack_client[0], // Stack STACK_SIZE, // Size &client_thread_handle, // Handle &client_thread_data // Thread data structure ); cyg_scheduler_start(); }